✨ 게임 방 입장(+유효성 검증) 구현

sehee123 · sehee123 · commit 4c599cffae9d · 2025-07-14T01:23:55.000+09:00
diff --git a/backend/src/main/java/io/f1/backend/domain/game/api/RoomController.java b/backend/src/main/java/io/f1/backend/domain/game/api/RoomController.java
@@ -2,8 +2,10 @@
 
 import io.f1.backend.domain.game.app.RoomService;
 import io.f1.backend.domain.game.dto.request.RoomCreateRequest;
+import io.f1.backend.domain.game.dto.request.RoomValidationRequest;
 import io.f1.backend.domain.game.dto.response.RoomCreateResponse;
 
+import io.f1.backend.domain.game.dto.response.RoomValidationResponse;
 import jakarta.validation.Valid;
 
 import lombok.RequiredArgsConstructor;
@@ -35,4 +37,9 @@ public RoomCreateResponse saveRoom(@RequestBody @Valid RoomCreateRequest request
 
         return roomService.saveRoom(request, loginUser);
     }
+
+    @PostMapping("/validation")
+    public RoomValidationResponse validateRoom(@RequestBody RoomValidationRequest request) {
+        return roomService.validateRoom(request);
+    }
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/app/RoomService.java b/backend/src/main/java/io/f1/backend/domain/game/app/RoomService.java
@@ -1,27 +1,38 @@
 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.toRoomSetting;
+import static io.f1.backend.domain.game.mapper.RoomMapper.toRoomSettingResponse;
 
+import io.f1.backend.domain.game.dto.RoomInitialData;
 import io.f1.backend.domain.game.dto.request.RoomCreateRequest;
+import io.f1.backend.domain.game.dto.request.RoomValidationRequest;
+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.QuizResponse;
 import io.f1.backend.domain.game.dto.response.RoomCreateResponse;
+import io.f1.backend.domain.game.dto.response.RoomSettingResponse;
+import io.f1.backend.domain.game.dto.response.RoomValidationResponse;
 import io.f1.backend.domain.game.model.GameSetting;
 import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
 import io.f1.backend.domain.game.model.RoomSetting;
+import io.f1.backend.domain.game.model.RoomState;
 import io.f1.backend.domain.game.store.RoomRepository;
