[feat] 게임 종료 구현

backend/src/main/java/io/f1/backend/domain/game/app/ChatService.java

@@ -0,0 +1,48 @@
+package io.f1.backend.domain.game.app;
+
+import static io.f1.backend.domain.game.websocket.WebSocketUtils.getDestination;
+
+import io.f1.backend.domain.game.dto.ChatMessage;
+import io.f1.backend.domain.game.dto.MessageType;
+import io.f1.backend.domain.game.event.GameCorrectAnswerEvent;
+import io.f1.backend.domain.game.model.Room;
+import io.f1.backend.domain.game.websocket.MessageSender;
+import io.f1.backend.domain.question.entity.Question;
+
+import lombok.RequiredArgsConstructor;
+
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class ChatService {
+
+    private final RoomService roomService;
+    private final TimerService timerService;
+    private final MessageSender messageSender;
+    private final ApplicationEventPublisher eventPublisher;
+
+    // todo 동시성적용
+    public void chat(Long roomId, String sessionId, ChatMessage chatMessage) {
+
+        Room room = roomService.findRoom(roomId);
+
+        String destination = getDestination(roomId);
+
+        messageSender.send(destination, MessageType.CHAT, chatMessage);
+
+        if (!room.isPlaying()) {
+            return;
+        }
+
+        Question currentQuestion = room.getCurrentQuestion();
+
+        String answer = currentQuestion.getAnswer();
+
+        if (answer.equals(chatMessage.message())) {
+            eventPublisher.publishEvent(
+                    new GameCorrectAnswerEvent(room, sessionId, chatMessage, answer));
+        }
+    }
+}

backend/src/main/java/io/f1/backend/domain/game/app/GameService.java

@@ -1,13 +1,16 @@
 package io.f1.backend.domain.game.app;
 
-import static io.f1.backend.domain.game.mapper.RoomMapper.toGameSettingResponse;
-import static io.f1.backend.domain.game.mapper.RoomMapper.toPlayerListResponse;
-import static io.f1.backend.domain.game.mapper.RoomMapper.toQuestionStartResponse;
+import static io.f1.backend.domain.game.mapper.RoomMapper.*;
+import static io.f1.backend.domain.game.websocket.WebSocketUtils.getDestination;
 import static io.f1.backend.domain.quiz.mapper.QuizMapper.toGameStartResponse;
 
+import io.f1.backend.domain.game.dto.ChatMessage;
 import io.f1.backend.domain.game.dto.MessageType;
+import io.f1.backend.domain.game.dto.RoomEventType;
 import io.f1.backend.domain.game.dto.request.GameSettingChanger;
 import io.f1.backend.domain.game.dto.response.PlayerListResponse;
+import io.f1.backend.domain.game.event.GameCorrectAnswerEvent;
+import io.f1.backend.domain.game.event.GameTimeoutEvent;
 import io.f1.backend.domain.game.event.RoomUpdatedEvent;
 import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
