feat(ports): add details

Author: emptybutton

src/tgdb/application/output_commits.py

@@ -5,15 +5,12 @@
 from tgdb.application.ports.notifying import Notifying
 from tgdb.application.ports.queque import Queque
 from tgdb.application.ports.shared_horizon import SharedHorizon
-from tgdb.entities.transaction import (
-    TransactionCommit,
-    TransactionCommit,
-)
+from tgdb.entities.horizon.transaction import PreparedCommit
 
 
 @dataclass(frozen=True)
 class OutputCommits:
-    commit_buffer: Buffer[TransactionCommit]
+    commit_buffer: Buffer[PreparedCommit]
     notifying: Notifying[Sequence[TransactionCommit]]
     output_commits: Queque[Sequence[TransactionCommit]]
     shared_horizon: SharedHorizon

src/tgdb/application/ports/clock.py

@@ -0,0 +1,6 @@
+from collections.abc import Awaitable
+
+from tgdb.entities.time.logic_time import LogicTime
+
+
+class Clock(Awaitable[LogicTime]): ...

src/tgdb/application/ports/logic_clock.py

@@ -1,6 +1,11 @@
 from abc import ABC, abstractmethod
 
+from tgdb.entities.horizon.transaction import Commit, ConflictError, NonSerializableWriteTransactionError
 
-class Notifying[ValueT](ABC):
+
+type Publishable = Commit | ConflictError | NonSerializableWriteTransactionError
+
+
+class Notifying(ABC):
     @abstractmethod
-    async def publish(self, value: ValueT, /) -> None: ...
+    async def publish(self, value: Publishable, /) -> None: ...

src/tgdb/application/ports/notifying.py

@@ -1,7 +1,7 @@
-from abc import ABC, abstractmethod
-from contextlib import AbstractAsyncContextManager
+from abc import ABC
+from collections.abc import Awaitable
 
-from tgdb.entities.transaction_horizon import TransactionHorizon
+from tgdb.entities.horizon.horizon import Horizon
 
 
-class SharedHorizon(AbstractAsyncContextManager[TransactionHorizon], ABC): ...
+class SharedHorizon(Awaitable[Horizon], ABC): ...