-
-import lombok.RequiredArgsConstructor;
-
-import org.springframework.stereotype.Service;
-
 import java.util.Map;
 import java.util.concurrent.atomic.AtomicLong;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class RoomService {
 
     private final RoomRepository roomRepository;
+
     private final AtomicLong roomIdGenerator = new AtomicLong(0);
 
     public RoomCreateResponse saveRoom(RoomCreateRequest request, Map<String, Object> loginUser) {
@@ -38,4 +49,53 @@ public RoomCreateResponse saveRoom(RoomCreateRequest request, Map<String, Object
 
         return new RoomCreateResponse(newId);
     }
+
+    public RoomValidationResponse validateRoom(RoomValidationRequest request) {
+
+        Room room = roomRepository.findRoom(request.roomId())
+            .orElseThrow(() -> new IllegalArgumentException("404 존재하지 않는 방입니다."));
+
+        if(room.getState().equals(RoomState.PLAYING)){
+            throw new IllegalArgumentException("403 게임이 진행중입니다.");
+        }
+
+        int maxUserCnt = room.getRoomSetting().maxUserCount();
+        int currentCnt = room.getPlayerSessionMap().size();
+        if (maxUserCnt == currentCnt) {
+            throw new IllegalArgumentException("403 정원이 모두 찼습니다.");
+        }
+
+        if (room.getRoomSetting().locked() && !room.getRoomSetting().password().equals(request.password())) {
+            throw new IllegalArgumentException("401 비밀번호가 일치하지 않습니다.");
+        }
+
+        return new RoomValidationResponse(request.roomId());
+    }
+
+    public RoomInitialData enterRoom(Long roomId, String sessionId) {
+
+        Room room = roomRepository.findRoom(roomId)
+            .orElseThrow(() -> new IllegalArgumentException("404 존재하지 않는 방입니다."));
+
+        //todo security
+        Player player = new Player(1L, "빵야빵야");
+
+        Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
+
+        playerSessionMap.put(sessionId, player);
+
+        String destination = "/sub/room/" + roomId;
+
+        RoomSettingResponse roomSettingResponse = toRoomSettingResponse(room);
+        //todo quiz 생성 api 완성 후 수정
+        QuizResponse quiz = new QuizResponse(room.getGameSetting().getQuizId(), "title", "설명",
+            "url", 10);
+        GameSettingResponse gameSettingResponse = toGameSettingResponse(room.getGameSetting(),
+            quiz);
+
+        PlayerListResponse playerListResponse = toPlayerListResponse(room);
+
+        return new RoomInitialData(destination, roomSettingResponse, gameSettingResponse,
+            playerListResponse);
+    }
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/MessageType.java b/backend/src/main/java/io/f1/backend/domain/game/dto/MessageType.java
@@ -0,0 +1,7 @@
+package io.f1.backend.domain.game.dto;
+
+public enum MessageType {
+    ROOM_SETTING,
+    GAME_SETTING,
+    PLAYER_LIST,
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/RoomInitialData.java b/backend/src/main/java/io/f1/backend/domain/game/dto/RoomInitialData.java
@@ -0,0 +1,11 @@
+package io.f1.backend.domain.game.dto;
+
+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.RoomSettingResponse;
+
+public record RoomInitialData(String destination, RoomSettingResponse roomSettingResponse,
+                              GameSettingResponse gameSettingResponse,
+                              PlayerListResponse playerListResponse) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/WebSocketDto.java b/backend/src/main/java/io/f1/backend/domain/game/dto/WebSocketDto.java
@@ -0,0 +1,6 @@
+package io.f1.backend.domain.game.dto;
+
+public interface WebSocketDto <T>{
+    MessageType getType();
+    T getMessage();
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/request/RoomCreateRequest.java b/backend/src/main/java/io/f1/backend/domain/game/dto/request/RoomCreateRequest.java
@@ -12,4 +12,4 @@ public record RoomCreateRequest(
                 @Max(value = 8, message = "방 인원 수는 최대 8명 입니다.")
                 Integer maxUserCount,
         @NotNull String password,
-        @NotNull boolean locked) {}
+        @NotNull Boolean locked) {}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/request/RoomValidationRequest.java b/backend/src/main/java/io/f1/backend/domain/game/dto/request/RoomValidationRequest.java
@@ -0,0 +1,5 @@
+package io.f1.backend.domain.game.dto.request;
+
+public record RoomValidationRequest(Long roomId, String password) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/DefaultWebSocketResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/DefaultWebSocketResponse.java
@@ -0,0 +1,13 @@
+package io.f1.backend.domain.game.dto.response;
+
+import io.f1.backend.domain.game.dto.MessageType;
+import io.f1.backend.domain.game.dto.WebSocketDto;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public class DefaultWebSocketResponse<T> implements WebSocketDto<T> {
+    private final MessageType type;
+    private final T message;
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/GameSettingResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/GameSettingResponse.java
@@ -0,0 +1,5 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record GameSettingResponse(int round, int timeLimit, QuizResponse quiz) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/PlayerListResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/PlayerListResponse.java
@@ -0,0 +1,7 @@
+package io.f1.backend.domain.game.dto.response;
+
+import java.util.List;
+
+public record PlayerListResponse(String host, List<PlayerResponse> players) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/PlayerResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/PlayerResponse.java
@@ -0,0 +1,5 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record PlayerResponse(String nickname, boolean ready) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/QuizResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/QuizResponse.java
@@ -0,0 +1,6 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record QuizResponse(Long quizId, String title, String description, String thumbnailUrl,
+                           int numberOfQuestion) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/RoomCreateResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/RoomCreateResponse.java
@@ -1,3 +1,5 @@
 package io.f1.backend.domain.game.dto.response;
 
-public record RoomCreateResponse(Long roomId) {}
+public record RoomCreateResponse(Long roomId) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/RoomSettingResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/RoomSettingResponse.java
@@ -0,0 +1,5 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record RoomSettingResponse(String roomName, int maxUserCount, int currentUserCount) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/RoomValidationResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/RoomValidationResponse.java
@@ -0,0 +1,5 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record RoomValidationResponse(Long roomId) {
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/mapper/RoomMapper.java b/backend/src/main/java/io/f1/backend/domain/game/mapper/RoomMapper.java
@@ -1,12 +1,40 @@
 package io.f1.backend.domain.game.mapper;
 
 import io.f1.backend.domain.game.dto.request.RoomCreateRequest;
+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;
+import io.f1.backend.domain.game.dto.response.QuizResponse;
+import io.f1.backend.domain.game.dto.response.RoomSettingResponse;
+import io.f1.backend.domain.game.model.GameSetting;
+import io.f1.backend.domain.game.model.Room;
 import io.f1.backend.domain.game.model.RoomSetting;
+import java.util.List;
 
 public class RoomMapper {
 
     public static RoomSetting toRoomSetting(RoomCreateRequest request) {
         return new RoomSetting(
-                request.roomName(), request.maxUserCount(), request.locked(), request.password());
+            request.roomName(), request.maxUserCount(), request.locked(), request.password());
+    }
+
+    public static RoomSettingResponse toRoomSettingResponse(Room room) {
+        return new RoomSettingResponse(
+            room.getRoomSetting().roomName(), room.getRoomSetting()
+            .maxUserCount(), room.getPlayerSessionMap().size());
+    }
+
+    public static GameSettingResponse toGameSettingResponse(GameSetting gameSetting, QuizResponse quiz) {
+        return new GameSettingResponse(
+            gameSetting.getRound(), gameSetting.getTimeLimit(),
+            quiz);
+    }
+
+    public static PlayerListResponse toPlayerListResponse(Room room) {
+        List<PlayerResponse> playerResponseList = room.getPlayerSessionMap().values().stream()
+            .map(player -> new PlayerResponse(player.getNickname(), false))
+            .toList();
+
+        return new PlayerListResponse(room.getHost().getNickname(), playerResponseList);
     }
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/store/RoomRepository.java b/backend/src/main/java/io/f1/backend/domain/game/store/RoomRepository.java
@@ -1,7 +1,10 @@
 package io.f1.backend.domain.game.store;
 
 import io.f1.backend.domain.game.model.Room;
+import java.util.Optional;
 
 public interface RoomRepository {
     void saveRoom(Room room);
+
+    Optional<Room> findRoom(Long roomId);
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/store/RoomRepositoryImpl.java b/backend/src/main/java/io/f1/backend/domain/game/store/RoomRepositoryImpl.java
@@ -2,6 +2,7 @@
 
 import io.f1.backend.domain.game.model.Room;
 
+import java.util.Optional;
 import org.springframework.stereotype.Repository;
 
 import java.util.Map;
@@ -17,6 +18,11 @@ public void saveRoom(Room room) {
         roomMap.put(room.getId(), room);
     }
 
+    @Override
+    public Optional<Room> findRoom(Long roomId) {
+        return Optional.ofNullable(roomMap.get(roomId));
+    }
+
     // 테스트 전용 메소드
     public Room getRoomForTest(Long roomId) {
         return roomMap.get(roomId);
diff --git a/backend/src/main/java/io/f1/backend/domain/game/websocket/GameSocketController.java b/backend/src/main/java/io/f1/backend/domain/game/websocket/GameSocketController.java
@@ -0,0 +1,38 @@
+package io.f1.backend.domain.game.websocket;
+
+import io.f1.backend.domain.game.app.RoomService;
+import io.f1.backend.domain.game.dto.MessageType;
+import io.f1.backend.domain.game.dto.RoomInitialData;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
+import org.springframework.stereotype.Controller;
+
+@Controller
+@RequiredArgsConstructor
+public class GameSocketController {
+
+    private final MessageSender messageSender;
+    private final RoomService roomService;
+
+    @MessageMapping("/room/enter/{roomId}")
+    public void roomEnter(@DestinationVariable Long roomId, Message<?> message) {
+
+        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
+        String websocketSessionId = accessor.getSessionId();
+
+        RoomInitialData roomInitialData = roomService.enterRoom(roomId, websocketSessionId);
+        String destination = roomInitialData.destination();
+
+        messageSender.send(destination, MessageType.ROOM_SETTING,
+            roomInitialData.roomSettingResponse());
+        messageSender.send(destination, MessageType.GAME_SETTING,
+            roomInitialData.gameSettingResponse());
+        messageSender.send(destination, MessageType.PLAYER_LIST,
+            roomInitialData.playerListResponse());
+    }
+
+
+}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/websocket/MessageSender.java b/backend/src/main/java/io/f1/backend/domain/game/websocket/MessageSender.java
@@ -0,0 +1,20 @@
+package io.f1.backend.domain.game.websocket;
+
+import io.f1.backend.domain.game.dto.MessageType;
+import io.f1.backend.domain.game.dto.response.DefaultWebSocketResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class MessageSender {
+
+    private final SimpMessagingTemplate messagingTemplate;
+
+    public <T> void send(String destination, MessageType type, T message) {
+        messagingTemplate.convertAndSend(destination,
+            new DefaultWebSocketResponse<>(type, message));
+    }
+
+}
diff --git a/backend/src/main/java/io/f1/backend/global/config/StompChannelInterceptor.java b/backend/src/main/java/io/f1/backend/global/config/StompChannelInterceptor.java
@@ -0,0 +1,45 @@
+package io.f1.backend.global.config;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.messaging.simp.stomp.StompCommand;
+import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
+import org.springframework.messaging.support.ChannelInterceptor;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class StompChannelInterceptor implements ChannelInterceptor {
+
+    @Override
+    public Message<?> preSend(Message<?> message, MessageChannel channel) {
+
+        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
+        StompCommand command = accessor.getCommand();
+        String sessionId = accessor.getSessionId();
+        String destination = accessor.getDestination();
+
+        if(command == null){
+            throw new IllegalArgumentException("Stomp command required");
+        }
+
+        switch (command) {
+            case CONNECT -> log.info("CONNECT : 세션 연결 - sessionId = {}", sessionId);
+
+            case SUBSCRIBE -> {
+                if (destination != null && sessionId != null) {
+                    log.info("SUBSCRIBE : 구독 시작 destination = {}", destination);
+                }
+            }
+
+            case DISCONNECT -> log.info("DISCONNECT : 연결 해제 sessionId = {}", sessionId);
+
+            default -> throw new IllegalStateException("Unexpected command: " + command);
+        }
+
+        return message;
+    }
+}
diff --git a/backend/src/main/java/io/f1/backend/global/config/WebSocketConfig.java b/backend/src/main/java/io/f1/backend/global/config/WebSocketConfig.java
diff --git a/backend/src/main/resources/static/ws-test.html b/backend/src/main/resources/static/ws-test.html
diff --git a/backend/src/main/resources/static/ws-test.js b/backend/src/main/resources/static/ws-test.js

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +package io.f1.backend.domain.game.dto.request;
++
 +public record RoomValidationRequest(Long roomId, String password) {
++
 +}