fix: 修复单测以适配 vectordb 接口重构，统一测试数据路径 (#333)

- 修复 filesystem stat 错误匹配，增加 "not found" 判断
- 为 AddResourceRequest 添加 model_validator 校验 path 参数
- 处理 queue manager 未初始化时 ObserverService 的异常
- 简化 vectordb record ID 生成逻辑，移除 owner_space
- 捕获 HTTP client close 时的 RuntimeError
- 统一测试数据路径至 test_data/ 目录
- 更新测试用例使用 get_context_by_uri() 等新接口
- 移除测试 mock 对 VikingDBInterface 的依赖

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

Author: qin-ctx

.gitignore

@@ -157,15 +157,6 @@ dmypy.json
 cython_debug/
 openviking/bin/
 test_scripts/
-test_large_scale_collection/
-
-# Test-generated directories
-.tmp_*/
-db_test_*/
-test_recall_collection/
-test_db_*/
-test_project_root/
-benchmark_stress_db/
 examples/data/
 openviking/_version.py
 specs/

openviking/server/routers/filesystem.py

@@ -74,7 +74,8 @@ async def stat(
         result = await service.fs.stat(uri, ctx=_ctx)
         return Response(status="ok", result=result)
     except AGFSClientError as e:
-        if "no such file or directory" in str(e).lower():
+        err_msg = str(e).lower()
+        if "not found" in err_msg or "no such file or directory" in err_msg:
             raise NotFoundError(uri, "file")
         raise
 

openviking/server/routers/resources.py

@@ -8,7 +8,7 @@
 from typing import Any, Optional
 
 from fastapi import APIRouter, Depends, File, UploadFile
-from pydantic import BaseModel
+from pydantic import BaseModel, model_validator
 
 from openviking.server.auth import get_request_context
 from openviking.server.dependencies import get_service
@@ -35,6 +35,12 @@ class AddResourceRequest(BaseModel):
     exclude: Optional[str] = None
     directly_upload_media: bool = True
 
+    @model_validator(mode="after")
+    def check_path_or_temp_path(self):
+        if not self.path and not self.temp_path:
+            raise ValueError("Either 'path' or 'temp_path' must be provided")
+        return self
+
 
 class AddSkillRequest(BaseModel):
     """Request model for add_skill."""

openviking/service/debug_service.py

@@ -81,7 +81,16 @@ def _dependencies_ready(self) -> bool:
     @property
     def queue(self) -> ComponentStatus:
         """Get queue status."""
-        observer = QueueObserver(get_queue_manager())
+        try:
+            qm = get_queue_manager()
+        except Exception:
+            return ComponentStatus(
+                name="queue",
+                is_healthy=False,
+                has_errors=True,
+                status="Not initialized",
+            )
+        observer = QueueObserver(qm)
         return ComponentStatus(
             name="queue",
             is_healthy=observer.is_healthy(),

openviking/storage/collection_schemas.py

@@ -204,8 +204,7 @@ async def on_dequeue(self, data: Optional[Dict[str, Any]]) -> Optional[Dict[str,
                 uri = inserted_data.get("uri")
                 if uri:
                     account_id = inserted_data.get("account_id", "default")
-                    owner_space = inserted_data.get("owner_space", "")
-                    id_seed = f"{account_id}:{owner_space}:{uri}"
+                    id_seed = f"{account_id}:{uri}"
                     inserted_data["id"] = hashlib.md5(id_seed.encode("utf-8")).hexdigest()
 
                 record_id = await self._vikingdb.upsert(inserted_data)

openviking_cli/client/http.py

@@ -183,7 +183,10 @@ async def initialize(self) -> None:
     async def close(self) -> None:
         """Close the HTTP client."""
         if self._http:
-            await self._http.aclose()
+            try:
+                await self._http.aclose()
+            except RuntimeError:
+                pass
             self._http = None
 
     # ============= Internal Helpers =============

tests/conftest.py

@@ -14,8 +14,8 @@
 from openviking import AsyncOpenViking
 
 # Test data root directory
-TEST_ROOT = Path(__file__).parent
-TEST_TMP_DIR = TEST_ROOT / ".tmp"
+PROJECT_ROOT = Path(__file__).parent.parent
+TEST_TMP_DIR = PROJECT_ROOT / "test_data" / "tmp"
 
 
 @pytest.fixture(scope="session")

tests/eval/test_ragas_basic.py

@@ -30,9 +30,9 @@ def test_generator_initialization():
 
 
 def test_pipeline_initialization():
-    pipeline = RAGQueryPipeline(config_path="./test.conf", data_path="./test_data")
+    pipeline = RAGQueryPipeline(config_path="./test.conf", data_path="./test_data/test_ragas")
     assert pipeline.config_path == "./test.conf"
-    assert pipeline.data_path == "./test_data"
+    assert pipeline.data_path == "./test_data/test_ragas"
     assert pipeline._client is None
 
 

tests/eval/test_ragas_validation.py

@@ -105,10 +105,10 @@ def test_pipeline_initialization():
 
     from openviking.eval.ragas.pipeline import RAGQueryPipeline
 
-    pipeline = RAGQueryPipeline(config_path="./test.conf", data_path="./test_data")
+    pipeline = RAGQueryPipeline(config_path="./test.conf", data_path="./test_data/test_ragas")
 
     assert pipeline.config_path == "./test.conf"
-    assert pipeline.data_path == "./test_data"
+    assert pipeline.data_path == "./test_data/test_ragas"
     assert pipeline._client is None
 
     print("  ✅ RAGQueryPipeline initialized successfully")

tests/integration/conftest.py

@@ -22,8 +22,8 @@
 from openviking.service.core import OpenVikingService
 from openviking_cli.session.user_id import UserIdentifier
 
-TEST_ROOT = Path(__file__).parent
-TEST_TMP_DIR = TEST_ROOT / ".tmp_integration"
+PROJECT_ROOT = Path(__file__).parent.parent.parent
+TEST_TMP_DIR = PROJECT_ROOT / "test_data" / "tmp_integration"
 
 
 @pytest.fixture(scope="session")