ISSUE #198

* Rename classes.

Author: Sergio García Prado

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

@@ -25,12 +25,12 @@
     RemoteSagaStepMeta,
     RemoteSagaStepWrapper,
     Saga,
-    SagaMeta,
+    SagaClassMeta,
+    SagaClassWrapper,
     SagaOperation,
     SagaStep,
     SagaStepMeta,
     SagaStepWrapper,
-    SagaWrapper,
 )
 from .exceptions import (
     AlreadyCommittedException,

packages/core/minos-microservice-saga/minos/saga/definitions/__init__.py

@@ -3,8 +3,8 @@
 )
 from .saga import (
     Saga,
-    SagaMeta,
-    SagaWrapper,
+    SagaClassMeta,
+    SagaClassWrapper,
 )
 from .steps import (
     ConditionalSagaStep,

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

@@ -48,13 +48,13 @@
 
 
 @runtime_checkable
-class SagaWrapper(Protocol):
+class SagaClassWrapper(Protocol):
     """TODO"""
 
-    meta: SagaMeta
+    meta: SagaClassMeta
 
 
-class SagaMeta:
+class SagaClassMeta:
     """TODO"""
 
     _class: SagaClass
@@ -111,8 +111,8 @@ def __init__(
             self.local_step(commit)
             self.committed = True
 
-    def __call__(self, type_: TP) -> Union[TP, SagaWrapper]:
-        type_.meta = SagaMeta(type_, self)
+    def __call__(self, type_: TP) -> Union[TP, SagaClassWrapper]:
+        type_.meta = SagaClassMeta(type_, self)
         return type_
 
     @classmethod

packages/core/minos-microservice-saga/minos/saga/executions/runners.py

@@ -37,7 +37,7 @@
 )
 from ..definitions import (
     Saga,
-    SagaWrapper,
+    SagaClassWrapper,
 )
 from ..exceptions import (
     SagaFailedExecutionException,
@@ -85,7 +85,7 @@ def __init__(
 
     async def run(
         self,
-        definition: Optional[Union[Saga, SagaWrapper]] = None,
+        definition: Optional[Union[Saga, SagaClassWrapper]] = None,
         context: Optional[SagaContext] = None,
         *,
         response: Optional[SagaResponse] = None,
@@ -115,7 +115,7 @@ async def run(
         :param kwargs: Additional named arguments.
         :return: This method does not return anything.
         """
-        if isinstance(definition, SagaWrapper):
+        if isinstance(definition, SagaClassWrapper):
             definition = definition.meta.definition
 
         if response is not None:

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

@@ -21,7 +21,7 @@
 )
 
 from .. import (
-    SagaWrapper,
+    SagaClassWrapper,
 )
 from ..context import (
     SagaContext,
@@ -141,7 +141,7 @@ def from_saga(cls, definition: Saga, context: Optional[SagaContext] = None, *arg
     @classmethod
     def from_definition(
         cls,
-        definition: Union[Saga, SagaWrapper],
+        definition: Union[Saga, SagaClassWrapper],
         context: Optional[SagaContext] = None,
         uuid: Optional[UUID] = None,
         *args,
@@ -156,7 +156,7 @@ def from_definition(
         :param kwargs: Additional named arguments.
         :return: A new ``SagaExecution`` instance.
         """
-        if isinstance(definition, SagaWrapper):
+        if isinstance(definition, SagaClassWrapper):
             definition = definition.meta.definition
 
         if uuid is None:

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

@@ -22,7 +22,7 @@
 )
 from .definitions import (
     Saga,
-    SagaWrapper,
+    SagaClassWrapper,
 )
 from .executions import (
     DatabaseSagaExecutionRepository,
@@ -82,7 +82,7 @@ async def _destroy(self) -> None:
 
     async def run(
         self,
-        definition: Optional[Union[Saga, SagaWrapper]] = None,
+        definition: Optional[Union[Saga, SagaClassWrapper]] = None,
         context: Optional[SagaContext] = None,
         *,
         response: Optional[SagaResponse] = None,

packages/core/minos-microservice-saga/tests/test_saga/test_definitions/test_saga.py

@@ -14,14 +14,14 @@
     OrderPrecedenceException,
     RemoteSagaStep,
     Saga,
+    SagaClassMeta,
+    SagaClassWrapper,
     SagaContext,
     SagaException,
     SagaExecution,
-    SagaMeta,
     SagaNotCommittedException,
     SagaOperation,
     SagaStep,
-    SagaWrapper,
 )
 from tests.utils import (
     ADD_ORDER,
@@ -31,7 +31,7 @@
 )
 
 
-class TestSagaMeta(unittest.TestCase):
+class TestSagaClassMeta(unittest.TestCase):
     def test_constructor(self):
         @Saga()
         class _Foo:
@@ -41,10 +41,10 @@ class _Foo:
             def step(self, context: SagaContext) -> SagaContext:
                 """For testing purposes."""
 
-        self.assertIsInstance(_Foo, SagaWrapper)
+        self.assertIsInstance(_Foo, SagaClassWrapper)
 
         meta = _Foo.meta
-        self.assertIsInstance(meta, SagaMeta)
+        self.assertIsInstance(meta, SagaClassMeta)
         self.assertEqual(meta.definition, Saga().local_step(_Foo.step).commit())
 
     def test_definition_raises_order(self):