feat(commit_transaction): show InvalidRelationTupleError

Author: emptybutton

src/tgdb/application/horizon/commit_transaction.py

@@ -38,6 +38,7 @@ class CommitTransaction:
     async def __call__(self, xid: XID, operators: Sequence[Operator]) -> None:
         """
         :raises tgdb.application.relation.ports.relations.NoRelationError:
+        :raises tgdb.entities.relation.tuple_effect.InvalidRelationTupleError:
         :raises tgdb.entities.horizon.horizon.NoTransactionError:
         :raises tgdb.entities.horizon.horizon.TransactionCommittingError:
         :raises tgdb.entities.horizon.transaction.ConflictError:
@@ -61,6 +62,7 @@ async def _effect(
     ) -> NewTuple | MutatedTuple | DeletedTuple | Claim:
         """
         :raises tgdb.application.relation.ports.relations.NoRelationError:
+        :raises tgdb.entities.relation.tuple_effect.InvalidRelationTupleError:
         """
 
         match operator:

src/tgdb/presentation/fastapi/horizon/routes/commit_transaction.py

@@ -14,6 +14,9 @@
     TransactionCommittingSchema,
     TransactionConflictSchema,
 )
+from tgdb.presentation.fastapi.relation.schemas.error import (
+    InvalidRelationTupleSchema,
+)
 
 
 commit_transaction_router = APIRouter()
@@ -42,7 +45,9 @@ class CommitTransactionSchema(BaseModel):
     responses={
         status.HTTP_204_NO_CONTENT: {"content": None},
         status.HTTP_404_NOT_FOUND: {"model": NoTransactionSchema},
-        status.HTTP_400_BAD_REQUEST: {"model": TransactionCommittingSchema},
+        status.HTTP_400_BAD_REQUEST: {
+            "model": InvalidRelationTupleSchema | TransactionCommittingSchema
+        },
         status.HTTP_409_CONFLICT: {"model": TransactionConflictSchema},
     },
     summary="Commit transaction",

src/tgdb/presentation/fastapi/relation/error_handling.py

@@ -6,7 +6,9 @@
     NotUniqueRelationNumberError,
 )
 from tgdb.application.relation.ports.tuples import OversizedRelationSchemaError
+from tgdb.entities.relation.tuple_effect import InvalidRelationTupleError
 from tgdb.presentation.fastapi.relation.schemas.error import (
+    InvalidRelationTupleSchema,
     NoRelationSchema,
     NotUniqueRelationNumberSchema,
     OversizedRelationSchemaSchema,
@@ -40,3 +42,12 @@ def _(_: object, error: OversizedRelationSchemaError) -> Response:
             schema.model_dump(mode="json", by_alias=True),
             status_code=status.HTTP_400_BAD_REQUEST,
         )
+
+    @app.exception_handler(InvalidRelationTupleError)
+    def _(_: object, error: InvalidRelationTupleError) -> Response:
+        schema = InvalidRelationTupleSchema.of(error)
+
+        return JSONResponse(
+            schema.model_dump(mode="json", by_alias=True),
+            status_code=status.HTTP_400_BAD_REQUEST,
+        )

src/tgdb/presentation/fastapi/relation/schemas/error.py

@@ -1,8 +1,12 @@
-from typing import Literal
+from typing import Annotated, Literal
 
+from annotated_types import Ge
 from pydantic import BaseModel, Field
 
 from tgdb.application.relation.ports.tuples import OversizedRelationSchemaError
+from tgdb.entities.relation.scalar import Scalar
+from tgdb.entities.relation.tuple import TID
+from tgdb.entities.relation.tuple_effect import InvalidRelationTupleError
 
 
 class NoRelationSchema(BaseModel):
@@ -30,3 +34,20 @@ def of(
             schemaSize=error.schema_size,
             schemaMaxSize=error.schema_max_size,
         )
+
+
+class InvalidRelationTupleSchema(BaseModel):
+    type: Literal["invalidRelationTuple"] = "invalidRelationTuple"
+    tid: TID
+    scalars: tuple[Scalar, ...]
+    relation_number: Annotated[int, Ge(0)]
+
+    @classmethod
+    def of(
+        cls, error: InvalidRelationTupleError
+    ) -> "InvalidRelationTupleSchema":
+        return InvalidRelationTupleSchema(
+            tid=error.tid,
+            scalars=error.scalars,
+            relation_number=int(error.relation_number),
+        )