fix(infrastructure): fix postgres io details (#62)

Author: emptybutton

src/ttt/infrastructure/adapters/games.py

@@ -28,10 +28,18 @@ async def current_user_game(self, user_id: int, /) -> Game | None:
         return table_game.entity()
 
     async def not_locked_game_with_id(self, game_id: UUID, /) -> Game | None:
+        lock_stmt = (
+            select(1)
+            .select_from(TableGame)
+            .where(TableGame.id == game_id)
+            .with_for_update()
+        )
         stmt = (
             select(TableGame)
             .where(TableGame.id == game_id)
-            .with_for_update()
         )
+
+        await self._session.execute(lock_stmt)
         table_game = await self._session.scalar(stmt)
+
         return None if table_game is None else table_game.entity()

src/ttt/infrastructure/adapters/transaction.py

@@ -38,7 +38,7 @@ async def __aexit__(
             return
 
         with reraise_serialization_error():
-            if error is None:
+            if error is None and transaction.is_active:
                 await transaction.commit()
             else:
                 await transaction.rollback()
@@ -71,7 +71,7 @@ async def __aexit__(
         if transaction is None:
             return
 
-        if error is None:
+        if error is None and transaction.is_active:
             await transaction.commit()
         else:
             await transaction.rollback()
@@ -102,7 +102,7 @@ async def __aexit__(
         if transaction is None:
             return
 
-        if error is None:
+        if error is None and transaction.is_active:
             await transaction.commit()
         else:
             await transaction.rollback()