✨ 게임 시작 상태 SSE로 이벤트 퍼블리시

Author: silver-eunjoo

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

@@ -2,15 +2,18 @@
 
 import io.f1.backend.domain.game.dto.GameStartData;
 import io.f1.backend.domain.game.dto.response.GameStartResponse;
+import io.f1.backend.domain.game.event.RoomUpdatedEvent;
 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.RoomState;
 import io.f1.backend.domain.game.store.RoomRepository;
 import io.f1.backend.domain.quiz.app.QuizService;
 
+import io.f1.backend.domain.quiz.entity.Quiz;
 import lombok.RequiredArgsConstructor;
 
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 
 import java.util.Map;
@@ -21,26 +24,15 @@ public class GameService {
 
     private final QuizService quizService;
     private final RoomRepository roomRepository;
+    private final ApplicationEventPublisher eventPublisher;
 
-    private Integer checkGameSetting(Room room, Long quizId) {
-
-        GameSetting gameSetting = room.getGameSetting();
-
-        Long roomQuizId = gameSetting.getQuizId();
-
-        if (!roomQuizId.equals(quizId)) {
-            throw new IllegalArgumentException("E409002 : 게임 설정이 다릅니다. (게임을 시작할 수 없습니다.)");
-        }
-
-        return gameSetting.getRound();
-    }
 
     public GameStartData gameStart(Long roomId, Long quizId) {
 
         Room room =
-                roomRepository
-                        .findRoom(roomId)
-                        .orElseThrow(() -> new IllegalArgumentException("404 존재하지 않는 방입니다."));
+            roomRepository
+                .findRoom(roomId)
+                .orElseThrow(() -> new IllegalArgumentException("404 존재하지 않는 방입니다."));
 
         if (!validateReadyStatus(room)) {
             throw new IllegalArgumentException("E403004 : 레디 상태가 아닙니다.");
@@ -49,15 +41,32 @@ public GameStartData gameStart(Long roomId, Long quizId) {
         // 방의 gameSetting에 설정된 퀴즈랑 요청 퀴즈랑 같은지 체크 후 GameSetting에서 라운드 가져오기
         Integer round = checkGameSetting(room, quizId);
 
+        Quiz quiz = quizService.getQuizWithQuestionsById(quizId);
+
         // 라운드 수만큼 랜덤 Question 추출
         GameStartResponse questions = quizService.getRandomQuestionsWithoutAnswer(quizId, round);
 
         // 방 정보 게임 중으로 변경
         room.updateRoomState(RoomState.PLAYING);
 
+        eventPublisher.publishEvent(new RoomUpdatedEvent(room, quiz));
+
         return new GameStartData(getDestination(roomId), questions);
     }
 
+    private Integer checkGameSetting(Room room, Long quizId) {
+
+        GameSetting gameSetting = room.getGameSetting();
+
+        Long roomQuizId = gameSetting.getQuizId();
+
+        if (!roomQuizId.equals(quizId)) {
+            throw new IllegalArgumentException("E409002 : 게임 설정이 다릅니다. (게임을 시작할 수 없습니다.)");
+        }
+
+        return gameSetting.getRound();
+    }
+
     private boolean validateReadyStatus(Room room) {
 
         Map<String, Player> playerSessionMap = room.getPlayerSessionMap();

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

@@ -60,7 +60,7 @@ public class RoomService {
     public RoomCreateResponse saveRoom(RoomCreateRequest request) {
 
         Long quizMinId = quizService.getQuizMinId();
-        Quiz quiz = quizService.getQuizById(quizMinId);
+        Quiz quiz = quizService.getQuizWithQuestionsById(quizMinId);
 
         GameSetting gameSetting = toGameSetting(quiz);
 
@@ -132,7 +132,7 @@ public RoomInitialData initializeRoomSocket(Long roomId, String sessionId) {
         RoomSettingResponse roomSettingResponse = toRoomSettingResponse(room);
 
         Long quizId = room.getGameSetting().getQuizId();
-        Quiz quiz = quizService.getQuizById(quizId);
+        Quiz quiz = quizService.getQuizWithQuestionsById(quizId);
 
         GameSettingResponse gameSettingResponse =
                 toGameSettingResponse(room.getGameSetting(), quiz);
@@ -189,7 +189,7 @@ public RoomListResponse getAllRooms() {
                         .map(
                                 room -> {
                                     Long quizId = room.getGameSetting().getQuizId();
-                                    Quiz quiz = quizService.getQuizById(quizId);
+                                    Quiz quiz = quizService.getQuizWithQuestionsById(quizId);
 
                                     return toRoomResponse(room, quiz);
                                 })

backend/src/main/java/io/f1/backend/domain/quiz/app/QuizService.java

@@ -216,12 +216,11 @@ public QuizListPageResponse getQuizzes(String title, String creator, Pageable pa
     }
 
     @Transactional(readOnly = true)
-    public Quiz getQuizById(Long quizId) {
+    public Quiz getQuizWithQuestionsById(Long quizId) {
         Quiz quiz =
                 quizRepository
-                        .findById(quizId)
+                        .findQuizWithQuestionsById(quizId)
                         .orElseThrow(() -> new RuntimeException("E404002: 존재하지 않는 퀴즈입니다."));
-        quiz.getQuestions().size();
         return quiz;
     }
 

backend/src/main/java/io/f1/backend/domain/quiz/dao/QuizRepository.java

@@ -3,19 +3,24 @@
 import io.f1.backend.domain.question.entity.Question;
 import io.f1.backend.domain.quiz.entity.Quiz;
 
+import java.util.Optional;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
 
 import java.util.List;
+import org.springframework.data.repository.query.Param;
 
 public interface QuizRepository extends JpaRepository<Quiz, Long> {
 
     Page<Quiz> findQuizzesByTitleContaining(String title, Pageable pageable);
 
     Page<Quiz> findQuizzesByCreator_NicknameContaining(String creator, Pageable pageable);
 
+    @Query("SELECT q FROM Quiz q LEFT JOIN FETCH q.questions WHERE q.id = :quizId")
+    Optional<Quiz> findQuizWithQuestionsById(Long quizId);
+
     @Query("SELECT MIN(q.id) FROM Quiz q")
     Long getQuizMinId();