@@ -26,21 +29,26 @@
 import lombok.extern.slf4j.Slf4j;
 
 import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.Map;
 import java.util.Objects;
 
 @Slf4j
 @Service
 @RequiredArgsConstructor
 public class GameService {
 
-    public static final int START_DELAY = 5;
+    private static final int START_DELAY = 5;
+    private static final int CONTINUE_DELAY = 3;
+    private static final String NONE_CORRECT_USER = "";
 
-    private final MessageSender messageSender;
-    private final TimerService timerService;
     private final QuizService quizService;
+    private final RoomService roomService;
+    private final TimerService timerService;
+    private final MessageSender messageSender;
     private final RoomRepository roomRepository;
     private final ApplicationEventPublisher eventPublisher;
 
@@ -68,12 +76,109 @@ public void gameStart(Long roomId, UserPrincipal principal) {
         timerService.startTimer(room, START_DELAY);
 
         messageSender.send(destination, MessageType.GAME_START, toGameStartResponse(questions));
+        messageSender.send(destination, MessageType.RANK_UPDATE, toRankUpdateResponse(room));
         messageSender.send(
                 destination,
                 MessageType.QUESTION_START,
                 toQuestionStartResponse(room, START_DELAY));
     }
 
+    @EventListener
+    public void onCorrectAnswer(GameCorrectAnswerEvent event) {
+
+        Room room = event.room();
+        String sessionId = event.sessionId();
+        ChatMessage chatMessage = event.chatMessage();
+        String answer = event.answer();
+
+        String destination = getDestination(room.getId());
+
+        room.increasePlayerCorrectCount(sessionId);
+
+        messageSender.send(
+                destination,
+                MessageType.QUESTION_RESULT,
+                toQuestionResultResponse(chatMessage.nickname(), answer));
+        messageSender.send(destination, MessageType.RANK_UPDATE, toRankUpdateResponse(room));
+        messageSender.send(
+                destination,
+                MessageType.SYSTEM_NOTICE,
+                ofPlayerEvent(chatMessage.nickname(), RoomEventType.CORRECT_ANSWER));
+
+        timerService.cancelTimer(room);
+
+        if (!timerService.validateCurrentRound(room)) {
+            gameEnd(room);
+            return;
+        }
+
+        room.increaseCurrentRound();
+
+        // 타이머 추가하기
+        timerService.startTimer(room, CONTINUE_DELAY);
+        messageSender.send(
+                destination,
+                MessageType.QUESTION_START,
+                toQuestionStartResponse(room, CONTINUE_DELAY));
+    }
+
+    @EventListener
+    public void onTimeout(GameTimeoutEvent event) {
+        Room room = event.room();
+        String destination = getDestination(room.getId());
+
+        messageSender.send(
+                destination,
+                MessageType.QUESTION_RESULT,
+                toQuestionResultResponse(NONE_CORRECT_USER, room.getCurrentQuestion().getAnswer()));
+        messageSender.send(
+                destination,
+                MessageType.SYSTEM_NOTICE,
+                ofPlayerEvent(NONE_CORRECT_USER, RoomEventType.TIMEOUT));
+
+        if (!timerService.validateCurrentRound(room)) {
+            gameEnd(room);
+            return;
+        }
+
+        room.increaseCurrentRound();
+
+        timerService.startTimer(room, CONTINUE_DELAY);
+        messageSender.send(
+                destination,
+                MessageType.QUESTION_START,
+                toQuestionStartResponse(room, CONTINUE_DELAY));
+    }
+
+    public void gameEnd(Room room) {
+        Long roomId = room.getId();
+        String destination = getDestination(roomId);
+
+        Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
+
+        // TODO : 랭킹 정보 업데이트
+        messageSender.send(
+                destination,
+                MessageType.GAME_RESULT,
+                toGameResultListResponse(playerSessionMap, room.getGameSetting().getRound()));
+
+        room.initializeRound();
+        room.initializePlayers();
+
+        List<Player> disconnectedPlayers = room.getDisconnectedPlayers();
+        roomService.handleDisconnectedPlayers(room, disconnectedPlayers);
+
+        room.updateRoomState(RoomState.WAITING);
+
+        messageSender.send(
+                destination,
+                MessageType.GAME_SETTING,
+                toGameSettingResponse(
+                        room.getGameSetting(),
+                        quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId())));
+        messageSender.send(destination, MessageType.ROOM_SETTING, toRoomSettingResponse(room));
+    }
+
     public void handlePlayerReady(Long roomId, String sessionId) {
 
         Room room = findRoom(roomId);
@@ -136,10 +241,6 @@ private Room findRoom(Long roomId) {
                 .orElseThrow(() -> new CustomException(RoomErrorCode.ROOM_NOT_FOUND));
     }
 
-    private String getDestination(Long roomId) {
-        return "/sub/room/" + roomId;
-    }
-
     private void validateHostAndState(Room room, UserPrincipal principal) {
         if (!room.isHost(principal.getUserId())) {
             throw new CustomException(RoomErrorCode.NOT_ROOM_OWNER);