Expose OpenGame

Author: marein

composer.json

@@ -36,7 +36,7 @@
     "doctrine/doctrine-migrations-bundle": "^3.3",
     "doctrine/migrations": "^3.7",
     "doctrine/orm": "^3.0",
-    "gaming-platform/api": "dev-add-game-messages",
+    "gaming-platform/api": "dev-add-game-messages#3da446b",
     "jms/serializer": "^3.17",
     "marein/php-nchan-client": "^3.1",
     "marein/symfony-lock-doctrine-migrations-bundle": "^1.0",

composer.lock

@@ -4,7 +4,7 @@ services:
         arguments:
             - 'ConnectFour.GameRequests'
             - 'gaming'
-            - ['ConnectFour.JoinGame', 'ConnectFour.MakeMove', 'ConnectFour.GetGamesByPlayer']]
+            - ['ConnectFour.OpenGame', 'ConnectFour.JoinGame', 'ConnectFour.MakeMove', 'ConnectFour.GetGamesByPlayer']
         tags: [{ name: 'gaming.message-broker.topology' }]
 
     connect-four.game-requests-message-handler.consumer:

config/connect-four/services/consumer.yml

@@ -10,6 +10,7 @@
 use Gaming\Common\MessageBroker\MessageHandler;
 use Gaming\ConnectFour\Application\Game\Command\JoinCommand;
 use Gaming\ConnectFour\Application\Game\Command\MoveCommand;
+use Gaming\ConnectFour\Application\Game\Command\OpenCommand;
 use Gaming\ConnectFour\Application\Game\Query\GamesByPlayerQuery;
 use Gaming\ConnectFour\Application\Game\Query\Model\Game\Game;
 use Gaming\ConnectFour\Application\Game\Query\Model\Game\Move;
@@ -20,6 +21,7 @@
 use GamingPlatform\Api\ConnectFour\V1\GetGamesByPlayerResponse;
 use GamingPlatform\Api\ConnectFour\V1\JoinGameResponse;
 use GamingPlatform\Api\ConnectFour\V1\MakeMoveResponse;
+use GamingPlatform\Api\ConnectFour\V1\OpenGameResponse;
 
 final class GameRequestsMessageHandler implements MessageHandler
 {
@@ -32,13 +34,36 @@ public function __construct(
     public function handle(Message $message, Context $context): void
     {
         match ($message->name()) {
+            'ConnectFour.OpenGame' => $this->handleOpenGame($message, $context),
             'ConnectFour.JoinGame' => $this->handleJoinGame($message, $context),
             'ConnectFour.MakeMove' => $this->handleMakeMove($message, $context),
             'ConnectFour.GetGamesByPlayer' => $this->handleGetGamesByPlayer($message, $context),
             default => true
         };
     }
 
+    private function handleOpenGame(Message $message, Context $context): void
+    {
+        $request = ConnectFourV1Factory::createOpenGame($message->body());
+
+        $response = $this->commandBus->handle(
+            new OpenCommand(
+                $request->getPlayerId(),
+                $request->getWidth(),
+                $request->getHeight(),
+                $request->getStone(),
+                $request->getTimer()
+            )
+        );
+
+        $context->reply(
+            new Message(
+                'ConnectFour.OpenGameResponse',
+                new OpenGameResponse()->setGameId($response)->serializeToString()
+            )
+        );
+    }
+
     private function handleJoinGame(Message $message, Context $context): void
     {
         $request = ConnectFourV1Factory::createJoinGame($message->body());