[feat] 게임 종료 구현

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

@@ -1,11 +1,17 @@
 package io.f1.backend.domain.game.app;
 
+import static io.f1.backend.domain.game.mapper.RoomMapper.toGameResultListResponse;
+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.toRankUpdateResponse;
+import static io.f1.backend.domain.game.mapper.RoomMapper.toRoomSettingResponse;
 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.MessageType;
 import io.f1.backend.domain.game.event.RoomUpdatedEvent;
+import io.f1.backend.domain.game.model.ConnectionState;
 import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
 import io.f1.backend.domain.game.model.RoomState;
@@ -24,6 +30,7 @@
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -34,9 +41,10 @@ public class GameService {
 
     private static final int START_DELAY = 5;
 
-    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;
 
@@ -64,12 +72,51 @@ 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));
     }
 
+    public void gameEnd(Room room) {
+        room.updateRoomState(RoomState.FINISHED);
+
+        Long roomId = room.getId();
+        String destination = getDestination(roomId);
+
+        Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
+
+        messageSender.send(
+                destination,
+                MessageType.GAME_RESULT,
+                toGameResultListResponse(playerSessionMap, room.getGameSetting().getRound()));
+
+        List<Player> disconnectedPlayers = new ArrayList<>();
+
+        room.initializeRound();
+        for (Player player : playerSessionMap.values()) {
+            if (player.getState().equals(ConnectionState.DISCONNECTED)) {
+                disconnectedPlayers.add(player);
+            }
+            player.initializeCorrectCount();
+            player.toggleReady();
+        }
+
+        for (Player player : disconnectedPlayers) {
+            String sessionId = room.getUserIdSessionMap().get(player.id);
+            roomService.exitRoomForDisconnectedPlayer(roomId, player, sessionId);
+        }
+
+        room.updateRoomState(RoomState.WAITING);
+        messageSender.send(destination, MessageType.PLAYER_LIST, toPlayerListResponse(room));
+        messageSender.send(
+                destination,
+                MessageType.GAME_SETTING,
+                toGameSettingResponse(room.getGameSetting(), room.getCurrentQuestion().getQuiz()));
+        messageSender.send(destination, MessageType.ROOM_SETTING, toRoomSettingResponse(room));
+    }
+
     private boolean validateReadyStatus(Room room) {
 
         Map<String, Player> playerSessionMap = room.getPlayerSessionMap();

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

@@ -59,6 +59,7 @@
 @RequiredArgsConstructor
 public class RoomService {
 
+    private final GameService gameService;
     private final TimerService timerService;
     private final QuizService quizService;
     private final RoomRepository roomRepository;
@@ -263,9 +264,8 @@ public void chat(Long roomId, String sessionId, ChatMessage chatMessage) {
 
             timerService.cancelTimer(room);
 
-            // TODO : 게임 종료 로직 추가
             if (!timerService.validateCurrentRound(room)) {
-                // 게임 종료 로직
+                gameService.gameEnd(room);
                 return;
             }
 
@@ -336,4 +336,31 @@ private void removePlayer(Room room, String sessionId, Player removePlayer) {
         room.removeUserId(removePlayer.getId());
         room.removeSessionId(sessionId);
     }
+
+    public void exitRoomForDisconnectedPlayer(Long roomId, Player player, String sessionId) {
+
+        // 연결 끊긴 플레이어 exit 로직 타게 해주기
+        Room room = findRoom(roomId);
+
+        /* 방 삭제 */
+        if (isLastPlayer(room, sessionId)) {
+            removeRoom(room);
+            return;
+        }
+
+        /* 방장 변경 */
+        if (room.isHost(player.getId())) {
+            changeHost(room, sessionId);
+        }
+
+        /* 플레이어 삭제 */
+        removePlayer(room, sessionId, player);
+
+        SystemNoticeResponse systemNoticeResponse =
+                ofPlayerEvent(player.nickname, RoomEventType.EXIT);
+
+        String destination = getDestination(roomId);
+
+        messageSender.send(destination, MessageType.SYSTEM_NOTICE, systemNoticeResponse);
+    }
 }

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

@@ -26,6 +26,8 @@ public class TimerService {
     private static final String NONE_CORRECT_USER = "";
     private static final int CONTINUE_DELAY = 3;
 
+    private final GameService gameService;
+
     public void startTimer(Room room, int delaySec) {
         cancelTimer(room);
 
@@ -53,14 +55,11 @@ private void handleTimeout(Room room) {
                 MessageType.SYSTEM_NOTICE,
                 ofPlayerEvent(NONE_CORRECT_USER, RoomEventType.TIMEOUT));
 
-        // TODO : 게임 종료 로직
         if (!validateCurrentRound(room)) {
-            // 게임 종료 로직
-            // GAME_SETTING, PLAYER_LIST, GAME_RESULT, ROOM_SETTING
+            gameService.gameEnd(room);
             return;
         }
 
-        // 다음 문제 출제
         room.increaseCurrentRound();
 
         startTimer(room, CONTINUE_DELAY);

backend/src/main/java/io/f1/backend/domain/game/dto/MessageType.java

@@ -9,5 +9,6 @@ public enum MessageType {
     CHAT,
     QUESTION_RESULT,
     RANK_UPDATE,
-    QUESTION_START
+    QUESTION_START,
+    GAME_RESULT
 }

backend/src/main/java/io/f1/backend/domain/game/dto/response/GameResultListResponse.java

@@ -0,0 +1,5 @@
+package io.f1.backend.domain.game.dto.response;
+
+import java.util.List;
+
+public record GameResultListResponse(List<GameResultResponse> result) {}

backend/src/main/java/io/f1/backend/domain/game/dto/response/GameResultResponse.java

@@ -0,0 +1,3 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record GameResultResponse(String nickname, int score, int totalCorrectCount, int rank) {}

backend/src/main/java/io/f1/backend/domain/game/mapper/RoomMapper.java

@@ -3,6 +3,8 @@
 import io.f1.backend.domain.game.dto.Rank;
 import io.f1.backend.domain.game.dto.RoomEventType;
 import io.f1.backend.domain.game.dto.request.RoomCreateRequest;
+import io.f1.backend.domain.game.dto.response.GameResultListResponse;
+import io.f1.backend.domain.game.dto.response.GameResultResponse;
 import io.f1.backend.domain.game.dto.response.GameSettingResponse;
 import io.f1.backend.domain.game.dto.response.PlayerListResponse;
 import io.f1.backend.domain.game.dto.response.PlayerResponse;
@@ -21,8 +23,10 @@
 import io.f1.backend.domain.quiz.entity.Quiz;
 
 import java.time.Instant;
+import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.List;
+import java.util.Map;
 
 public class RoomMapper {
 
@@ -109,4 +113,42 @@ public static QuestionStartResponse toQuestionStartResponse(Room room, int delay
                 room.getCurrentRound(),
                 Instant.now().plusSeconds(delay));
     }
+
+    public static GameResultResponse toGameResultResponse(
+            Player player, int round, int rank, int totalPlayers) {
+        double correctRate = (double) player.getCorrectCount() / round;
+        int score = (int) (correctRate * 100) + (totalPlayers - rank) * 5;
+
+        return new GameResultResponse(player.nickname, score, player.getCorrectCount(), rank);
+    }
+
+    public static GameResultListResponse toGameResultListResponse(
+            Map<String, Player> playerSessionMap, int round) {
+
+        List<Player> rankedPlayers =
+                playerSessionMap.values().stream()
+                        .sorted(Comparator.comparingInt(Player::getCorrectCount).reversed())
+                        .toList();
+
+        int totalPlayers = rankedPlayers.size();
+
+        int prevCorrectCnt = -1;
+        int rank = 0;
+
+        List<GameResultResponse> gameResults = new ArrayList<>();
+        for (int i = 0; i < totalPlayers; i++) {
+            Player player = rankedPlayers.get(i);
+
+            int correctCnt = player.getCorrectCount();
+
+            if (prevCorrectCnt != correctCnt) {
+                rank = i + 1;
+            }
+
+            gameResults.add(toGameResultResponse(player, round, rank, totalPlayers));
+            prevCorrectCnt = correctCnt;
+        }
+
+        return new GameResultListResponse(gameResults);
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/model/Player.java

@@ -27,4 +27,8 @@ public void toggleReady() {
     public void increaseCorrectCount() {
         correctCount++;
     }
+
+    public void initializeCorrectCount() {
+        correctCount = 0;
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/model/Room.java

@@ -90,4 +90,8 @@ public Boolean isPlaying() {
     public void increaseCurrentRound() {
         currentRound++;
     }
+
+    public void initializeRound() {
+        currentRound = 0;
+    }
 }

backend/src/test/java/io/f1/backend/domain/game/app/RoomServiceTests.java

@@ -45,6 +45,7 @@ class RoomServiceTests {
 
     @Mock private RoomRepository roomRepository;
     @Mock private QuizService quizService;
+    @Mock private GameService gameService;
     @Mock private TimerService timerService;
     @Mock private ApplicationEventPublisher eventPublisher;
     @Mock private MessageSender messageSender;
@@ -54,7 +55,12 @@ void setUp() {
         MockitoAnnotations.openMocks(this); // @Mock 어노테이션이 붙은 필드들을 초기화합니다.
         roomService =
                 new RoomService(
-                        timerService, quizService, roomRepository, eventPublisher, messageSender);
+                        gameService,
+                        timerService,
+                        quizService,
+                        roomRepository,
+                        eventPublisher,
+                        messageSender);
 
         SecurityContextHolder.clearContext();
     }