Feat:채팅방 검색

Author: skyeong42

src/main/java/cmf/commitField/domain/chat/chatRoom/controller/ChatRoomController.java

@@ -213,6 +213,30 @@ public GlobalResponse<Object> getMyHeartRoomList(
         return GlobalResponse.success("좋아요 누른 채팅방 리스트 조회 완료", list);
     }
 
+    // 채팅방 제목 검색 조회
+    @GetMapping("/room/search")
+    @LoginCheck
+    public GlobalResponse<Object> searchRoomName(
+            @RequestParam(name = "roomName") String roomName,
+            Pageable pageable) {
+
+        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+
+        if (authentication instanceof OAuth2AuthenticationToken) {
+            CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
+            Long userId = principal.getId();  // Extract userId from the principal
+
+            if (roomName.isEmpty()) {
+                throw new IllegalArgumentException("원하는 채팅방의 제목을 입력하세요.");
+            }
+
+            List<ChatRoomDto> list = chatRoomService.searchRoomByTitle(roomName, userId, pageable);
+            return GlobalResponse.success(list);
+        } else {
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
+        }
+    }
+
 
 
 

src/main/java/cmf/commitField/domain/chat/chatRoom/repository/ChatRoomRepository.java

@@ -36,4 +36,7 @@ public interface ChatRoomRepository extends JpaRepository<ChatRoom, Long> {
     @Query("SELECT c FROM ChatRoom c WHERE c.id IN :ids ORDER BY c.createdAt DESC")
     Page<ChatRoom> findChatRoomByInId(@Param("ids") List<Long> ids, Pageable pageable);
 
+    @Query("SELECT c FROM ChatRoom c WHERE c.title LIKE CONCAT('%', :title, '%')")
+    Page<ChatRoom> findChatRoomWithPartOfTitle(@Param("title") String title, Pageable pageable);
+
 }

src/main/java/cmf/commitField/domain/chat/chatRoom/service/ChatRoomService.java

@@ -35,4 +35,6 @@ public interface ChatRoomService {
     List<ChatRoomDto> myHeartRoomList(Long userId, Pageable pageable);
 
     void joinRoom(Long roomId, Long userId, ChatRoomRequest chatRoomRequest);
+
+    List<ChatRoomDto> searchRoomByTitle(String roomName, Long userId, Pageable pageable);
 }

src/main/java/cmf/commitField/domain/chat/chatRoom/service/ChatRoomServiceImpl.java

@@ -29,6 +29,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
+import static cmf.commitField.global.error.ErrorCode.NOT_FOUND_ROOM;
 import static java.time.LocalDateTime.now;
 
 @Service
@@ -138,7 +139,7 @@ public void joinRoom(Long roomId, Long userId, ChatRoomRequest chatRoomRequest)
 
             // room 조회
             ChatRoom chatRoom = chatRoomRepository.findById(roomId) // lock (기존)
-                    .orElseThrow(() -> new CustomException(ErrorCode.NOT_FOUND_ROOM));
+                    .orElseThrow(() -> new CustomException(NOT_FOUND_ROOM));
 
             // user_chatroom 현재 인원 카운트 (비즈니스 로직)
             Long currentUserCount = userChatRoomRepository.countNonLockByChatRoomId(roomId); // lock (기존)
@@ -236,6 +237,31 @@ public void updateRoom(Long roomId, ChatRoomUpdateRequest chatRoomUpdateRequest,
         chatRoomRepository.save(room);
     }
 
+    @Override
+    @Transactional(readOnly = true)
+    public List<ChatRoomDto> searchRoomByTitle(String roomName, Long userId, Pageable pageable) {
+        getUser(userId);
+        Page<ChatRoom> search = chatRoomRepository.findChatRoomWithPartOfTitle(roomName, pageable);
+
+        List<ChatRoom> searchRoomList = search.toList();
+        List<ChatRoomDto> chatRoomDtos = new ArrayList<>();
+        if (searchRoomList.isEmpty()) {
+            throw new CustomException(NOT_FOUND_ROOM);
+        }
+
+        for (ChatRoom chatRoom : searchRoomList) {
+            ChatRoomDto build = ChatRoomDto.builder()
+                    .id(chatRoom.getId())
+                    .title(chatRoom.getTitle())
+                    .heartCount(chatRoom.getHearts().size())
+                    .currentUserCount((long) chatRoom.getUserChatRooms().size())
+                    .userCountMax(chatRoom.getUserCountMax())
+                    .build();
+            chatRoomDtos.add(build);
+        }
+        return chatRoomDtos;
+    }
+
     private User getUser(Long userId) {
         return userRepository.findById(userId)
                 .orElseThrow(() -> new CustomException(ErrorCode.NOT_FOUND_USER));

src/main/java/cmf/commitField/domain/chat/chatRoom/service/CocurrencyChatRoomTest.java

@@ -3,6 +3,7 @@
 //import cmf.commitField.domain.chat.chatRoom.entity.ChatRoom;
 //import cmf.commitField.domain.chat.chatRoom.repository.ChatRoomRepository;
 //import cmf.commitField.domain.chat.userChatRoom.repository.UserChatRoomRepository;
+//import cmf.commitField.domain.user.service.UserService;
 //import org.springframework.beans.factory.annotation.Autowired;
 //
 //import java.util.ArrayList;