Merge remote-tracking branch 'origin/dev' into refactor/86

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

Author: sehee123

backend/src/main/java/io/f1/backend/domain/admin/api/AdminController.java

@@ -0,0 +1,28 @@
+package io.f1.backend.domain.admin.api;
+
+import io.f1.backend.domain.admin.app.AdminService;
+import io.f1.backend.domain.admin.dto.UserPageResponse;
+import io.f1.backend.global.validation.LimitPageSize;
+
+import lombok.RequiredArgsConstructor;
+
+import org.springframework.data.domain.Pageable;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/admin")
+@RequiredArgsConstructor
+public class AdminController {
+
+    private final AdminService adminService;
+
+    @LimitPageSize
+    @GetMapping("/users")
+    public ResponseEntity<UserPageResponse> getUsers(Pageable pageable) {
+        UserPageResponse response = adminService.getAllUsers(pageable);
+        return ResponseEntity.ok().body(response);
+    }
+}

backend/src/main/java/io/f1/backend/domain/admin/app/AdminService.java

@@ -0,0 +1,27 @@
+package io.f1.backend.domain.admin.app;
+
+import static io.f1.backend.domain.admin.mapper.AdminMapper.toUserListPageResponse;
+
+import io.f1.backend.domain.admin.dto.UserPageResponse;
+import io.f1.backend.domain.admin.dto.UserResponse;
+import io.f1.backend.domain.user.dao.UserRepository;
+
+import lombok.RequiredArgsConstructor;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+public class AdminService {
+
+    private final UserRepository userRepository;
+
+    @Transactional(readOnly = true)
+    public UserPageResponse getAllUsers(Pageable pageable) {
+        Page<UserResponse> users = userRepository.findAllUsersWithPaging(pageable);
+        return toUserListPageResponse(users);
+    }
+}

backend/src/main/java/io/f1/backend/domain/admin/dto/UserPageResponse.java

@@ -0,0 +1,6 @@
+package io.f1.backend.domain.admin.dto;
+
+import java.util.List;
+
+public record UserPageResponse(
+        int totalPages, int currentPage, int totalElements, List<UserResponse> users) {}

backend/src/main/java/io/f1/backend/domain/admin/dto/UserResponse.java

@@ -0,0 +1,6 @@
+package io.f1.backend.domain.admin.dto;
+
+import java.time.LocalDateTime;
+
+public record UserResponse(
+        Long id, String nickname, LocalDateTime lastLogin, LocalDateTime createdAt) {}

backend/src/main/java/io/f1/backend/domain/admin/entity/Admin.java

@@ -8,12 +8,15 @@
 import jakarta.persistence.GenerationType;
 import jakarta.persistence.Id;
 
+import lombok.Builder;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 import java.time.LocalDateTime;
 
 @Entity
 @Getter
