Merge pull request #83 from kjiyun/chat

#82 Feat: 채팅 페이지네이션 기능 추가

Author: kjiyun

src/main/java/com/memesphere/domain/chat/controller/ChatController.java

@@ -1,15 +1,15 @@
 package com.memesphere.domain.chat.controller;
 
 import com.memesphere.domain.chat.dto.request.ChatRequest;
-import com.memesphere.domain.chat.dto.response.ChatListResponse;
 import com.memesphere.domain.chat.dto.response.ChatResponse;
 import com.memesphere.domain.chat.service.ChatService;
 import com.memesphere.global.apipayload.ApiResponse;
 import com.memesphere.global.jwt.CustomUserDetails;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
-import lombok.extern.log4j.Log4j2;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 import org.springframework.messaging.handler.annotation.DestinationVariable;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.messaging.handler.annotation.Payload;
@@ -32,17 +32,17 @@ public ChatResponse chat(@DestinationVariable("coin_id") Long coin_id,
         return chatService.saveMessage(coin_id, chatRequest);
     }
 
-    @GetMapping("/chat/{coin_id}/list/")
+    @GetMapping("/chat/{coin_id}/list")
     @Operation(summary = "코인별 채팅 전체 메시지 조회 API",
             description = "특정 코인의 채팅방의 전체 메시지를 보여줍니다.")
-    public ApiResponse<ChatListResponse> getChatList(@PathVariable("coin_id") Long coin_id) {
-        ChatListResponse chatListResponse = chatService.getChatList(coin_id);
+    public ApiResponse<Page<ChatResponse>> getChatList(@PathVariable("coin_id") Long coin_id,
+                                                           Pageable pageable) {
 
-        return ApiResponse.onSuccess(chatListResponse);
+        return ApiResponse.onSuccess(chatService.getChatList(coin_id, pageable));
     }
 
     //최신 댓글 조회 Api
-    @GetMapping("/chat/{coin_id}/latest/")
+    @GetMapping("/chat/{coin_id}/latest")
     @Operation(summary = "코인별 최신 댓글 조회 API",
             description = "특정 코인에 대한 최신 댓글을 반환합니다. 요청 시 최신 댓글 하나만 가져옵니다.")
     public ApiResponse<ChatResponse> getLatestMessages(

src/main/java/com/memesphere/domain/chat/converter/ChatConverter.java

@@ -1,15 +1,12 @@
 package com.memesphere.domain.chat.converter;
 
-import com.memesphere.domain.chat.dto.response.ChatListResponse;
 import com.memesphere.domain.chat.entity.Chat;
 import com.memesphere.domain.chat.entity.ChatLike;
 import com.memesphere.domain.memecoin.entity.MemeCoin;
 import com.memesphere.domain.chat.dto.request.ChatRequest;
 import com.memesphere.domain.chat.dto.response.ChatResponse;
 import com.memesphere.domain.user.entity.User;
 
-import java.util.List;
-
 public class ChatConverter {
 
     public static Chat toChat(MemeCoin memeCoin, ChatRequest chatRequest, User user) {
@@ -33,12 +30,6 @@ public static ChatResponse toChatResponse(Chat chat) {
                 .build();
     }
 
-    public static ChatListResponse toChatListResponse(List<ChatResponse> chatResponses) {
-        return ChatListResponse.builder()
-                .chats(chatResponses)
-                .build();
-    }
-
     public static ChatLike toChatLike(Chat chat, User user) {
         return ChatLike.builder()
                 .user(user)

src/main/java/com/memesphere/domain/chat/dto/response/ChatListResponse.java

@@ -1,12 +1,14 @@
 package com.memesphere.domain.chat.repository;
 
 import com.memesphere.domain.chat.entity.Chat;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;
 
-public interface ChatRepository extends JpaRepository<Chat, Long>, ChatCustomRepository {
+public interface ChatRepository extends JpaRepository<Chat, Long> {
 
     Chat findFirstByMemeCoin_IdOrderByCreatedAtDesc(Long coin_id);
-    List<Chat> findAllByMemeCoin_Id(Long coin_id);
+    Page<Chat> findAllByMemeCoin_Id(Long coin_id, Pageable pageable);
 }

src/main/java/com/memesphere/domain/chat/repository/ChatCustomRepository.java

@@ -1,7 +1,6 @@
 package com.memesphere.domain.chat.service;
 
 import com.memesphere.domain.chat.converter.ChatConverter;
-import com.memesphere.domain.chat.dto.response.ChatListResponse;
 import com.memesphere.domain.chat.entity.Chat;
 import com.memesphere.domain.chat.entity.ChatLike;
 import com.memesphere.domain.chat.repository.ChatLikeRepository;
@@ -15,11 +14,11 @@
 import com.memesphere.domain.memecoin.repository.MemeCoinRepository;
 import com.memesphere.domain.chat.repository.ChatRepository;
 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;
 
-import java.util.ArrayList;
-import java.util.List;
 import java.util.Optional;
 
 @Service
@@ -46,18 +45,10 @@ public ChatResponse saveMessage(Long coin_id, ChatRequest chatRequest) {
     }
 
     @Transactional
-    public ChatListResponse getChatList(Long coin_id) {
+    public Page<ChatResponse> getChatList(Long coin_id, Pageable pageable) {
 
-        List<Chat> chatList = chatRepository.findAllByMemeCoin_Id(coin_id);
-        List<ChatResponse> chatResponses = new ArrayList<>();
-
-        for (Chat chat : chatList) {
-            ChatResponse chatResponse = ChatConverter.toChatResponse(chat);
-            chatResponses.add(chatResponse);
-        }
-
-        ChatListResponse chatListResponse = ChatConverter.toChatListResponse(chatResponses);
-        return chatListResponse;
+        Page<Chat> chatPage = chatRepository.findAllByMemeCoin_Id(coin_id, pageable);
+        return chatPage.map(ChatConverter::toChatResponse);
     }
 
     // 최신 댓글을 가져오는 메서드