progress action logic

chain_service/services/progress_action/base.py

@@ -0,0 +1,9 @@
+from abc import ABC, abstractmethod
+from chain_service.database.models.progress_chain import BaseProgressAction
+
+
+class BaseProgressActionService(ABC):
+
+    @abstractmethod
+    async def process(self, progress_action: BaseProgressAction):
+        pass

chain_service/services/progress_action/comment_progress_action.py

@@ -0,0 +1,8 @@
+from .base import BaseProgressActionService
+from chain_service.database.models.progress_chain import CommentProgressAction
+
+
+class CommentProgressActionService(BaseProgressActionService):
+
+    async def process(self, progress_action: CommentProgressAction):
+        print("Comment service", progress_action)

chain_service/services/progress_action/factory.py

@@ -0,0 +1,20 @@
+from chain_service.database.models.progress_chain import BaseProgressAction
+
+from .base import BaseProgressActionService
+from .wait_progress_action import WaitProgressActionService
+from .comment_progress_action import CommentProgressActionService
+
+
+class ProgressActionServiceFactory:
+
+    def __call__(
+        self, progress_action: BaseProgressAction
+    ) -> BaseProgressActionService:
+
+        match progress_action.action_type:
+
+            case "wait":
+                return WaitProgressActionService()
+
+            case "comment":
+                return CommentProgressActionService()

chain_service/services/progress_action/wait_progress_action.py

@@ -0,0 +1,10 @@
+from .base import BaseProgressActionService
+from chain_service.database.models.progress_chain import WaitProgressAction
+
+import asyncio
+
+
+class WaitProgressActionService(BaseProgressActionService):
+
+    async def process(self, progress_action: WaitProgressAction):
+        await asyncio.sleep(progress_action.wait_for)