ref(entities): merge matchmaking_queue and user (#58)

Author: emptybutton

deploy/dev/docker-compose.yaml

@@ -35,6 +35,10 @@ services:
       TTT_NATS_URL: nats://nats:4222
 
       TTT_GEMINI_URL: https://my-openai-gemini-sigma-sandy.vercel.app
+
+      TTT_MATCHMAKING_MAX_WORKERS: 4
+      TTT_MATCHMAKING_WORKER_MAX_USERS: 100
+      TTT_MATCHMAKING_WORKER_CREATION_INTERVAL_SECONDS: 0.5
     secrets:
       - secrets
     command: ttt-dev

pyproject.toml

@@ -111,6 +111,7 @@ ignore = [
     "EM101",
     "N807",
     "FURB118",
+    "DOC402",
 ]
 
 [tool.ruff.lint.per-file-ignores]

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

@@ -6,13 +6,6 @@
 
 
 class GameLog(ABC):
-    @abstractmethod
-    async def game_against_user_started(
-        self,
-        game: Game,
-        /,
-    ) -> None: ...
-
     @abstractmethod
     async def game_against_ai_started(
         self,

src/ttt/application/matchmaking/common/matchmaking_log.py

@@ -38,3 +38,8 @@ async def users_with_ids(
         ids: Sequence[int],
         /,
     ) -> tuple[User | None, ...]: ...
+
+    @abstractmethod
+    async def some_users_waiting_for_matchmaking_to_matchmake(
+        self,
+    ) -> list[User]: ...

src/ttt/application/matchmaking/common/matchmaking_views.py

@@ -0,0 +1,69 @@
+from asyncio import gather
+from dataclasses import dataclass
+
+from ttt.application.common.ports.emojis import Emojis
+from ttt.application.common.ports.map import Map
+from ttt.application.common.ports.transaction import Transaction
+from ttt.application.common.ports.uuids import UUIDs
+from ttt.application.user.common.ports.users import Users
+from ttt.application.user.game.ports.user_log import GameUserLog
+from ttt.application.user.game.ports.user_views import GameUserViews
+from ttt.entities.core.game.game import Game
+from ttt.entities.core.user.matchmaking import MatchmakingInput, matchmaking
+from ttt.entities.tools.tracking import Tracking
+
+
+@dataclass(frozen=True, unsafe_hash=False)
+class Matchmake:
+    map_: Map
+    transaction: Transaction
+    users: Users
+    log: GameUserLog
+    views: GameUserViews
+    uuids: UUIDs
+    emojis: Emojis
+
+    async def __call__(self) -> None:
+        async with self.transaction:
+            tracking = Tracking()
+            games = await self._result(tracking)
+
+            await self.log.games_were_matched(games)
+            await gather(
+                self.views.matched_games_view(games),
+                self.map_(tracking),
+            )
+
+    async def _result(self, tracking: Tracking) -> list[Game]:
+        users, input_ = await gather(
+            self.users.some_users_waiting_for_matchmaking_to_matchmake(),
+            self._matchmaking_input(),
+        )
+
+        games = list[Game]()
+        matchmaking_ = matchmaking(users, input_, tracking)
+
+        try:
+            while True:
+                games.append(matchmaking_.send(await self._matchmaking_input()))
+        except StopIteration:
+            return games
+
+    async def _matchmaking_input(self) -> MatchmakingInput:
+        (
+            cell_id_matrix,
+            game_id,
+            player1_random_emoji,
+            player2_random_emoji,
+        ) = await gather(
+            self.uuids.random_uuid_matrix((3, 3)),
+            self.uuids.random_uuid(),
+            self.emojis.random_emoji(),
+            self.emojis.random_emoji(),
+        )
+        return MatchmakingInput(
+            cell_id_matrix,
+            game_id,
+            player1_random_emoji,
+            player2_random_emoji,
+        )