ISSUE #51

* Add `build_create` method to the `SagaExecutionDatabaseOperationFactory` interface.

Author: Sergio García Prado

packages/core/minos-microservice-saga/minos/saga/executions/repositories/database/factories.py

@@ -15,6 +15,13 @@
 class SagaExecutionDatabaseOperationFactory(DatabaseOperationFactory, ABC):
     """Saga Execution Database Operation Factory class."""
 
+    @abstractmethod
+    def build_create(self) -> DatabaseOperation:
+        """Build the database operation to create the delta table.
+
+        :return: A ``DatabaseOperation`` instance.s
+        """
+
     @abstractmethod
     def build_store(self, uuid: UUID, **kwargs) -> DatabaseOperation:
         """Build the database operation to store a saga execution.

packages/core/minos-microservice-saga/minos/saga/executions/repositories/database/impl.py

@@ -36,6 +36,12 @@ def __init__(self, *args, database_key: Optional[tuple[str]] = None, **kwargs):
             database_key = ("saga",)
         super().__init__(*args, database_key=database_key, **kwargs)
 
+    async def _setup(self) -> None:
+        await super()._setup()
+
+        operation = self.database_operation_factory.build_create()
+        await self.execute_on_database(operation)
+
     async def _store(self, execution: SagaExecution) -> None:
         operation = self.database_operation_factory.build_store(**execution.raw)
         await self.execute_on_database(operation)

packages/core/minos-microservice-saga/minos/saga/testing.py

@@ -35,6 +35,10 @@
 class MockedSagaExecutionDatabaseOperationFactory(SagaExecutionDatabaseOperationFactory):
     """For testing purposes"""
 
+    def build_create(self) -> DatabaseOperation:
+        """For testing purposes"""
+        return MockedDatabaseOperation("create_table")
+
     def build_store(self, uuid: UUID, **kwargs) -> DatabaseOperation:
         """For testing purposes"""
         return MockedDatabaseOperation("create_table")

packages/core/minos-microservice-saga/tests/test_saga/test_executions/test_repositories/test_database/test_factories.py

@@ -16,7 +16,8 @@ def test_abstract(self):
         self.assertTrue(issubclass(SagaExecutionDatabaseOperationFactory, (DatabaseOperationFactory, ABC)))
         # noinspection PyUnresolvedReferences
         self.assertEqual(
-            {"build_store", "build_load", "build_delete"}, SagaExecutionDatabaseOperationFactory.__abstractmethods__
+            {"build_create", "build_store", "build_load", "build_delete"},
+            SagaExecutionDatabaseOperationFactory.__abstractmethods__,
         )
 
 

packages/plugins/minos-database-lmdb/minos/plugins/lmdb/factories/saga/executions.py

@@ -3,6 +3,7 @@
 )
 
 from minos.common import (
+    ComposedDatabaseOperation,
     DatabaseOperation,
 )
 from minos.saga import (
@@ -29,6 +30,13 @@ def build_table_name(self) -> str:
         """
         return "LocalState"
 
+    def build_create(self) -> DatabaseOperation:
+        """Build the database operation to create the delta table.
+
+        :return: A ``DatabaseOperation`` instance.s
+        """
+        return ComposedDatabaseOperation([])  # FIXME: create specific empty operation.
+
     def build_store(self, uuid: UUID, **kwargs) -> DatabaseOperation:
         """Build the database operation to store a saga execution.