DRAW-412 이미 게임중인 유저 중복 참여 방지

app/support/exception/src/main/kotlin/com/xorker/draw/exception/ExceptionButtonType.kt

@@ -64,6 +64,7 @@ fun XorkerException.getButtons(): List<ExceptionButtonType> {
         InvalidWebSocketStatusException,
         is NotDefinedMessageCodeException,
         NotFoundLockKeyException,
+        AlreadyPlayingPlayerException,
         -> buttonOk
     }
 }

app/websocket/src/main/kotlin/com/xorker/draw/websocket/event/MafiaGameInfoWebSocketListener.kt

@@ -11,12 +11,14 @@ import com.xorker.draw.user.User
 import com.xorker.draw.user.UserId
 import com.xorker.draw.websocket.message.response.MafiaGameMessenger
 import com.xorker.draw.websocket.message.response.MafiaPhaseMessenger
+import com.xorker.draw.websocket.session.SessionManager
 import org.springframework.stereotype.Component
 
 @Component
 internal class MafiaGameInfoWebSocketListener(
     private val mafiaPhaseMessenger: MafiaPhaseMessenger,
     private val mafiaGameMessenger: MafiaGameMessenger,
+    private val sessionManager: SessionManager,
 ) : MafiaGameInfoStatusChangedListener, MafiaGameActionListener, MafiaGameMatchListener {
 
     override fun connectUser(gameInfo: MafiaGameInfo, userId: UserId) {
@@ -34,6 +36,13 @@ internal class MafiaGameInfoWebSocketListener(
         if (gameInfo.phase == MafiaPhase.Wait) {
             mafiaGameMessenger.broadcastPlayerList(gameInfo)
         }
+
+        if (gameInfo.room.isRandomMatching) {
+            for (player in gameInfo.room.players) {
+                val session = sessionManager.getSession(player.userId) ?: continue
+                session.origin.close()
+            }
+        }
     }
 
     override fun startRandomMatch(user: User, locale: String, isLastPlayer: Boolean) {

app/websocket/src/main/kotlin/com/xorker/draw/websocket/handler/BaseWebSocketHandler.kt

@@ -2,14 +2,17 @@ package com.xorker.draw.websocket.handler
 
 import com.fasterxml.jackson.databind.ObjectMapper
 import com.xorker.draw.auth.token.TokenUseCase
+import com.xorker.draw.exception.AlreadyPlayingPlayerException
 import com.xorker.draw.exception.InvalidRequestValueException
 import com.xorker.draw.exception.UnAuthenticationException
+import com.xorker.draw.exception.XorkerException
 import com.xorker.draw.mafia.MafiaGameUseCase
 import com.xorker.draw.support.logging.defaultApiJsonMap
 import com.xorker.draw.support.logging.logger
 import com.xorker.draw.support.logging.registerRequestId
 import com.xorker.draw.user.User
 import com.xorker.draw.user.UserId
+import com.xorker.draw.websocket.exception.WebSocketExceptionHandler
 import com.xorker.draw.websocket.message.request.RequestAction
 import com.xorker.draw.websocket.message.request.WebSocketRequest
 import com.xorker.draw.websocket.message.request.WebSocketRequestParser
@@ -32,6 +35,7 @@ internal abstract class BaseWebSocketHandler(
     private val parser: WebSocketRequestParser,
     private val tokenUseCase: TokenUseCase,
     private val gameUseCase: MafiaGameUseCase,
+    private val webSocketExceptionHandler: WebSocketExceptionHandler,
 ) : TextWebSocketHandler() {
     private val logger = logger()
 
@@ -40,18 +44,26 @@ internal abstract class BaseWebSocketHandler(
     abstract fun afterDisconnect(session: Session?, status: CloseStatus)
 
     override fun afterConnectionEstablished(session: WebSocketSession) {
-        registerRequestId()
-        val user = getUser(session) ?: throw UnAuthenticationException()
-        val locale = session.getHeader(HEADER_LOCALE) ?: throw InvalidRequestValueException
+        try {
+            registerRequestId()
+            val user = getUser(session) ?: throw UnAuthenticationException()
 
-        val sessionDto = SessionWrapper(session, user, locale)
-        setupMdc(sessionDto)
-        sessionManager.registerSession(sessionDto)
+            if (sessionManager.getSession(user.id) != null) {
+                throw AlreadyPlayingPlayerException
+            }
+
+            val locale = session.getHeader(HEADER_LOCALE) ?: throw InvalidRequestValueException
+
+            val sessionDto = SessionWrapper(session, user, locale)
+            setupMdc(sessionDto)
+            sessionManager.registerSession(sessionDto)
 
-        try {
             afterConnect(sessionDto)
+        } catch (ex: XorkerException) {
+            webSocketExceptionHandler.handleXorkerException(session, RequestAction.INIT, ex)
+            throw ex
         } finally {
-            log(sessionDto.id, "WS_CONNECT")
+            log(SessionId(session.id), "WS_CONNECT")
             MDC.clear()
         }
     }
@@ -73,6 +85,8 @@ internal abstract class BaseWebSocketHandler(
 
         try {
             action(sessionDto, request)
+        } catch (ex: XorkerException) {
+            webSocketExceptionHandler.handleXorkerException(session, request.action, ex)
         } finally {
             log(sessionId, request)
             MDC.clear()

app/websocket/src/main/kotlin/com/xorker/draw/websocket/handler/QuickWebSocketHandler.kt

@@ -6,6 +6,7 @@ import com.xorker.draw.mafia.MafiaGameUseCase
 import com.xorker.draw.mafia.UserConnectionUseCase
 import com.xorker.draw.mafia.WaitingQueueUseCase
 import com.xorker.draw.websocket.WebSocketRouter
+import com.xorker.draw.websocket.exception.WebSocketExceptionHandler
 import com.xorker.draw.websocket.message.request.WebSocketRequest
 import com.xorker.draw.websocket.message.request.WebSocketRequestParser
 import com.xorker.draw.websocket.session.Session
@@ -20,6 +21,7 @@ internal class QuickWebSocketHandler(
     parser: WebSocketRequestParser,
     tokenUseCase: TokenUseCase,
     gameUseCase: MafiaGameUseCase,
+    webSocketExceptionHandler: WebSocketExceptionHandler,
     private val userConnectionUseCase: UserConnectionUseCase,
     private val router: WebSocketRouter,
     private val waitingQueueUseCase: WaitingQueueUseCase,
@@ -29,6 +31,7 @@ internal class QuickWebSocketHandler(
     parser,
     tokenUseCase,
     gameUseCase,
+    webSocketExceptionHandler,
 ) {
     override fun afterConnect(session: Session) {
         waitingQueueUseCase.enqueue(session.user, session.locale)

app/websocket/src/main/kotlin/com/xorker/draw/websocket/handler/RoomWebSocketHandler.kt

@@ -6,6 +6,7 @@ import com.xorker.draw.mafia.MafiaGameUseCase
 import com.xorker.draw.mafia.UserConnectionUseCase
 import com.xorker.draw.room.RoomId
 import com.xorker.draw.websocket.WebSocketRouter
+import com.xorker.draw.websocket.exception.WebSocketExceptionHandler
 import com.xorker.draw.websocket.message.request.WebSocketRequest
 import com.xorker.draw.websocket.message.request.WebSocketRequestParser
 import com.xorker.draw.websocket.session.Session
@@ -20,6 +21,7 @@ internal class RoomWebSocketHandler(
     parser: WebSocketRequestParser,
     tokenUseCase: TokenUseCase,
     gameUseCase: MafiaGameUseCase,
+    webSocketExceptionHandler: WebSocketExceptionHandler,
     private val userConnectionUseCase: UserConnectionUseCase,
     private val router: WebSocketRouter,
 ) : BaseWebSocketHandler(
@@ -28,6 +30,7 @@ internal class RoomWebSocketHandler(
     parser,
     tokenUseCase,
     gameUseCase,
+    webSocketExceptionHandler,
 ) {
     override fun afterConnect(session: Session) {
         userConnectionUseCase.connectUser(

domain/src/main/kotlin/com/xorker/draw/exception/XorkerException.kt

@@ -20,6 +20,7 @@ data object AlreadyJoinRoomException : ClientException("c005", "이미 참여한
 data object InvalidRequestOnlyMyTurnException : ClientException("c006", "요청자의 차례가 아니라서 처리 불가능") { private fun readResolve(): Any = InvalidRequestOnlyMyTurnException }
 data object InvalidRequestOtherPlayingException : ClientException("c007", "진행 중인 게임 방이 있습니다.") { private fun readResolve(): Any = InvalidRequestOtherPlayingException }
 data object AlreadyPlayingRoomException : ClientException("c008", "진행 중인 게임 방에는 참여할 수 없습니다.") { private fun readResolve(): Any = AlreadyPlayingRoomException }
+data object AlreadyPlayingPlayerException : ClientException("c010", "한 유저가 여러번 접속 시도를 하고 있습니다.") { private fun readResolve(): Any = AlreadyPlayingRoomException }
 
 //endregion