[feat] 플레이어 준비 상태 변경 기능

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

@@ -32,6 +32,8 @@
 import io.f1.backend.domain.quiz.app.QuizService;
 import io.f1.backend.domain.quiz.entity.Quiz;
 
+import io.f1.backend.global.exception.CustomException;
+import io.f1.backend.global.exception.errorcode.RoomErrorCode;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
@@ -182,6 +184,11 @@ public RoomExitData exitRoom(Long roomId, String sessionId) {
         }
     }
 
+    public Player findPlayerInRoomBySessionId(String sessionId, Long roomId) {
+        return roomRepository.findPlayerInRoomBySessionId(sessionId, roomId)
+            .orElseThrow(() -> new CustomException(RoomErrorCode.PLAYER_NOT_FOUND));
+    }
+
     public RoomListResponse getAllRooms() {
         List<Room> rooms = roomRepository.findAll();
         List<RoomResponse> roomResponses =
@@ -256,4 +263,11 @@ private void removePlayer(Room room, String sessionId, Player removePlayer) {
         room.removeUserId(removePlayer.getId());
         room.removeSessionId(sessionId);
     }
+
+    public PlayerListResponse getPlayerListResponse(Long roomId) {
+        Room room = roomRepository.findRoom(roomId)
+            .orElseThrow(() -> new IllegalStateException("방을 찾을 수 없습니다. roomId=" + roomId));
+
+        return toPlayerListResponse(room);
+    }
 }

backend/src/main/java/io/f1/backend/domain/game/store/RoomRepository.java

@@ -1,16 +1,20 @@
 package io.f1.backend.domain.game.store;
 
+import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
 
 import java.util.List;
 import java.util.Optional;
 
 public interface RoomRepository {
+
     void saveRoom(Room room);
 
     Optional<Room> findRoom(Long roomId);
 
     List<Room> findAll();
 
     void removeRoom(Long roomId);
+
+    Optional<Player> findPlayerInRoomBySessionId(String sessionId, Long roomId);
 }

backend/src/main/java/io/f1/backend/domain/game/store/RoomRepositoryImpl.java

@@ -1,13 +1,14 @@
 package io.f1.backend.domain.game.store;
 
+import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
 
+import java.util.Optional;
 import org.springframework.stereotype.Repository;
 
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
 
 @Repository
@@ -35,6 +36,11 @@ public void removeRoom(Long roomId) {
         roomMap.remove(roomId);
     }
 
+    @Override
+    public Optional<Player> findPlayerInRoomBySessionId(String sessionId, Long roomId) {
+        return findRoom(roomId).map(room -> room.getPlayerSessionMap().get(sessionId));
+    }
+
     // 테스트 전용 메소드
     public Room getRoomForTest(Long roomId) {
         return roomMap.get(roomId);

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

@@ -5,6 +5,8 @@
 import io.f1.backend.domain.game.dto.RoomExitData;
 import io.f1.backend.domain.game.dto.RoomInitialData;
 
+import io.f1.backend.domain.game.dto.response.PlayerListResponse;
+import io.f1.backend.domain.game.model.Player;
 import lombok.RequiredArgsConstructor;
 
 import org.springframework.messaging.Message;
@@ -27,6 +29,7 @@ public void initializeRoomSocket(@DestinationVariable Long roomId, Message<?> me
 
         RoomInitialData roomInitialData =
                 roomService.initializeRoomSocket(roomId, websocketSessionId);
+
         String destination = roomInitialData.destination();
 
         messageSender.send(
@@ -56,6 +59,21 @@ public void exitRoom(@DestinationVariable Long roomId, Message<?> message) {
         }
     }
 
+    @MessageMapping("/room/ready/{roomId}")
+    public void playerReady(@DestinationVariable Long roomId, Message<?> message) {
+        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
+        String sessionId = accessor.getSessionId();
+
+        Player player = roomService.findPlayerInRoomBySessionId(sessionId, roomId);
+
+        player.toggleReady();
+
+        PlayerListResponse response = roomService.getPlayerListResponse(roomId);
+
+        String destination = "/sub/room/" + roomId;
+        messageSender.send(destination, MessageType.PLAYER_LIST, response);
+    }
+
     private static String getSessionId(Message<?> message) {
         StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
         return accessor.getSessionId();

backend/src/main/java/io/f1/backend/global/exception/errorcode/RoomErrorCode.java

@@ -11,7 +11,8 @@ public enum RoomErrorCode implements ErrorCode {
     ROOM_USER_LIMIT_REACHED("E403002", HttpStatus.FORBIDDEN, "정원이 모두 찼습니다."),
     ROOM_GAME_IN_PROGRESS("E403003", HttpStatus.FORBIDDEN, "게임이 진행 중 입니다."),
     ROOM_NOT_FOUND("E404005", HttpStatus.NOT_FOUND, "존재하지 않는 방입니다."),
-    WRONG_PASSWORD("E401006", HttpStatus.UNAUTHORIZED, "비밀번호가 일치하지않습니다.");
+    WRONG_PASSWORD("E401006", HttpStatus.UNAUTHORIZED, "비밀번호가 일치하지않습니다."),
+    PLAYER_NOT_FOUND("E404007", HttpStatus.NOT_FOUND, "존재하지 않는 플레이어입니다.");
 
     private final String code;