[QUZ-83][FEATURE] 게임 랜덤 매칭 구현

[QUZ-83][FEATURE] 게임 랜덤 매칭 구현

Author: s0o0bn

matching-service/matching-application/app-api/build.gradle.kts

@@ -10,6 +10,8 @@ dependencies {
 
     //swagger
     implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.6.0")
+
+    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
 }
 
 tasks.named<BootJar>("bootJar") {

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/game/GameMatchingApi.kt

@@ -0,0 +1,36 @@
+package com.grepp.quizy.matching.api.game
+
+import com.grepp.quizy.common.api.ApiResponse
+import com.grepp.quizy.matching.api.sse.SseConnector
+import com.grepp.quizy.matching.domain.match.MatchingUseCase
+import com.grepp.quizy.matching.domain.user.UserId
+import com.grepp.quizy.web.annotation.AuthUser
+import com.grepp.quizy.web.dto.UserPrincipal
+import org.springframework.http.MediaType
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.*
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter
+
+@RestController
+@RequestMapping("/api/matching")
+class GameMatchingApi(
+    private val matchingUseCase: MatchingUseCase,
+    private val sseConnector: SseConnector
+) {
+
+    @GetMapping(
+        value = ["/subscribe"],
+        produces = [MediaType.TEXT_EVENT_STREAM_VALUE]
+    )
+    fun subscribe(@AuthUser principal: UserPrincipal): ResponseEntity<SseEmitter> {
+        val emitter = sseConnector.connect(UserId(principal.value))
+        matchingUseCase.registerWaiting(UserId(principal.value))
+        return ResponseEntity.ok(emitter)
+    }
+
+    @DeleteMapping("/unsubscribe")
+    fun unsubscribe(@AuthUser principal: UserPrincipal): ApiResponse<Unit> {
+        sseConnector.disconnect(UserId(principal.value))
+        return ApiResponse.success()
+    }
+}

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/sse/SseConnector.kt

@@ -0,0 +1,45 @@
+package com.grepp.quizy.matching.api.sse
+
+import com.grepp.quizy.matching.domain.match.MatchingPoolManager
+import com.grepp.quizy.matching.domain.user.UserId
+import org.springframework.stereotype.Component
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter
+import java.io.IOException
+
+@Component
+class SseConnector(
+    private val matchingPoolManager: MatchingPoolManager,
+    private val emitterRepository: SseEmitterRepository
+) {
+    
+    fun connect(userId: UserId): SseEmitter {
+        val emitter = SseEmitter(TIME_OUT)
+        emitterRepository.save(userId.value, emitter)
+        emitter.onTimeout { disconnect(userId) }
+        emitter.onCompletion { disconnect(userId) }
+        
+        try {
+            emitter.send(
+                SseEmitter.event()
+                    .id("")
+                    .name(CONNECTION_NAME)
+                    .data("emitter connected")
+            )
+        } catch (e: IOException) {
+            emitterRepository.remove(userId.value)
+            emitter.completeWithError(e)
+        }
+        
+        return emitter
+    }
+
+    fun disconnect(userId: UserId) {
+        emitterRepository.remove(userId.value)
+        matchingPoolManager.remove(userId)
+    }
+    
+    companion object {
+        const val CONNECTION_NAME = "CONNECT"
+        const val TIME_OUT = 5 * 60 * 1000L
+    }
+}

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/sse/SseEmitterRepository.kt

@@ -0,0 +1,20 @@
+package com.grepp.quizy.matching.api.sse
+
+import org.springframework.stereotype.Repository
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter
+import java.util.concurrent.ConcurrentHashMap
+
+@Repository
+class SseEmitterRepository {
+    private val emitters = ConcurrentHashMap<Long, SseEmitter>()
+
+    fun save(userId: Long, emitter: SseEmitter) {
+        emitters[userId] = emitter
+    }
+
+    fun findById(userId: Long) = emitters[userId]
+
+    fun remove(userId: Long) {
+        emitters.remove(userId)
+    }
+}

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/sse/SseSender.kt

@@ -0,0 +1,41 @@
+package com.grepp.quizy.matching.api.sse
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.grepp.quizy.matching.domain.match.MatchingEventSender
+import com.grepp.quizy.matching.domain.match.MatchingPoolManager
+import com.grepp.quizy.matching.domain.match.PersonalMatchingSucceedEvent
+import com.grepp.quizy.matching.domain.user.UserId
+import org.springframework.stereotype.Component
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter
+import java.io.IOException
+
+@Component
+class SseSender(
+    private val matchingPoolManager: MatchingPoolManager,
+    private val emitterRepository: SseEmitterRepository,
+    private val objectMapper: ObjectMapper
+) : MatchingEventSender {
+
+    override fun send(event: PersonalMatchingSucceedEvent) {
+        val emitter = emitterRepository.findById(event.userId) ?: return
+
+        try {
+            emitter.send(
+                SseEmitter.event()
+                    .id("")
+                    .name("MATCHING")
+                    .data(objectMapper.writeValueAsString(MatchingSucceed(event.gameRoomId)))
+            )
+        } catch (e: IOException) {
+            closeEmitter(event.userId)
+            emitter.completeWithError(e)
+        }
+    }
+
+    private fun closeEmitter(userId: Long) {
+        emitterRepository.remove(userId)
+        matchingPoolManager.remove(UserId(userId))
+    }
+}
+
+private data class MatchingSucceed(val roomId: Long)

matching-service/matching-domain/src/main/kotlin/com/grepp/quizy/matching/domain/game/GameFetcher.kt

@@ -0,0 +1,8 @@
+package com.grepp.quizy.matching.domain.game
+
+import com.grepp.quizy.matching.domain.user.InterestCategory
+import com.grepp.quizy.matching.domain.user.UserId
+
+interface GameFetcher {
+    fun requestGameRoomId(userIds: List<UserId>, subject: InterestCategory): GameRoomId
+}

matching-service/matching-domain/src/main/kotlin/com/grepp/quizy/matching/domain/game/GameVO.kt

@@ -0,0 +1,3 @@
+package com.grepp.quizy.matching.domain.game
+
+@JvmInline value class GameRoomId(val value: Long)

matching-service/matching-domain/src/main/kotlin/com/grepp/quizy/matching/domain/match/MatchingConstants.kt

@@ -0,0 +1,3 @@
+package com.grepp.quizy.matching.domain.match
+
+const val MATCHING_K = 5

matching-service/matching-domain/src/main/kotlin/com/grepp/quizy/matching/domain/match/MatchingEventHandler.kt

@@ -0,0 +1,19 @@
+package com.grepp.quizy.matching.domain.match
+
+import org.springframework.context.event.EventListener
+import org.springframework.scheduling.annotation.Async
+import org.springframework.stereotype.Component
+
+@Component
+class MatchingEventHandler(
+    private val matchingPoolManager: MatchingPoolManager,
+    private val matchingManager: MatchingManager,
+) {
+
+    @Async
+    @EventListener(UserWaitingRegisteredEvent::class)
+    fun handleUserWaitingRegistered(event: UserWaitingRegisteredEvent) {
+        val pivot = matchingPoolManager.findPivot() ?: return
+        matchingManager.match(pivot)
+    }
+}

matching-service/matching-domain/src/main/kotlin/com/grepp/quizy/matching/domain/match/MatchingEventPublishers.kt

@@ -0,0 +1,21 @@
+package com.grepp.quizy.matching.domain.match
+
+import org.springframework.context.ApplicationEventPublisher
+import org.springframework.stereotype.Component
+
+@Component
+class MatchingEventInternalPublisher(
+    private val eventPublisher: ApplicationEventPublisher
+) {
+    fun publish(event: UserWaitingRegisteredEvent) {
+        eventPublisher.publishEvent(event)
+    }
+}
+
+interface MatchingEventPublisher {
+    fun publish(event: PersonalMatchingSucceedEvent)
+}
+
+interface MatchingEventSender {
+    fun send(event: PersonalMatchingSucceedEvent)
+}