♻️ refactor: 게임 세팅 요청 후처리 분리

Author: LimKangHyun

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

@@ -5,9 +5,8 @@
 import static io.f1.backend.domain.game.mapper.RoomMapper.toQuestionStartResponse;
 import static io.f1.backend.domain.quiz.mapper.QuizMapper.toGameStartResponse;
 
-import io.f1.backend.domain.game.dto.MessageType;
 import io.f1.backend.domain.game.dto.request.GameSettingChanger;
-import io.f1.backend.domain.game.dto.response.PlayerListResponse;
+import io.f1.backend.domain.game.dto.MessageType;
 import io.f1.backend.domain.game.event.RoomUpdatedEvent;
 import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
@@ -83,7 +82,6 @@ public void handlePlayerReady(Long roomId, String sessionId) {
         toggleReadyIfPossible(room, player);
 
         String destination = getDestination(roomId);
-        PlayerListResponse playerListResponse = toPlayerListResponse(room);
 
         messageSender.send(destination, MessageType.PLAYER_LIST, toPlayerListResponse(room));
     }
@@ -96,20 +94,14 @@ public void changeGameSetting(
         if (!request.change(room, quizService)) {
             return;
         }
+        request.afterChange(room, messageSender);
 
-        room.resetAllPlayerReadyStates();
-
-        String destination = getDestination(roomId);
-        Quiz quiz = quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId());
+        broadcastGameSetting(room);
 
-        PlayerListResponse playerListResponse = toPlayerListResponse(room);
-        messageSender.send(
-                destination,
-                MessageType.GAME_SETTING,
-                toGameSettingResponse(room.getGameSetting(), quiz));
-        messageSender.send(destination, MessageType.PLAYER_LIST, playerListResponse);
+        RoomUpdatedEvent roomUpdatedEvent = new RoomUpdatedEvent(room,
+            quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId()));
 
-        eventPublisher.publishEvent(new RoomUpdatedEvent(room, quiz));
+        eventPublisher.publishEvent(roomUpdatedEvent);
     }
 
     private void validateRoomStart(Room room, UserPrincipal principal) {
@@ -160,4 +152,13 @@ private void toggleReadyIfPossible(Room room, Player player) {
             player.toggleReady();
         }
     }
+
+    private void broadcastGameSetting(Room room) {
+        String destination = getDestination(room.getId());
+        Quiz quiz = quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId());
+        messageSender.send(
+            destination,
+            MessageType.GAME_SETTING,
+            toGameSettingResponse(room.getGameSetting(), quiz));
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/dto/request/GameSettingChanger.java

@@ -1,8 +1,12 @@
 package io.f1.backend.domain.game.dto.request;
 
 import io.f1.backend.domain.game.model.Room;
+import io.f1.backend.domain.game.websocket.MessageSender;
 import io.f1.backend.domain.quiz.app.QuizService;
 
 public interface GameSettingChanger {
+
     boolean change(Room room, QuizService quizService);
+
+    void afterChange(Room room, MessageSender messageSender);
 }

backend/src/main/java/io/f1/backend/domain/game/dto/request/QuizChangeRequest.java

@@ -1,11 +1,16 @@
 package io.f1.backend.domain.game.dto.request;
 
+import io.f1.backend.domain.game.dto.MessageType;
+import io.f1.backend.domain.game.dto.response.PlayerListResponse;
 import io.f1.backend.domain.game.model.Room;
+import io.f1.backend.domain.game.websocket.MessageSender;
 import io.f1.backend.domain.quiz.app.QuizService;
 import io.f1.backend.domain.quiz.entity.Quiz;
 
 import java.util.Objects;
 
+import static io.f1.backend.domain.game.mapper.RoomMapper.toPlayerListResponse;
+
 public record QuizChangeRequest(Long quizId) implements GameSettingChanger {
 
     @Override
@@ -20,4 +25,14 @@ public boolean change(Room room, QuizService quizService) {
         room.getGameSetting().changeRound(questionSize, questionSize);
         return true;
     }
+
+    @Override
+    public void afterChange(Room room, MessageSender messageSender) {
+        room.resetAllPlayerReadyStates();
+
+        String destination = "/sub/room/" + room.getId();
+        PlayerListResponse response = toPlayerListResponse(room);
+
+        messageSender.send(destination, MessageType.PLAYER_LIST, response);
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/dto/request/RoundChangeRequest.java

@@ -1,6 +1,7 @@
 package io.f1.backend.domain.game.dto.request;
 
 import io.f1.backend.domain.game.model.Room;
+import io.f1.backend.domain.game.websocket.MessageSender;
 import io.f1.backend.domain.quiz.app.QuizService;
 import io.f1.backend.domain.quiz.entity.Quiz;
 
@@ -20,4 +21,9 @@ public boolean change(Room room, QuizService quizService) {
         room.getGameSetting().changeRound(round, questionSize);
         return true;
     }
+
+    @Override
+    public void afterChange(Room room, MessageSender messageSender) {
+        // 고유한 후처리 동작 없음
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/dto/request/TimeLimitChangeRequest.java

@@ -1,6 +1,7 @@
 package io.f1.backend.domain.game.dto.request;
 
 import io.f1.backend.domain.game.model.Room;
+import io.f1.backend.domain.game.websocket.MessageSender;
 import io.f1.backend.domain.quiz.app.QuizService;
 
 public record TimeLimitChangeRequest(int timeLimit) implements GameSettingChanger {
@@ -13,4 +14,9 @@ public boolean change(Room room, QuizService quizService) {
         room.getGameSetting().changeTimeLimit(TimeLimit.from(timeLimit));
         return true;
     }
+
+    @Override
+    public void afterChange(Room room, MessageSender messageSender) {
+        // 고유한 후처리 동작 없음
+    }
 }