+@NoArgsConstructor
 public class Admin extends BaseEntity {
 
     @Id
@@ -32,4 +35,12 @@ public class Admin extends BaseEntity {
     public void updateLastLogin(LocalDateTime lastLogin) {
         this.lastLogin = lastLogin;
     }
+
+    @Builder
+    public Admin(Long id, String username, String password, LocalDateTime lastLogin) {
+        this.id = id;
+        this.username = username;
+        this.password = password;
+        this.lastLogin = LocalDateTime.now();
+    }
 }

backend/src/main/java/io/f1/backend/domain/admin/mapper/AdminMapper.java

@@ -0,0 +1,21 @@
+package io.f1.backend.domain.admin.mapper;
+
+import io.f1.backend.domain.admin.dto.UserPageResponse;
+import io.f1.backend.domain.admin.dto.UserResponse;
+
+import org.springframework.data.domain.Page;
+
+public class AdminMapper {
+
+    private AdminMapper() {}
+
+    public static UserPageResponse toUserListPageResponse(Page<UserResponse> userPage) {
+        int curPage = userPage.getNumber() + 1;
+
+        return new UserPageResponse(
+                userPage.getTotalPages(),
+                curPage,
+                userPage.getNumberOfElements(),
+                userPage.getContent());
+    }
+}

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

@@ -2,17 +2,16 @@
 
 import static io.f1.backend.domain.quiz.mapper.QuizMapper.toGameStartResponse;
 
-import io.f1.backend.domain.game.dto.request.GameStartRequest;
 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.question.entity.Question;
 import io.f1.backend.domain.quiz.app.QuizService;
 import io.f1.backend.domain.quiz.entity.Quiz;
+import io.f1.backend.domain.user.dto.UserPrincipal;
 import io.f1.backend.global.exception.CustomException;
 import io.f1.backend.global.exception.errorcode.GameErrorCode;
 import io.f1.backend.global.exception.errorcode.RoomErrorCode;
@@ -24,6 +23,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 
 @Service
 @RequiredArgsConstructor
@@ -33,53 +33,54 @@ public class GameService {
     private final RoomRepository roomRepository;
     private final ApplicationEventPublisher eventPublisher;
 
-    public GameStartResponse gameStart(Long roomId, GameStartRequest gameStartRequest) {
-
-        Long quizId = gameStartRequest.quizId();
+    public GameStartResponse gameStart(Long roomId, UserPrincipal principal) {
 
         Room room =
                 roomRepository
                         .findRoom(roomId)
                         .orElseThrow(() -> new CustomException(RoomErrorCode.ROOM_NOT_FOUND));
 
-        if (!validateReadyStatus(room)) {
-            throw new CustomException(RoomErrorCode.PLAYER_NOT_READY);
-        }
-
-        // 방의 gameSetting에 설정된 퀴즈랑 요청 퀴즈랑 같은지 체크 후 GameSetting에서 라운드 가져오기
-        Integer round = checkGameSetting(room, quizId);
+        validateRoomStart(room, principal);
 
+        Long quizId = room.getGameSetting().getQuizId();
         Quiz quiz = quizService.getQuizWithQuestionsById(quizId);
+        List<Question> questions = prepareQuestions(room, quiz);
 
-        // 라운드 수만큼 랜덤 Question 추출
-        List<Question> questions = quizService.getRandomQuestionsWithoutAnswer(quizId, round);
         room.updateQuestions(questions);
 
-        GameStartResponse gameStartResponse = toGameStartResponse(questions);
-
         // 방 정보 게임 중으로 변경
         room.updateRoomState(RoomState.PLAYING);
 
         eventPublisher.publishEvent(new RoomUpdatedEvent(room, quiz));
 
-        return gameStartResponse;
+        return toGameStartResponse(questions);
     }
 
-    private Integer checkGameSetting(Room room, Long quizId) {
-
-        GameSetting gameSetting = room.getGameSetting();
+    private boolean validateReadyStatus(Room room) {
 
-        if (!gameSetting.validateQuizId(quizId)) {
-            throw new CustomException(GameErrorCode.GAME_SETTING_CONFLICT);
-        }
+        Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
 
-        return gameSetting.getRound();
+        return playerSessionMap.values().stream().allMatch(Player::isReady);
     }
 
-    private boolean validateReadyStatus(Room room) {
+    private void validateRoomStart(Room room, UserPrincipal principal) {
+        if (!Objects.equals(principal.getUserId(), room.getHost().getId())) {
+            throw new CustomException(RoomErrorCode.NOT_ROOM_OWNER);
+        }
 
-        Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
+        if (!validateReadyStatus(room)) {
+            throw new CustomException(GameErrorCode.PLAYER_NOT_READY);
+        }
 
-        return playerSessionMap.values().stream().allMatch(Player::isReady);
+        if (room.getState() == RoomState.PLAYING) {
+            throw new CustomException(RoomErrorCode.GAME_ALREADY_PLAYING);
+        }
+    }
+
+    // 라운드 수만큼 랜덤 Question 추출
+    private List<Question> prepareQuestions(Room room, Quiz quiz) {
+        Long quizId = quiz.getId();
+        Integer round = room.getGameSetting().getRound();
+        return quizService.getRandomQuestionsWithoutAnswer(quizId, round);
     }
 }

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

@@ -5,15 +5,12 @@
 import io.f1.backend.domain.game.dto.ChatMessage;
 import io.f1.backend.domain.game.dto.MessageType;
 import io.f1.backend.domain.game.dto.request.DefaultWebSocketRequest;
-import io.f1.backend.domain.game.dto.request.GameStartRequest;
 import io.f1.backend.domain.game.dto.response.GameStartResponse;
 import io.f1.backend.domain.user.dto.UserPrincipal;
 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.security.core.Authentication;
 import org.springframework.stereotype.Controller;
 
 @Controller
@@ -48,9 +45,13 @@ public void exitRoom(@DestinationVariable Long roomId, Message<?> message) {
     public void gameStart(
         @DestinationVariable Long roomId,
         Message<DefaultWebSocketRequest<GameStartRequest>> message) {
+    public void gameStart(@DestinationVariable Long roomId, Message<?> message) {
 
         GameStartResponse gameStartResponse =
             gameService.gameStart(roomId, message.getPayload().getMessage());
+        UserPrincipal principal = getSessionUser(message);
+
+        GameStartResponse gameStartResponse = gameService.gameStart(roomId, principal);
 
         String destination = getDestination(roomId);
 

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

@@ -0,0 +1,21 @@
+package io.f1.backend.domain.game.websocket;
+
+import io.f1.backend.domain.user.dto.UserPrincipal;
+
+import org.springframework.messaging.Message;
+import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
+import org.springframework.security.core.Authentication;
+
+public class WebSocketUtils {
+
+    public static String getSessionId(Message<?> message) {
+        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
+        return accessor.getSessionId();
+    }
+
+    public static UserPrincipal getSessionUser(Message<?> message) {
+        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
+        Authentication auth = (Authentication) accessor.getUser();
+        return (UserPrincipal) auth.getPrincipal();
+    }
+}