feat start game event broadcast (#181)

* feat start game event broadcast
Game-as-a-Service · Oct 12, 2023 · 37b8735 · 37b8735
1 parent 8810599
commit 37b8735
Show file tree

Hide file tree

Showing 4 changed files with 34 additions and 11 deletions.
diff --git a/application/src/main/kotlin/tw/waterballsa/gaas/application/usecases/StartGameUseCase.kt b/application/src/main/kotlin/tw/waterballsa/gaas/application/usecases/StartGameUseCase.kt
@@ -6,6 +6,9 @@ import tw.waterballsa.gaas.application.eventbus.EventBus
 import tw.waterballsa.gaas.application.repositories.RoomRepository
 import tw.waterballsa.gaas.application.repositories.UserRepository
 import tw.waterballsa.gaas.domain.Room
+import tw.waterballsa.gaas.events.StartedGameEvent
+import tw.waterballsa.gaas.events.StartedGameEvent.Data
+import tw.waterballsa.gaas.events.enums.EventMessageType.GAME_STARTED
 import tw.waterballsa.gaas.exceptions.PlatformException
 import tw.waterballsa.gaas.exceptions.enums.PlatformError.GAME_START_FAILED
 import javax.inject.Named
@@ -29,11 +32,12 @@ class StartGameUseCase(
                 validateAllPlayersReady()
             }
 
-            val gameServerUrl = room.startGameByHost(jwtToken)
+            val startedGameEvent = room.startGameByHost(jwtToken)
 
             room.startGame()
             roomRepository.update(room)
-            presenter.present(gameServerUrl)
+            presenter.present(startedGameEvent.data.gameUrl)
+            eventBus.broadcast(startedGameEvent)
         }
     }
 
@@ -59,11 +63,12 @@ class StartGameUseCase(
         }
     }
 
-    private fun Room.startGameByHost(jwtToken: String): String {
+    private fun Room.startGameByHost(jwtToken: String): StartedGameEvent {
         val gameServerHost = game.backEndUrl
         val startGameRequest = StartGameRequest(players.map { it.toGamePlayer() })
+        val startGameResponse = gameService.startGame(gameServerHost, jwtToken, startGameRequest)
 
-        return gameService.startGame(gameServerHost, jwtToken, startGameRequest).url
+        return StartedGameEvent(GAME_STARTED, Data(startGameResponse.url, roomId!!))
     }
 
     private fun Room.Player.toGamePlayer(): StartGameRequest.GamePlayer =

diff --git a/domain/src/main/kotlin/tw/waterballsa/gaas/events/StartedGameEvent.kt b/domain/src/main/kotlin/tw/waterballsa/gaas/events/StartedGameEvent.kt
@@ -0,0 +1,15 @@
+package tw.waterballsa.gaas.events
+
+import tw.waterballsa.gaas.domain.Room
+import tw.waterballsa.gaas.events.enums.EventMessageType
+
+data class StartedGameEvent(
+    val type: EventMessageType,
+    val data: Data
+) : DomainEvent() {
+
+    data class Data(
+        val gameUrl: String,
+        val roomId: Room.Id,
+    )
+}
diff --git a/domain/src/main/kotlin/tw/waterballsa/gaas/events/enums/EventMessageType.kt b/domain/src/main/kotlin/tw/waterballsa/gaas/events/enums/EventMessageType.kt
@@ -0,0 +1,10 @@
+package tw.waterballsa.gaas.events.enums
+
+enum class EventMessageType(
+    val eventName: String
+) {
+    CHAT_MESSAGE("CHAT_MESSAGE"),
+    CHATROOM_JOIN("CHATROOM_JOIN"),
+    CONNECT_EVENT("CONNECT_EVENT"),
+    GAME_STARTED("GAME_STARTED"),
+}
diff --git a/domain/src/main/kotlin/tw/waterballsa/gaas/exceptions/enums/SocketIOEventMessage.kt b/domain/src/main/kotlin/tw/waterballsa/gaas/exceptions/enums/SocketIOEventMessage.kt