feature: find game sort by times played

.gitignore

@@ -86,3 +86,5 @@ buildNumber.properties
 .classpath
 
 # End of https://www.toptal.com/developers/gitignore/api/intellij,maven
+
+.env

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

@@ -71,7 +71,7 @@ class StartGameUseCase(
         val startGameRequest = StartGameRequest(roomId!!.value, players.map { it.toGamePlayer() })
         val startGameResponse = gameService.startGame(gameServerHost, jwtToken, startGameRequest)
 
-        return StartedGameEvent(GAME_STARTED, Data(startGameResponse.url, roomId!!))
+        return StartedGameEvent(GAME_STARTED, Data(startGameResponse.url, roomId!!, game.id!!))
     }
 
     private fun Room.Player.toGamePlayer(): StartGameRequest.GamePlayer =

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

@@ -1,5 +1,6 @@
 package tw.waterballsa.gaas.events
 
+import tw.waterballsa.gaas.domain.GameRegistration
 import tw.waterballsa.gaas.domain.Room
 import tw.waterballsa.gaas.events.enums.EventMessageType
 
@@ -10,6 +11,7 @@ class StartedGameEvent(
     data class Data(
         val gameUrl: String,
         val roomId: Room.Id,
+        val gameId: GameRegistration.Id,
     )
 
     override fun getEventData(): Any = data

spring/src/main/kotlin/tw/waterballsa/gaas/spring/eventbus/DispatcherEventBus.kt

@@ -0,0 +1,20 @@
+package tw.waterballsa.gaas.spring.eventbus
+
+import org.springframework.stereotype.Component
+import tw.waterballsa.gaas.application.eventbus.EventBus
+import tw.waterballsa.gaas.events.DomainEvent
+import kotlin.reflect.safeCast
+
+@Component
+class DispatcherEventBus(
+    private val listeners: List<EventListener<*>>,
+) : EventBus {
+
+    override fun broadcast(events: Collection<DomainEvent>) {
+        listeners.forEach { listener ->
+            events.mapNotNull { listener.eventType.safeCast(it) }
+                .takeIf { it.isNotEmpty() }
+                ?.run { (listener as EventListener<DomainEvent>).onEvents(this) }
+        }
+    }
+}

spring/src/main/kotlin/tw/waterballsa/gaas/spring/eventbus/EventListener.kt

@@ -0,0 +1,9 @@
+package tw.waterballsa.gaas.spring.eventbus
+
+import tw.waterballsa.gaas.events.DomainEvent
+import kotlin.reflect.KClass
+
+interface EventListener<T: DomainEvent> {
+    val eventType: KClass<T>
+    fun onEvents(events: List<T>)
+}

spring/src/main/kotlin/tw/waterballsa/gaas/spring/eventbus/RoomEventListener.kt

@@ -0,0 +1,25 @@
+package tw.waterballsa.gaas.spring.eventbus
+
+import com.corundumstudio.socketio.SocketIOServer
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.stereotype.Component
+import tw.waterballsa.gaas.events.RoomEvent
+import kotlin.reflect.KClass
+
+@Component
+class RoomEventListener(
+    override val eventType: KClass<RoomEvent>,
+    val socketIOServer: SocketIOServer,
+): EventListener<RoomEvent> {
+
+    @Autowired
+    constructor(socketIOServer: SocketIOServer): this(RoomEvent::class, socketIOServer)
+
+    override fun onEvents(events: List<RoomEvent>) {
+        events
+            .forEach {
+                socketIOServer.getRoomOperations("ROOM_${it.getRoomId().value}")
+                    .sendEvent(it.type.eventName, it.getEventData())
+            }
+    }
+}

spring/src/main/kotlin/tw/waterballsa/gaas/spring/eventbus/StartedGameEventListener.kt

@@ -0,0 +1,23 @@
+package tw.waterballsa.gaas.spring.eventbus
+
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.stereotype.Component
+import tw.waterballsa.gaas.events.StartedGameEvent
+import tw.waterballsa.gaas.spring.repositories.dao.GameRegistrationDAO
+import kotlin.reflect.KClass
+
+@Component
+class StartedGameEventListener(
+    override val eventType: KClass<StartedGameEvent>,
+    private val gameRegistrationDAO: GameRegistrationDAO,
+) : EventListener<StartedGameEvent> {
+
+    @Autowired
+    constructor(gameRegistrationDAO: GameRegistrationDAO): this(StartedGameEvent::class, gameRegistrationDAO)
+
+    override fun onEvents(events: List<StartedGameEvent>) {
+        events.forEach {
+            gameRegistrationDAO.incrementTimesPlayedById(it.data.gameId.value)
+        }
+    }
+}

spring/src/main/kotlin/tw/waterballsa/gaas/spring/repositories/SpringGameRegistrationRepository.kt

@@ -2,6 +2,7 @@ package tw.waterballsa.gaas.spring.repositories
 
 import org.springframework.data.domain.Sort
 import org.springframework.data.domain.Sort.Order
+import org.springframework.data.mongodb.core.query.Update
 import org.springframework.stereotype.Component
 import tw.waterballsa.gaas.application.repositories.GameRegistrationRepository
 import tw.waterballsa.gaas.domain.GameRegistration
@@ -43,7 +44,9 @@ class SpringGameRegistrationRepository(
         gameRegistrationDAO.save(gameRegistration.toData()).toDomain()
 
     enum class SortBy(val value: String, val orders: List<Order>) {
-        CREATED_ON("createdOn", listOf(Order.desc("createdOn"), Order.desc("_id")));
+        CREATED_ON("createdOn", listOf(Order.desc("createdOn"), Order.desc("_id"))),
+        TIMES_PLAYED("timesPlayed", listOf(Order.desc("timesPlayed"), Order.desc("_id")))
+        ;
 
         companion object {
             private val map = SortBy.values().associateBy { it.value }

spring/src/main/kotlin/tw/waterballsa/gaas/spring/repositories/dao/GameRegistrationDAO.kt

@@ -1,11 +1,17 @@
 package tw.waterballsa.gaas.spring.repositories.dao
 
 import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.Query
+import org.springframework.data.mongodb.repository.Update
 import org.springframework.stereotype.Repository
 import tw.waterballsa.gaas.spring.repositories.data.GameRegistrationData
 
 @Repository
 interface GameRegistrationDAO : MongoRepository<GameRegistrationData, String> {
     fun findByUniqueName(uniqueName: String): GameRegistrationData?
     fun existsByUniqueName(uniqueName: String): Boolean
+
+    @Query("{ '_id' : ?0 }")
+    @Update("{ '\$inc' : { 'timesPlayed' : ?1 } }")
+    fun incrementTimesPlayedById(id: String, increment: Long = 1)
 }

spring/src/main/kotlin/tw/waterballsa/gaas/spring/repositories/data/GameRegistrationData.kt

@@ -22,6 +22,7 @@ class GameRegistrationData(
     var frontEndUrl: String?,
     var backEndUrl: String?,
     val createdOn: Instant?,
+    var timesPlayed: Long? = null,
 ) {
     @DBRef
     var logs: MutableList<GameDevelopmentLog> = mutableListOf()