ISSUE #98

* Remove tests code duplication.

Author: Sergio García Prado

packages/core/minos-microservice-aggregate/minos/aggregate/testing/__init__.py

@@ -1,9 +1,12 @@
-from .event_repository import (
+from .events import (
     EventRepositoryTestCase,
+    MockedEventDatabaseOperationFactory,
 )
-from .snapshot_repository import (
+from .snapshots import (
+    MockedSnapshotDatabaseOperationFactory,
     SnapshotRepositoryTestCase,
 )
-from .transaction_repository import (
+from .transactions import (
+    MockedTransactionDatabaseOperationFactory,
     TransactionRepositoryTestCase,
 )

packages/core/minos-microservice-aggregate/minos/aggregate/testing/events/__init__.py

@@ -0,0 +1,4 @@
+from .repositories import (
+    EventRepositoryTestCase,
+    MockedEventDatabaseOperationFactory,
+)

packages/core/minos-microservice-aggregate/minos/aggregate/testing/events/repositories/__init__.py

@@ -0,0 +1,6 @@
+from .factories import (
+    MockedEventDatabaseOperationFactory,
+)
+from .testcases import (
+    EventRepositoryTestCase,
+)

packages/core/minos-microservice-aggregate/minos/aggregate/testing/events/repositories/factories.py

@@ -0,0 +1,77 @@
+from datetime import (
+    datetime,
+)
+from typing import (
+    Optional,
+)
+from uuid import (
+    UUID,
+)
+
+from minos.common import (
+    DatabaseOperation,
+)
+from minos.common.testing import (
+    MockedDatabaseClient,
+    MockedDatabaseOperation,
+)
+
+from ....actions import (
+    Action,
+)
+from ....events import (
+    EventDatabaseOperationFactory,
+)
+
+
+class MockedEventDatabaseOperationFactory(EventDatabaseOperationFactory):
+    """For testing purposes."""
+
+    def build_create(self) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("create")
+
+    def build_submit(
+        self,
+        transaction_uuids: tuple[UUID],
+        uuid: UUID,
+        action: Action,
+        name: str,
+        version: int,
+        data: bytes,
+        created_at: datetime,
+        transaction_uuid: UUID,
+        lock: Optional[int],
+        **kwargs,
+    ) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("submit")
+
+    def build_query(
+        self,
+        uuid: Optional[UUID] = None,
+        name: Optional[str] = None,
+        version: Optional[int] = None,
+        version_lt: Optional[int] = None,
+        version_gt: Optional[int] = None,
+        version_le: Optional[int] = None,
+        version_ge: Optional[int] = None,
+        id: Optional[int] = None,
+        id_lt: Optional[int] = None,
+        id_gt: Optional[int] = None,
+        id_le: Optional[int] = None,
+        id_ge: Optional[int] = None,
+        transaction_uuid: Optional[UUID] = None,
+        transaction_uuid_ne: Optional[UUID] = None,
+        transaction_uuid_in: Optional[tuple[UUID, ...]] = None,
+        **kwargs,
+    ) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("select_rows")
+
+    def build_query_offset(self) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("select_max_id")
+
+
+MockedDatabaseClient.set_factory(EventDatabaseOperationFactory, MockedEventDatabaseOperationFactory)

packages/core/minos-microservice-aggregate/minos/aggregate/testing/event_repository.py renamed to packages/core/minos-microservice-aggregate/minos/aggregate/testing/events/repositories/testcases.py

@@ -0,0 +1,4 @@
+from .repositories import (
+    MockedSnapshotDatabaseOperationFactory,
+    SnapshotRepositoryTestCase,
+)

packages/core/minos-microservice-aggregate/minos/aggregate/testing/snapshots/__init__.py

@@ -0,0 +1,6 @@
+from .factories import (
+    MockedSnapshotDatabaseOperationFactory,
+)
+from .testcases import (
+    SnapshotRepositoryTestCase,
+)

packages/core/minos-microservice-aggregate/minos/aggregate/testing/snapshots/repositories/__init__.py

@@ -0,0 +1,78 @@
+from collections.abc import (
+    Iterable,
+)
+from datetime import (
+    datetime,
+)
+from typing import (
+    Any,
+    Optional,
+)
+from uuid import (
+    UUID,
+)
+
+from minos.common import (
+    DatabaseOperation,
+)
+from minos.common.testing import (
+    MockedDatabaseClient,
+    MockedDatabaseOperation,
+)
+
+from ....queries import (
+    _Condition,
+    _Ordering,
+)
+from ....snapshots import (
+    SnapshotDatabaseOperationFactory,
+)
+
+
+class MockedSnapshotDatabaseOperationFactory(SnapshotDatabaseOperationFactory):
+    """For testing purposes."""
+
+    def build_create(self) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("create")
+
+    def build_delete(self, transaction_uuids: Iterable[UUID]) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("delete")
+
+    def build_submit(
+        self,
+        uuid: UUID,
+        name: str,
+        version: int,
+        schema: bytes,
+        data: dict[str, Any],
+        created_at: datetime,
+        updated_at: datetime,
+        transaction_uuid: UUID,
+    ) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("insert")
+
+    def build_query(
+        self,
+        name: str,
+        condition: _Condition,
+        ordering: Optional[_Ordering],
+        limit: Optional[int],
+        transaction_uuids: tuple[UUID, ...],
+        exclude_deleted: bool,
+    ) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("query")
+
+    def build_submit_offset(self, value: int) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("store_offset")
+
+    def build_query_offset(self) -> DatabaseOperation:
+        """For testing purposes."""
+        return MockedDatabaseOperation("get_offset")
+
+
+MockedDatabaseClient.set_factory(SnapshotDatabaseOperationFactory, MockedSnapshotDatabaseOperationFactory)