fix: implement new io (#62)

Author: emptybutton

deploy/dev/nats/streams/game.json

@@ -0,0 +1,14 @@
+{
+    "name": "GAME",
+    "subjects": ["game.>"],
+    "retention": "limits",
+    "max_consumers": -1,
+    "max_msgs": -1,
+    "max_bytes": -1,
+    "max_age": 31536000000000000,
+    "max_msg_size": -1,
+    "storage": "file",
+    "discard": "old",
+    "num_replicas": 1,
+    "duplicate_window": 0
+}

deploy/dev/nats/streams/stars_purchase.json

@@ -0,0 +1,14 @@
+{
+    "name": "STARS_PURCHASE",
+    "subjects": ["stars_purchase.>"],
+    "retention": "limits",
+    "max_consumers": -1,
+    "max_msgs": -1,
+    "max_bytes": -1,
+    "max_age": 31536000000000000,
+    "max_msg_size": -1,
+    "storage": "file",
+    "discard": "old",
+    "num_replicas": 1,
+    "duplicate_window": 0
+}

deploy/prod/nats/streams/game.json

@@ -0,0 +1,14 @@
+{
+    "name": "GAME",
+    "subjects": ["game.>"],
+    "retention": "limits",
+    "max_consumers": -1,
+    "max_msgs": -1,
+    "max_bytes": -1,
+    "max_age": 31536000000000000,
+    "max_msg_size": -1,
+    "storage": "file",
+    "discard": "old",
+    "num_replicas": 1,
+    "duplicate_window": 0
+}

deploy/prod/nats/streams/stars_purchase.json

@@ -0,0 +1,14 @@
+{
+    "name": "STARS_PURCHASE",
+    "subjects": ["stars_purchase.>"],
+    "retention": "limits",
+    "max_consumers": -1,
+    "max_msgs": -1,
+    "max_bytes": -1,
+    "max_age": 31536000000000000,
+    "max_msg_size": -1,
+    "storage": "file",
+    "discard": "old",
+    "num_replicas": 1,
+    "duplicate_window": 0
+}

pyproject.toml

@@ -25,6 +25,7 @@ dependencies = [
     "openai==1.97.0",
     "structlog==25.4.0",
     "structlog-sentry==2.2.1",
+    "taskiq==0.11.18",
 ]
 
 [dependency-groups]

src/ttt/application/game/game/make_ai_move_in_game.py

@@ -4,13 +4,16 @@
 
 from ttt.application.common.ports.map import Map
 from ttt.application.common.ports.randoms import Randoms
-from ttt.application.common.ports.transaction import SerializableTransaction
+from ttt.application.common.ports.transaction import (
+    NotSerializableTransaction,
+)
 from ttt.application.common.ports.uuids import UUIDs
 from ttt.application.game.game.ports.game_ai_gateway import GameAiGateway
 from ttt.application.game.game.ports.game_dao import GameDao
 from ttt.application.game.game.ports.game_log import GameLog
 from ttt.application.game.game.ports.game_views import GameViews
 from ttt.application.game.game.ports.games import Games
+from ttt.application.user.common.ports.user_locks import UserLocks
 from ttt.application.user.common.ports.users import Users
 from ttt.entities.core.game.game import (
     AlreadyCompletedGameError,
@@ -28,17 +31,15 @@ class MakeAiMoveInGame:
     uuids: UUIDs
     randoms: Randoms
     ai_gateway: GameAiGateway
-    transaction: SerializableTransaction
+    transaction: NotSerializableTransaction
     log: GameLog
     dao: GameDao
+    locks: UserLocks
 
-    async def __call__(self, game_id: UUID, ai_id: UUID) -> None:
-        """
-        :raises ttt.application.common.errors.serialization_error.SerializationError:
-        """  # noqa: E501
-
+    async def __call__(self, user_id: int, game_id: UUID, ai_id: UUID) -> None:
         async with self.transaction:
-            game = await self.games.game_with_id(game_id)
+            await self.locks.lock_user_by_id(user_id)
+            game = await self.games.not_locked_game_with_id(game_id)
 
             if game is None:
                 await self.log.no_game_to_make_ai_move(game_id)

src/ttt/application/game/game/make_move_in_game.py

@@ -11,6 +11,7 @@
 from ttt.application.game.game.ports.game_tasks import GameTasks
 from ttt.application.game.game.ports.game_views import GameViews
 from ttt.application.game.game.ports.games import Games
+from ttt.application.user.common.ports.user_locks import UserLocks
 from ttt.application.user.common.ports.users import Users
 from ttt.entities.core.game.cell import AlreadyFilledCellError
 from ttt.entities.core.game.game import (
@@ -34,6 +35,7 @@ class MakeMoveInGame:
     log: GameLog
     dao: GameDao
     tasks: GameTasks
+    locks: UserLocks
 
     async def __call__(
         self,
@@ -118,8 +120,9 @@ async def __call__(
                 await self.map_(tracking)
 
                 if user_move.next_move_ai_id is not None:
+                    await self.locks.lock_user_by_id(user_id)
                     await self.tasks.make_ai_move(
-                        game.id, user_move.next_move_ai_id,
+                        user_id, game.id, user_move.next_move_ai_id,
                     )
 
                 await self.transaction.commit()

src/ttt/application/game/game/ports/game_log.py

@@ -28,13 +28,6 @@ async def no_game_to_make_ai_move(
         /,
     ) -> None: ...
 
-    @abstractmethod
-    async def no_current_game(
-        self,
-        user_id: int,
-        /,
-    ) -> None: ...
-
     @abstractmethod
     async def game_against_ai_started(
         self,

src/ttt/application/game/game/ports/game_tasks.py

@@ -6,6 +6,7 @@ class GameTasks(ABC):
     @abstractmethod
     async def make_ai_move(
         self,
+        user_id: int,
         game_id: UUID,
         ai_id: UUID,
         /,

src/ttt/application/game/game/ports/games.py

@@ -12,4 +12,5 @@ class Games(ABC):
     async def current_user_game(self, user_id: int, /) -> Game | None: ...
 
     @abstractmethod
-    async def game_with_id(self, game_id: UUID, /) -> Game | None: ...
+    async def not_locked_game_with_id(self, game_id: UUID, /) -> Game | None:
+        ...