feat: make it better, faster, stronger

Author: emptybutton

deployments/dev/lib_snake_case/Dockerfile deployments/dev/backend/Dockerfiledeployments/dev/lib_snake_case/Dockerfile renamed to deployments/dev/backend/Dockerfile

@@ -0,0 +1,3 @@
+app_api_id = 23598539
+app_api_hash = "6d9d7305ffc6f148dab120d24541b127"
+bot_token = "7795216733:AAE6w9ijwsmMDEXLna7-14LkkQC_wFirnyw"

…oyments/dev/lib_snake_case/entrypoint.sh deployments/dev/backend/entrypoint.shdeployments/dev/lib_snake_case/entrypoint.sh renamed to deployments/dev/backend/entrypoint.sh deployments/dev/lib_snake_case/entrypoint.sh renamed to deployments/dev/backend/entrypoint.sh

@@ -31,6 +31,7 @@ dev = [
     "dirty-equals==0.8.0",
     "httpx==0.27.2",
     "httpx-ws==0.7.2",
+    "pytest-timeout==2.4.0",
 ]
 
 [build-system]

deployments/dev/backend/tg_secrets.toml

@@ -0,0 +1,30 @@
+from dataclasses import dataclass
+
+from tgdb.application.ports.operator_serialization import OperatorSerialization
+from tgdb.application.ports.queque import Queque
+from tgdb.entities.operator import Operator
+
+
+class InputOperatorError(Exception): ...
+
+
+@dataclass(frozen=True)
+class InputOperator[SerializedOperatorsT]:
+    input_operators: Queque[Operator]
+    operator_serialization: OperatorSerialization[SerializedOperatorsT]
+
+    async def __call__(
+        self, serialized_operator: SerializedOperatorsT
+    ) -> None:
+        """
+        :raises tgdb.application.input_operator.InputOperatorError:
+        """
+
+        input_operator = await self.operator_serialization.deserialized(
+            serialized_operator
+        )
+
+        if input_operator is None:
+            raise InputOperatorError
+
+        await self.input_operators.push(input_operator)

pyproject.toml

@@ -2,7 +2,7 @@
 from dataclasses import dataclass
 
 from tgdb.application.ports.commit_serialization import CommitSerialization
-from tgdb.application.ports.sync_queque import SyncQueque
+from tgdb.application.ports.queque import Queque
 from tgdb.entities.transaction import TransactionCommit
 
 
@@ -11,7 +11,7 @@ class InvalidOperatorError(Exception): ...
 
 @dataclass(frozen=True)
 class OutputCommits[SerializedCommitT]:
-    output_commits: SyncQueque[TransactionCommit]
+    output_commits: Queque[TransactionCommit]
     commit_serialization: CommitSerialization[SerializedCommitT]
 
     async def __call__(self) -> AsyncIterable[SerializedCommitT]:

src/tgdb/application/input_operator.py

@@ -1,7 +1,7 @@
 from dataclasses import dataclass
 
 from tgdb.application.ports.heap import Heap
-from tgdb.application.ports.sync_queque import SyncQueque
+from tgdb.application.ports.queque import Queque
 from tgdb.entities.transaction import (
     TransactionCommit,
     TransactionOkCommit,
@@ -11,7 +11,7 @@
 @dataclass(frozen=True)
 class OutputCommitsToHeap:
     heap: Heap
-    output_commits: SyncQueque[TransactionCommit]
+    output_commits: Queque[TransactionCommit]
 
     async def __call__(self) -> None:
         async for commit in self.output_commits:

src/tgdb/application/input_operators.py

@@ -1,9 +1,8 @@
 from dataclasses import dataclass
 
 from tgdb.application.ports.log import Log
-from tgdb.application.ports.logic_clock import LogicClock
-from tgdb.application.ports.sync_queque import SyncQueque
-from tgdb.entities.operator import Operator, applied_operator
+from tgdb.application.ports.queque import Queque
+from tgdb.entities.operator import CommitOperator, StartOperator
 from tgdb.entities.transaction import (
     TransactionCommit,
     TransactionOkCommit,
@@ -12,25 +11,17 @@
 
 @dataclass(frozen=True)
 class OutputCommitsToLog:
-    clock: LogicClock
     log: Log
-    output_commits: SyncQueque[TransactionCommit]
+    output_commits: Queque[TransactionCommit]
 
     async def __call__(self) -> None:
         async for commit in self.output_commits:
             if not isinstance(commit, TransactionOkCommit):
                 continue
 
-            operators = (
-                Operator(effect, commit.transaction_id)
-                for effect in commit.effect
+            start_operator = StartOperator(commit.transaction_id)
+            commit_operator = CommitOperator(
+                commit.transaction_id, commit.effect
             )
 
-            chronology = await self.clock.chronology(len(commit.effect))
-
-            applied_operators = (
-                applied_operator(operator, time)
-                for operator, time in zip(operators, chronology, strict=True)
-            )
-
-            await self.log.push(*applied_operators)
+            await self.log.push_many((start_operator, commit_operator))