fix(ReadUncommitedTransaction): remove constant zero effect

Author: emptybutton

src/tgdb/entities/horizon/transaction.py

@@ -231,7 +231,7 @@ def _complete(self) -> None:
 class ReadUncommitedTransaction:
     _xid: XID
     _start_time: LogicTime
-    _space: dict[TID, TupleEffect]
+    _space: dict[TID, TransactionScalarEffect]
 
     def xid(self) -> XID:
         return self._xid
@@ -255,7 +255,7 @@ def rollback(self) -> None:
         ...
 
     def commit(self) -> Commit:
-        return Commit(self._xid, frozenset())
+        return Commit(self._xid, frozenset(self._space.values()))
 
     @classmethod
     def start(

src/tgdb/entities/relation/tuple_effect.py

@@ -19,7 +19,7 @@ def __and__(self, effect: "TupleEffect") -> "TupleEffect":
 class NewTuple:
     tuple: Tuple
 
-    def __and__(self, effect: "TupleEffect") -> "TupleEffect":
+    def __and__(self, effect: "TupleEffect") -> "NewTuple | DeletedTuple":
         match effect:
             case JustViewedTuple():
                 return self
@@ -37,7 +37,7 @@ def tid(self) -> TID:
 class MutatedTuple:
     tuple: Tuple
 
-    def __and__(self, effect: "TupleEffect") -> "TupleEffect":
+    def __and__(self, effect: "TupleEffect") -> "MutatedTuple | DeletedTuple | MigratedTuple":
         match effect:
             case JustViewedTuple():
                 return self
@@ -55,13 +55,13 @@ def tid(self) -> TID:
 class MigratedTuple:
     tuple: Tuple
 
-    def __and__(self, effect: "TupleEffect") -> "TupleEffect":
+    def __and__(self, effect: "TupleEffect") -> "MutatedTuple | MigratedTuple | DeletedTuple":
         match effect:
             case JustViewedTuple():
                 return self
             case NewTuple(tuple):
                 return MutatedTuple(tuple)
-            case MutatedTuple() | DeletedTuple() | MigratedTuple():
+            case MutatedTuple() | MigratedTuple() | DeletedTuple():
                 return effect
 
     @property
@@ -73,7 +73,7 @@ def tid(self) -> TID:
 class DeletedTuple:
     tid: TID
 
-    def __and__(self, effect: "TupleEffect") -> "TupleEffect":
+    def __and__(self, effect: "TupleEffect") -> "DeletedTuple | MutatedTuple":
         match effect:
             case (
                 JustViewedTuple()

tests/test_tgdb/test_entities/test_horizon/test_horizon.py

@@ -590,3 +590,18 @@ def test_no_memory_leak(horizon: Horizon) -> None:
         horizon.complete_commit(time, commit.xid)
 
     assert not live_transactions
+
+
+def test_read_uncommited_commit(horizon: Horizon) -> None:
+    """
+    |--|
+    """
+
+    horizon.start_transaction(1, UUID(int=1), IsolationLevel.read_uncommited)
+    commit = horizon.commit_transaction(
+        2, UUID(int=1), [MutatedTuple(tuple_(tid=UUID(int=2)))]
+    )
+
+    assert commit == Commit(
+        UUID(int=1), frozenset({MutatedTuple(tuple_(tid=UUID(int=2)))})
+    )