clear comments from the tests file

Author: HenokAsaye

backend/tests/conftest.py

@@ -8,7 +8,6 @@
 import pytest
 from fastapi.testclient import TestClient
 
-
 @pytest.fixture(scope="session")
 def app_instance():
     os.environ.setdefault("ENVIRONMENT", "development")
@@ -28,17 +27,14 @@ def app_instance():
 
     return app
 
-
 @pytest.fixture
 def test_org_id() -> UUID:
     return uuid4()
 
-
 @pytest.fixture
 def test_user_id() -> UUID:
     return uuid4()
 
-
 @pytest.fixture
 def auth_claims(test_user_id: UUID, test_org_id: UUID) -> dict:
     return {
@@ -50,13 +46,11 @@ def auth_claims(test_user_id: UUID, test_org_id: UUID) -> dict:
         "type": "access",
     }
 
-
 @pytest.fixture
 def api_client(app_instance) -> Iterator[TestClient]:
     with TestClient(app_instance) as client:
         yield client
 
-
 @pytest.fixture
 def authed_client(
     api_client: TestClient, auth_claims: dict, app_instance
@@ -70,21 +64,18 @@ async def _override() -> dict:
     yield api_client
     app_instance.dependency_overrides.pop(get_current_claims, None)
 
-
 @pytest.fixture
 def storage_dir(tmp_path: Path) -> Path:
     path = tmp_path / "object-storage"
     path.mkdir()
     os.environ["DOCUMENT_STORAGE_DIR"] = str(path)
     return path
 
-
 @pytest.fixture(autouse=True)
 def _clear_dependency_overrides(app_instance) -> Iterator[None]:
     yield
     app_instance.dependency_overrides.clear()
 
-
 @pytest.fixture
 def sample_text_bytes() -> bytes:
     return b"Hello MindVault.\n\nThis is a test document for chunking."

backend/tests/contract/test_object_storage_contract.py

@@ -6,7 +6,6 @@
 
 from app.adapters.outbound.storage.local_storage import LocalObjectStorage
 
-
 @pytest.mark.contract
 class TestObjectStorageContract:
     """Behaviors required by all ObjectStorage implementations."""

backend/tests/helpers/mocks.py

@@ -12,7 +12,6 @@
 from app.domain.entities.user import User
 from app.domain.value_objects.membership_status import MembershipStatus
 
-
 @dataclass
 class FakeUserRepo:
     by_email: dict[str, User] = field(default_factory=dict)
@@ -33,7 +32,6 @@ async def update_last_login(self, *, user_id: UUID) -> None:
         if user:
             user.last_login_at = user.last_login_at
 
-
 @dataclass
 class FakeOrgRepo:
     slugs: set[str] = field(default_factory=set)
@@ -47,7 +45,6 @@ async def create_org(self, *, org: Organization) -> Organization:
         self.orgs[org.id] = org
         return org
 
-
 @dataclass
 class FakeMembershipRepo:
     memberships: list[OrganizationMembership] = field(default_factory=list)
@@ -80,7 +77,6 @@ async def list_user_memberships(
     ) -> list[OrganizationMembership]:
         return [m for m in self.memberships if m.user_id == user_id]
 
-
 class FakeUoW:
     def __init__(
         self,
@@ -106,14 +102,12 @@ async def commit(self) -> None:
     async def rollback(self) -> None:
         pass
 
-
 def uow_factory(uow: FakeUoW):
     def _factory() -> FakeUoW:
         return uow
 
     return _factory
 
-
 @dataclass
 class FakeDocumentRepo:
     documents: dict[UUID, Document] = field(default_factory=dict)
@@ -185,7 +179,6 @@ def count_failed_by_org(self, org_id: str) -> int:
             if d.org_id == oid and d.status == DocumentStatus.FAILED
         )
 
-
 @dataclass
 class FakeChunkRepo:
     chunks: list[Any] = field(default_factory=list)
@@ -197,7 +190,6 @@ def count_by_org(self, org_id: str) -> int:
         oid = UUID(org_id) if isinstance(org_id, str) else org_id
         return sum(1 for c in self.chunks if c.org_id == oid)
 
-
 @dataclass
 class FakeSyncDocumentRepo:
     documents: dict[UUID, Document] = field(default_factory=dict)
@@ -224,7 +216,6 @@ def update_status(
             if token_count is not None:
                 doc.token_count = token_count
 
-
 @dataclass
 class FakeSyncChunkRepo:
     chunks: list[Any] = field(default_factory=list)
@@ -235,7 +226,6 @@ def add_many(self, chunks: list) -> None:
     def delete_by_document(self, *, document_id: UUID) -> None:
         self.chunks = [c for c in self.chunks if c.document_id != document_id]
 
-
 class FakeMemoryStorage:
     """Minimal ObjectStorage fake."""
 
@@ -254,12 +244,10 @@ def get_object(self, *, key: str) -> bytes:
     def delete_object(self, *, key: str) -> None:
         self._objects.pop(key, None)
 
-
 class FakeEmbedder:
     def embed_texts(self, texts: list[str]) -> list[list[float]]:
         return [[0.1, 0.2, 0.3] for _ in texts]
 
-
 class FakeVectorStore:
     def __init__(self) -> None:
         self.upserted: list[dict] = []
@@ -273,7 +261,6 @@ async def query_by_similarity(self, **kwargs: Any) -> list[dict]:
     async def delete_by_document_id(self, *, document_id: str, namespace: str) -> None:
         pass
 
-
 def make_document(
     *,
     org_id: UUID | None = None,

backend/tests/integration/test_auth_routes.py

@@ -15,7 +15,6 @@
 from app.infrastructure.di.container import Container
 from app.main import app
 
-
 @pytest.mark.integration
 def test_register_success(api_client, monkeypatch) -> None:
     class FakeRegister:
@@ -40,7 +39,6 @@ async def execute(self, command):
     assert "user_id" in data
     assert "default_org_id" in data
 
-
 @pytest.mark.integration
 def test_register_conflict_on_duplicate(api_client) -> None:
     class FailingRegister:
@@ -62,7 +60,6 @@ async def execute(self, command):
     app.dependency_overrides.pop(Container.get_register_user_service, None)
     assert response.status_code == 409
 
-
 @pytest.mark.integration
 def test_login_success(api_client) -> None:
     class FakeIAM:
@@ -82,13 +79,11 @@ async def login(self, **kwargs):
     assert response.status_code == 200
     assert response.json()["access_token"] == "access"
 
-
 @pytest.mark.integration
 def test_me_requires_auth(api_client) -> None:
     response = api_client.get("/api/v1/auth/me")
     assert response.status_code == 401
 
-
 @pytest.mark.integration
 def test_me_returns_claims(authed_client, auth_claims) -> None:
     response = authed_client.get("/api/v1/auth/me")
@@ -97,7 +92,6 @@ def test_me_returns_claims(authed_client, auth_claims) -> None:
     assert body["user_id"] == auth_claims["sub"]
     assert body["org_id"] == auth_claims["org_id"]
 
-
 @pytest.mark.integration
 def test_switch_org(authed_client, test_user_id, test_org_id) -> None:
     class FakeSwitch:

backend/tests/integration/test_chat_routes.py

@@ -9,7 +9,6 @@
 from app.infrastructure.di.container import Container
 from app.main import app
 
-
 @pytest.mark.integration
 def test_chat_streams_plain_text(authed_client) -> None:
     class FakeChatService:

backend/tests/integration/test_documents_routes.py

@@ -16,7 +16,6 @@
 
 ROUTES = "app.adapters.inbound.api.v1.routes_documents"
 
-
 @pytest.mark.integration
 def test_upload_document_accepted(authed_client, test_org_id, monkeypatch) -> None:
     doc = make_document(org_id=test_org_id)
@@ -35,7 +34,6 @@ async def execute(self, command):
     assert response.status_code == 202
     assert response.json()["id"] == str(doc.id)
 
-
 @pytest.mark.integration
 def test_upload_empty_file_400(authed_client, monkeypatch) -> None:
     service = IngestDocumentService(
@@ -53,7 +51,6 @@ def test_upload_empty_file_400(authed_client, monkeypatch) -> None:
     )
     assert response.status_code == 400
 
-
 @pytest.mark.integration
 def test_list_documents(authed_client, test_org_id, monkeypatch) -> None:
     doc = make_document(org_id=test_org_id)
@@ -68,7 +65,6 @@ def test_list_documents(authed_client, test_org_id, monkeypatch) -> None:
     assert body["total"] == 1
     assert body["items"][0]["id"] == str(doc.id)
 
-
 @pytest.mark.integration
 def test_get_document_not_found(authed_client, monkeypatch) -> None:
     monkeypatch.setattr(f"{ROUTES}.get_document_repository", lambda: FakeDocumentRepo())
@@ -78,7 +74,6 @@ def test_get_document_not_found(authed_client, monkeypatch) -> None:
     )
     assert response.status_code == 404
 
-
 @pytest.mark.integration
 def test_list_chunks(authed_client, test_org_id, monkeypatch) -> None:
     doc = make_document(org_id=test_org_id)

backend/tests/integration/test_health.py

@@ -4,7 +4,6 @@
 
 import pytest
 
-
 @pytest.mark.integration
 def test_health_returns_ok(api_client) -> None:
     response = api_client.get("/health")

backend/tests/integration/test_retrieval_policy.py

@@ -1,6 +1,5 @@
 """Integration tests for retrieval policy end-to-end flow."""
 
-
 class TestRetrievalPolicyIntegration:
     """Integration tests for complete retrieval pipeline."""
 

backend/tests/unit/adapters/test_infer_source_type.py

@@ -6,7 +6,6 @@
 
 from app.adapters.inbound.api.v1.routes_documents import _infer_source_type
 
-
 @pytest.mark.unit
 class TestInferSourceType:
     def test_from_pdf_content_type(self) -> None:

backend/tests/unit/adapters/test_key_retriever.py

@@ -1,6 +1,5 @@
 """Unit tests for key retriever adapter."""
 
-
 class TestKeyRetriever:
     """Tests for KeyRetriever class."""