實作[WebSocket] 看見其他玩家準備/取消準備

application/src/main/kotlin/tw/waterballsa/gaas/application/usecases/ChangePlayerReadinessUsecase.kt

@@ -1,20 +1,31 @@
 package tw.waterballsa.gaas.application.usecases
 
+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.PlayerReadinessChangedEvent
+import tw.waterballsa.gaas.events.PlayerReadinessChangedEvent.Data
+import tw.waterballsa.gaas.events.PlayerReadinessChangedEvent.Data.User
+import tw.waterballsa.gaas.events.enums.EventMessageType.USER_NOT_READY
+import tw.waterballsa.gaas.events.enums.EventMessageType.USER_READY
 import javax.inject.Named
 
 @Named
 class ChangePlayerReadinessUsecase(
     roomRepository: RoomRepository,
     userRepository: UserRepository,
+    private val eventBus: EventBus,
 ) : AbstractRoomUseCase(roomRepository, userRepository) {
     fun execute(request: Request) {
         with(request) {
             val room = findRoomById(roomId, false)
             val player = findPlayerByIdentity(userIdentity)
             room.changePlayerReadiness(player.id, readiness)
             roomRepository.update(room)
+
+            val playerReadinessChangedEvent = room.changePlayerReadiness(readiness, player.id!!.value, player.nickname)
+            eventBus.broadcast(playerReadinessChangedEvent)
         }
     }
 
@@ -30,3 +41,23 @@ class ChangePlayerReadinessUsecase(
         }
     }
 }
+
+fun Room.changePlayerReadiness(
+    readiness: Boolean,
+    playerId: String,
+    nickname: String
+): PlayerReadinessChangedEvent {
+    val type = if (readiness) USER_READY else USER_NOT_READY
+    val user = User(
+        playerId,
+        nickname
+    )
+    val data = Data(
+        user,
+        roomId!!.value
+    )
+    return PlayerReadinessChangedEvent(
+        type,
+        data
+    )
+}

domain/src/main/kotlin/tw/waterballsa/gaas/events/PlayerReadinessChangedEvent.kt

@@ -0,0 +1,18 @@
+package tw.waterballsa.gaas.events
+
+import tw.waterballsa.gaas.events.enums.EventMessageType
+
+data class PlayerReadinessChangedEvent(
+    val type: EventMessageType,
+    val data: Data
+) : DomainEvent() {
+    data class Data(
+        val user: User,
+        val roomId: String
+    ) {
+        data class User(
+            val id: String,
+            val nickname: String
+        )
+    }
+}

domain/src/main/kotlin/tw/waterballsa/gaas/events/enums/EventMessageType.kt

@@ -7,4 +7,6 @@ enum class EventMessageType(
     CHATROOM_JOIN("CHATROOM_JOIN"),
     CONNECT_EVENT("CONNECT_EVENT"),
     GAME_STARTED("GAME_STARTED"),
+    USER_READY("USER_READY"),
+    USER_NOT_READY("USER_NOT_READY"),
 }