[feat] GameSetting 변경 기능 추가

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

@@ -1,10 +1,12 @@
 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.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.dto.request.GameSettingChanger;
 import io.f1.backend.domain.game.event.RoomUpdatedEvent;
 import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
@@ -25,7 +27,6 @@
 import org.springframework.stereotype.Service;
 
 import java.util.List;
-import java.util.Map;
 import java.util.Objects;
 
 @Service
@@ -70,19 +71,47 @@ public void gameStart(Long roomId, UserPrincipal principal) {
                 toQuestionStartResponse(room, START_DELAY));
     }
 
-    private boolean validateReadyStatus(Room room) {
+    public void handlePlayerReady(Long roomId, String sessionId) {
+        Player player =
+                roomRepository
+                        .findPlayerInRoomBySessionId(roomId, sessionId)
+                        .orElseThrow(() -> new CustomException(RoomErrorCode.PLAYER_NOT_FOUND));
+
+        Room room = findRoom(roomId);
+
+        toggleReadyIfPossible(room, player);
+
+        String destination = getDestination(roomId);
+
+        messageSender.send(destination, MessageType.PLAYER_LIST, toPlayerListResponse(room));
+    }
+
+    public void changeGameSetting(
+            Long roomId, UserPrincipal principal, GameSettingChanger request) {
+        Room room = findRoom(roomId);
+        validateHostAndState(room, principal);
 
-        Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
+        if (!request.change(room, quizService)) {
+            return;
+        }
+        request.afterChange(room, messageSender);
+
+        broadcastGameSetting(room);
 
-        return playerSessionMap.values().stream().allMatch(Player::isReady);
+        RoomUpdatedEvent roomUpdatedEvent =
+                new RoomUpdatedEvent(
+                        room,
+                        quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId()));
+
+        eventPublisher.publishEvent(roomUpdatedEvent);
     }
 
     private void validateRoomStart(Room room, UserPrincipal principal) {
         if (!Objects.equals(principal.getUserId(), room.getHost().getId())) {
             throw new CustomException(RoomErrorCode.NOT_ROOM_OWNER);
         }
 
-        if (!validateReadyStatus(room)) {
+        if (!room.validateReadyStatus()) {
             throw new CustomException(GameErrorCode.PLAYER_NOT_READY);
         }
 
@@ -97,4 +126,41 @@ private List<Question> prepareQuestions(Room room, Quiz quiz) {
         Integer round = room.getGameSetting().getRound();
         return quizService.getRandomQuestionsWithoutAnswer(quizId, round);
     }
+
+    private Room findRoom(Long roomId) {
+        return roomRepository
+                .findRoom(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 (!Objects.equals(principal.getUserId(), room.getHost().getId())) {
+            throw new CustomException(RoomErrorCode.NOT_ROOM_OWNER);
+        }
+        if (room.isPlaying()) {
+            throw new CustomException(RoomErrorCode.GAME_ALREADY_PLAYING);
+        }
+    }
+
+    private void toggleReadyIfPossible(Room room, Player player) {
+        if (room.isPlaying()) {
+            throw new CustomException(RoomErrorCode.GAME_ALREADY_PLAYING);
+        }
+        if (!Objects.equals(player.getId(), room.getHost().getId())) {
+            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/app/RoomService.java

@@ -201,21 +201,6 @@ public void exitRoom(Long roomId, String sessionId, UserPrincipal principal) {
         }
     }
 
-    public void handlePlayerReady(Long roomId, String sessionId) {
-        Player player =
-                roomRepository
-                        .findPlayerInRoomBySessionId(roomId, sessionId)
-                        .orElseThrow(() -> new CustomException(RoomErrorCode.PLAYER_NOT_FOUND));
-
-        player.toggleReady();
-
-        Room room = findRoom(roomId);
-
-        String destination = getDestination(roomId);
-
-        messageSender.send(destination, MessageType.PLAYER_LIST, toPlayerListResponse(room));
-    }
-
     public RoomListResponse getAllRooms() {
         List<Room> rooms = roomRepository.findAll();
         List<RoomResponse> roomResponses =

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

@@ -0,0 +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

@@ -0,0 +1,38 @@
+package io.f1.backend.domain.game.dto.request;
+
+import static io.f1.backend.domain.game.mapper.RoomMapper.toPlayerListResponse;
+
+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;
+
+public record QuizChangeRequest(Long quizId) implements GameSettingChanger {
+
+    @Override
+    public boolean change(Room room, QuizService quizService) {
+        if (Objects.equals(room.getGameSetting().getQuizId(), quizId)) {
+            return false; // 동일하면 무시
+        }
+        Quiz quiz = quizService.getQuizWithQuestionsById(quizId);
+        int questionSize = quiz.getQuestions().size();
+        room.getGameSetting().changeQuiz(quiz);
+        // 퀴즈의 문제 갯수로 변경
+        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

@@ -0,0 +1,29 @@
+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;
+
+import java.util.Objects;
+
+public record RoundChangeRequest(Integer round) implements GameSettingChanger {
+
+    @Override
+    public boolean change(Room room, QuizService quizService) {
+        if (Objects.equals(room.getGameSetting().getRound(), round)) {
+            return false; // 동일하면 무시
+        }
+
+        Quiz quiz = quizService.findQuizById(room.getGameSetting().getQuizId());
+        int questionSize = quiz.getQuestions().size();
+
+        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/TimeLimit.java

@@ -0,0 +1,29 @@
+package io.f1.backend.domain.game.dto.request;
+
+import io.f1.backend.global.exception.CustomException;
+import io.f1.backend.global.exception.errorcode.GameErrorCode;
+
+import lombok.Getter;
+
+import java.util.Arrays;
+
+@Getter
+public enum TimeLimit {
+    FIFTEEN(15),
+    THIRTY(30),
+    FORTY_FIVE(45),
+    SIXTY(60);
+
+    private final int value;
+
+    TimeLimit(int value) {
+        this.value = value;
+    }
+
+    public static TimeLimit from(int value) {
+        return Arrays.stream(values())
+                .filter(t -> t.value == value)
+                .findFirst()
+                .orElseThrow(() -> new CustomException(GameErrorCode.GAME_SETTING_CONFLICT));
+    }
+}

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

@@ -0,0 +1,22 @@
+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 {
+
+    @Override
+    public boolean change(Room room, QuizService quizService) {
+        if (room.getGameSetting().getTimeLimit() == timeLimit) {
+            return false; // 동일하면 무시
+        }
+        room.getGameSetting().changeTimeLimit(TimeLimit.from(timeLimit));
+        return true;
+    }
+
+    @Override
+    public void afterChange(Room room, MessageSender messageSender) {
+        // 고유한 후처리 동작 없음
+    }
+}

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

@@ -56,7 +56,7 @@ public static GameSettingResponse toGameSettingResponse(GameSetting gameSetting,
     public static PlayerListResponse toPlayerListResponse(Room room) {
         List<PlayerResponse> playerResponseList =
                 room.getPlayerSessionMap().values().stream()
-                        .map(player -> new PlayerResponse(player.getNickname(), false))
+                        .map(player -> new PlayerResponse(player.getNickname(), player.isReady()))
                         .toList();
 
         return new PlayerListResponse(room.getHost().getNickname(), playerResponseList);

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

@@ -1,19 +1,34 @@
 package io.f1.backend.domain.game.model;
 
+import io.f1.backend.domain.game.dto.request.TimeLimit;
+import io.f1.backend.domain.quiz.entity.Quiz;
+import io.f1.backend.global.exception.CustomException;
+import io.f1.backend.global.exception.errorcode.GameErrorCode;
+
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
-import java.util.Objects;
-
 @Getter
 @AllArgsConstructor
 public class GameSetting {
 
     private Long quizId;
-    private Integer round; // 게임 변경 시 해당 게임의 총 문제 수로 설정
+    private Integer round;
     private int timeLimit;
 
-    public boolean validateQuizId(Long quizId) {
-        return Objects.equals(this.quizId, quizId);
+    public void changeQuiz(Quiz quiz) {
+        quizId = quiz.getId();
+        round = quiz.getQuestions().size(); // 라운드를 바꾼 퀴즈의 문제 수로 동기화
+    }
+
+    public void changeTimeLimit(TimeLimit timeLimit) {
+        this.timeLimit = timeLimit.getValue();
+    }
+
+    public void changeRound(int round, int questionsCount) {
+        if (round > questionsCount) {
+            throw new CustomException(GameErrorCode.ROUND_EXCEEDS_QUESTION_COUNT);
+        }
+        this.round = round;
     }
 }

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

@@ -24,6 +24,10 @@ public void toggleReady() {
         this.isReady = !this.isReady;
     }
 
+    public void setReadyFalse() {
+        this.isReady = false;
+    }
+
     public void increaseCorrectCount() {
         correctCount++;
     }

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

@@ -8,6 +8,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
@@ -90,4 +91,16 @@ public Boolean isPlaying() {
     public void increaseCurrentRound() {
         currentRound++;
     }
+
+    public boolean validateReadyStatus() {
+
+        return playerSessionMap.values().stream().allMatch(Player::isReady);
+    }
+
+    public void resetAllPlayerReadyStates() {
+        for (Player player : playerSessionMap.values()) {
+            if (Objects.equals(player.getId(), getHost().getId())) continue;
+            player.setReadyFalse();
+        }
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/websocket/GameSocketController.java

@@ -6,6 +6,9 @@
 import io.f1.backend.domain.game.app.GameService;
 import io.f1.backend.domain.game.app.RoomService;
 import io.f1.backend.domain.game.dto.ChatMessage;
+import io.f1.backend.domain.game.dto.QuizChangeRequest;
+import io.f1.backend.domain.game.dto.RoundChangeRequest;
+import io.f1.backend.domain.game.dto.TimeLimitChangeRequest;
 import io.f1.backend.domain.game.dto.request.DefaultWebSocketRequest;
 import io.f1.backend.domain.user.dto.UserPrincipal;
 
@@ -61,6 +64,30 @@ public void chat(
     @MessageMapping("/room/ready/{roomId}")
     public void playerReady(@DestinationVariable Long roomId, Message<?> message) {
 
-        roomService.handlePlayerReady(roomId, getSessionId(message));
+        gameService.handlePlayerReady(roomId, getSessionId(message));
+    }
+
+    @MessageMapping("/room/quiz/{roomId}")
+    public void quizChange(
+            @DestinationVariable Long roomId,
+            Message<DefaultWebSocketRequest<QuizChangeRequest>> message) {
+        UserPrincipal principal = getSessionUser(message);
+        gameService.changeGameSetting(roomId, principal, message.getPayload().getMessage());
+    }
+
+    @MessageMapping("/room/time-limit/{roomId}")
+    public void timeLimitChange(
+            @DestinationVariable Long roomId,
+            Message<DefaultWebSocketRequest<TimeLimitChangeRequest>> message) {
+        UserPrincipal principal = getSessionUser(message);
+        gameService.changeGameSetting(roomId, principal, message.getPayload().getMessage());
+    }
+
+    @MessageMapping("/room/round/{roomId}")
+    public void roundChange(
+            @DestinationVariable Long roomId,
+            Message<DefaultWebSocketRequest<RoundChangeRequest>> message) {
+        UserPrincipal principal = getSessionUser(message);
+        gameService.changeGameSetting(roomId, principal, message.getPayload().getMessage());
     }
 }