ref(entities): deepen the model

Author: emptybutton

pyproject.toml

@@ -76,7 +76,6 @@ lines-after-imports = 2
 "src/tgdb/entities/*" = ["PLR2004"]
 "src/tgdb/application/*" = ["PLR0917"]
 "src/tgdb/infrastructure/adapters/*" = ["RUF029"]
-"src/tgdb/entities/horizon/transaction.py" = ["SLF001"]
 "tests/*" = ["PLR0124", "PLR0917", "S106", "C901", "PLR2004"]
 "__init__.py" = ["PLC0414"]
 

src/tgdb/application/input_operator.py

@@ -9,14 +9,14 @@
 from tgdb.application.ports.operator_serialization import OperatorSerialization
 from tgdb.application.ports.shared_horizon import SharedHorizon
 from tgdb.entities.operator import AppliedOperator
-from tgdb.entities.transaction import TransactionPreparedCommit
+from tgdb.entities.transaction import TransactionCommit
 
 
 @dataclass(frozen=True)
 class InputOperator[SerializedOperatorsT]:
     clock: LogicClock
     operator_serialization: OperatorSerialization[SerializedOperatorsT]
-    commit_buffer: Buffer[TransactionPreparedCommit]
+    commit_buffer: Buffer[TransactionCommit]
     shared_horizon: SharedHorizon
 
     async def __call__(

src/tgdb/application/output_commits.py

@@ -6,16 +6,16 @@
 from tgdb.application.ports.queque import Queque
 from tgdb.application.ports.shared_horizon import SharedHorizon
 from tgdb.entities.transaction import (
-    TransactionOkPreparedCommit,
-    TransactionPreparedCommit,
+    TransactionCommit,
+    TransactionCommit,
 )
 
 
 @dataclass(frozen=True)
 class OutputCommits:
-    commit_buffer: Buffer[TransactionPreparedCommit]
-    notifying: Notifying[Sequence[TransactionPreparedCommit]]
-    output_commits: Queque[Sequence[TransactionOkPreparedCommit]]
+    commit_buffer: Buffer[TransactionCommit]
+    notifying: Notifying[Sequence[TransactionCommit]]
+    output_commits: Queque[Sequence[TransactionCommit]]
     shared_horizon: SharedHorizon
 
     async def __call__(self) -> None:
@@ -24,7 +24,7 @@ async def __call__(self) -> None:
 
             ok_prepared_commits = tuple(
                 commit for commit in prepared_commits
-                if isinstance(commit, TransactionOkPreparedCommit)
+                if isinstance(commit, TransactionCommit)
             )
 
             await self.output_commits.push(ok_prepared_commits)

src/tgdb/application/output_commits_to_heap.py

@@ -3,13 +3,13 @@
 
 from tgdb.application.ports.heap import Heap
 from tgdb.application.ports.queque import Queque
-from tgdb.entities.transaction import TransactionOkPreparedCommit
+from tgdb.entities.transaction import TransactionCommit
 
 
 @dataclass(frozen=True)
 class OutputCommitsToHeap:
     heap: Heap
-    output_commits: Queque[Sequence[TransactionOkPreparedCommit]]
+    output_commits: Queque[Sequence[TransactionCommit]]
 
     async def __call__(self) -> None:
         async for commits in self.output_commits:

src/tgdb/entities/__init__.py

@@ -0,0 +1,11 @@
+from time import monotonic_ns
+
+
+n = 100_000
+
+x = monotonic_ns()
+frozenset(range(n)) & frozenset(range(n * 2))
+print(monotonic_ns() - x)
+
+
+# 1 000 000 000

src/tgdb/entities/horizon/__init__.py

@@ -0,0 +1 @@
+