Merge pull request #74 from CommitField/feat/#20

Feat/#20

Author: skyeong42

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

@@ -4,6 +4,7 @@
 import cmf.commitField.domain.chat.chatRoom.dto.ChatRoomDto;
 import cmf.commitField.domain.chat.chatRoom.service.ChatRoomService;
 import cmf.commitField.domain.user.entity.CustomOAuth2User;
+import cmf.commitField.global.error.ErrorCode;
 import cmf.commitField.global.globalDto.GlobalResponse;
 import cmf.commitField.global.security.LoginCheck;
 import jakarta.validation.Valid;
@@ -32,9 +33,9 @@ public GlobalResponse<Object> createRoom(
             CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
             Long userId = principal.getId();  // getId()를 통해 userId를 추출
             chatRoomService.createRoom(chatRoomRequest, userId);  // userId를 전달
-            return GlobalResponse.success();
+            return GlobalResponse.success("채팅방을 생성하였습니다.");
         } else {
-            throw new IllegalArgumentException("User not logged in.");
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
         }
     }
 
@@ -47,9 +48,9 @@ public GlobalResponse<Object> joinRoom(@PathVariable Long roomId) {
             CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
             Long userId = principal.getId();  // getId()를 통해 userId를 추출
             chatRoomService.joinRoom(roomId, userId);  // userId를 전달
-            return GlobalResponse.success();
+            return GlobalResponse.success("해당 채팅방에 입장하셨습니다");
         } else {
-            throw new IllegalArgumentException("User not logged in.");
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
         }
     }
 
@@ -58,7 +59,13 @@ public GlobalResponse<Object> joinRoom(@PathVariable Long roomId) {
     @LoginCheck
     public GlobalResponse<Object> roomList(Pageable pageable) {
         List<ChatRoomDto> roomList = chatRoomService.getRoomList(pageable);
-        return GlobalResponse.success(roomList);
+
+        // 방 리스트가 비어 있으면 notFound 응답 반환
+        if (roomList.isEmpty()) {
+            return GlobalResponse.error(ErrorCode.NO_ROOM_FOUND);
+        }
+
+        return GlobalResponse.success("전체 목록 조회에 성공하였습니다.",roomList);
     }
 
     // 사용자(자신)가 생성한 방 리스트 조회
@@ -72,9 +79,15 @@ public GlobalResponse<Object> getByUserRoomList(Pageable pageable) {
             Long userId = principal.getId();  // getId()를 통해 userId를 추출
 
             List<ChatRoomDto> userByRoomList = chatRoomService.getUserByRoomList(userId, pageable);
-            return GlobalResponse.success(userByRoomList);
+
+            // 방 리스트가 비어 있으면 notFound 응답 반환
+            if (userByRoomList.isEmpty()) {
+                return GlobalResponse.error(ErrorCode.USER_CREATED_ROOM_NOT_FOUND);
+            }
+
+            return GlobalResponse.success("사용자가 생성한 방 조회 성공.",userByRoomList);
         } else {
-            throw new IllegalArgumentException("User not logged in.");
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
         }
     }
 
@@ -88,9 +101,15 @@ public GlobalResponse<Object> getByUserRoomPartList(Pageable pageable) {
             CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
             Long userId = principal.getId();  // getId()를 통해 userId를 추출
             List<ChatRoomDto> userByRoomPartList = chatRoomService.getUserByRoomPartList(userId, pageable);
-            return GlobalResponse.success(userByRoomPartList);
+
+            // 만약 방 리스트가 없다면 notFound 응답 반환
+            if (userByRoomPartList.isEmpty()) {
+                return GlobalResponse.error(ErrorCode.NONE_ROOM);
+            }
+
+            return GlobalResponse.success("사용자가 들어가 있는 방 리스트 조회 성공.",userByRoomPartList);
         } else {
-            throw new IllegalArgumentException("User not logged in.");
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
         }
     }
 
@@ -105,27 +124,27 @@ public GlobalResponse<Object> outRoom(
             CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
             Long userId = principal.getId();  // getId()를 통해 userId를 추출
             chatRoomService.outRoom(userId, roomId);
-            return GlobalResponse.success();
+            return GlobalResponse.success("채팅방을 나갔습니다.");
+        } else {
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
+        }
+    }
+
+    // 채팅방 삭제
+    @DeleteMapping("/room/delete/{roomId}")
+    @LoginCheck
+    public GlobalResponse<Object> deleteRoom(
+            @PathVariable Long roomId) {
+        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+
+        if (authentication instanceof OAuth2AuthenticationToken) {
+            CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
+            Long userId = principal.getId();  // getId()를 통해 userId를 추출
+            chatRoomService.deleteRoom(userId, roomId);
+            return GlobalResponse.success("채팅방을 삭제했습니다.");
         } else {
-            throw new IllegalArgumentException("User not logged in.");
+            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
         }
     }
-//
-//    // 채팅방 삭제
-//    @DeleteMapping("/room/delete/{roomId}")
-//    @LoginCheck
-//    public ResponseEntity<Object> deleteRoom(
-//            @PathVariable Long roomId) {
-//        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
-//
-//        if (authentication instanceof OAuth2AuthenticationToken) {
-//            CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
-//            Long userId = principal.getId();  // getId()를 통해 userId를 추출
-//            chatRoomService.deleteRoom(userId, roomId);
-//            return ResponseEntity.ok().body("success");
-//        } else {
-//            throw new IllegalArgumentException("User not logged in.");
-//        }
-//    }
 
 }

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

@@ -21,6 +21,6 @@ public interface ChatRoomService {
     List<ChatRoomDto> getUserByRoomPartList(Long userId, Pageable pageable);
 
     void outRoom(Long userId, Long roomId);
-//
-//    void deleteRoom(Long userId, Long roomId);
+
+    void deleteRoom(Long userId, Long roomId);
 }

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

@@ -74,12 +74,17 @@ public void joinRoom(Long roomId, Long userId) {
 
         // 현재 인원 수 조회
         Long currentUserCount = userChatRoomRepository.countByChatRoomId(roomId);
-
         // 채팅방이 꽉 찼을 경우 예외 처리
         if (currentUserCount >= chatRoom.getUserCountMax()) {
             throw new CustomException(ErrorCode.ROOM_USER_FULL);
         }
 
+        // 이미 참여한 방인지 확인
+        if (userChatRoomRepository.existsByChatRoomIdAndUserId(roomId, userId)) {
+            throw new CustomException(ErrorCode.ALREADY_JOIN_ROOM);
+        }
+
+
         // user_chatroom 관계 생성
         UserChatRoom userChatRoom = UserChatRoom.builder()
                 .user(findUser)
@@ -131,33 +136,36 @@ public List<ChatRoomDto> getUserByRoomPartList(Long userId, Pageable pageable) {
     }
 
     @Override
-    @Transactional(readOnly = true)
+    @Transactional
     public void outRoom(Long userId, Long roomId) {
         Long roomCreatorId = chatRoomRepository
                 .findChatRoomByRoomCreator(roomId);
         // 방장이 아니라면
         if (!Objects.equals(roomCreatorId, userId)) {
-            userChatRoomRepository.deleteUserChatRoomByUserId(userId);
+            userChatRoomRepository.deleteUserChatRoomByChatRoom_IdAndUserId(roomId, userId);
             return;
         }
         // 방장이라면 방 삭제
         userChatRoomRepository.deleteUserChatRoomByChatRoom_Id(roomId);
         chatRoomRepository.deleteById(roomId);
+        //    chatMsgRepository.deleteById(roomId); 방 삭제 시 채팅도 다 삭제(필요 시)
     }
 
-////    chatMsgRepository.deleteById(roomId); 방 삭제 시 채팅도 다 삭제 되어야 함.
-//    @Override
-//    @Transactional
-//    public void deleteRoom(Long userId, Long roomId) {
-//        Long roomCreatorId = chatRoomRepository
-//                .findChatRoomByRoomCreator(roomId);
-//        if (!Objects.equals(roomCreatorId, userId)) {
-//            throw new CustomException(ErrorCode.NOT_ROOM_CREATOR);
-//        }
-//        userChatRoomRepository.deleteUserChatRoomByChatRoom_Id(roomId);
-//        chatRoomRepository.deleteById(roomId);
-    // 채팅 메시지 구현 시, 방 삭제할 때 메시지도 같이 삭제되는 메서드 구현
-//}
+
+    @Override
+    @Transactional
+    public void deleteRoom(Long userId, Long roomId) {
+        Long roomCreatorId = chatRoomRepository
+                .findChatRoomByRoomCreator(roomId);
+        //방장이 아닐 경우, 삭제 불가
+        if (!Objects.equals(roomCreatorId, userId)) {
+            throw new CustomException(ErrorCode.NOT_ROOM_CREATOR);
+        }
+        //모든 사용자 제거 후 방 삭제
+        userChatRoomRepository.deleteUserChatRoomByChatRoom_Id(roomId);
+        chatRoomRepository.deleteById(roomId);
+//        chatMessageRepository.deleteId(roomId);
+}
 
 
 

src/main/java/cmf/commitField/domain/chat/userChatRoom/dto/UserChatRoomDto.java

@@ -0,0 +1,12 @@
+package cmf.commitField.domain.chat.userChatRoom.dto;
+
+import lombok.*;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class UserChatRoomDto {
+    private Long userId;
+}

src/main/java/cmf/commitField/domain/chat/userChatRoom/repository/UserChatRoomRepository.java

@@ -10,6 +10,8 @@
 import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Repository
 public interface UserChatRoomRepository extends JpaRepository<UserChatRoom, Long> {
 
@@ -18,11 +20,19 @@ public interface UserChatRoomRepository extends JpaRepository<UserChatRoom, Long
     Long countByChatRoomId(Long roomId); // 비관적 락
 
 //    @Query("select count(*) from UserChatRoom u where u.chatRoom.id = ?1 ")
-//    Long countNonLockByChatRoomId(Long roomId); // test 용도
     @Query("select count(*) from UserChatRoom u where u.chatRoom.id = :roomId")
     Long countNonLockByChatRoomId(@Param("roomId")Long roomId); // test 용도
-
+    // 특정 방의 모든 유저 관계 삭제
     void deleteUserChatRoomByChatRoom_Id(Long chatRoomId);
-
+    // 특정 방에서 특정 사용자만 삭제
+    void deleteUserChatRoomByChatRoom_IdAndUserId(Long chatRoomId, Long userId);
+    // 특정 방과 사용자 관계 삭제
     void deleteUserChatRoomByUserId(Long userId);
+    // 사용자가 해당 방에 참여한 여부 확인
+    boolean existsByChatRoomIdAndUserId(Long roomId, Long userId);
+    // 특정 방에 참여한 모든 UserChatRoom 관계 조회
+    List<UserChatRoom> findByChatRoom_Id(Long chatRoomId);
+
+
+
 }

src/main/java/cmf/commitField/domain/user/entity/User.java

@@ -11,6 +11,7 @@
 import lombok.Setter;
 import lombok.experimental.SuperBuilder;
 
+import java.util.ArrayList;
 import java.util.List;
 
 @Entity
@@ -32,13 +33,13 @@ public enum Role {
         USER, ADMIN
     }
     //추가
-    @OneToMany(mappedBy = "user", fetch = FetchType.LAZY)
-    private List<ChatRoom> chatRooms;
+    @OneToMany(mappedBy = "user", fetch = FetchType.LAZY, cascade = CascadeType.PERSIST)
+    private List<ChatRoom> chatRooms = new ArrayList<>();
 
-    @OneToMany(mappedBy = "user", fetch = FetchType.LAZY)
-    private List<UserChatRoom> userChatRooms;
+    @OneToMany(mappedBy = "user", fetch = FetchType.LAZY, cascade = CascadeType.PERSIST)
+    private List<UserChatRoom> userChatRooms = new ArrayList<>();
 
-    @OneToMany(mappedBy = "user", fetch = FetchType.LAZY)
-    private List<ChatMessage> chatMessages;
+    @OneToMany(mappedBy = "user", fetch = FetchType.LAZY, cascade = CascadeType.PERSIST)
+    private List<ChatMessage> chatMessages = new ArrayList<>();
 
 }

src/main/java/cmf/commitField/domain/user/service/CustomOAuth2UserService.java

@@ -8,6 +8,7 @@
 import org.springframework.security.oauth2.core.user.OAuth2User;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.Map;
 import java.util.Optional;
 
@@ -41,7 +42,7 @@ public OAuth2User loadUser(OAuth2UserRequest userRequest) {
             user.setAvatarUrl(avatarUrl);
             user.setEmail(email);  // GitHub에서 이메일이 변경될 수도 있으니 업데이트\
         } else {
-            user = new User(username, email, name, avatarUrl, User.Role.USER, null, null, null);
+            user = new User(username, email, name, avatarUrl, User.Role.USER, new ArrayList<>(), new ArrayList<>(), new ArrayList<>());
             userRepository.save(user);
         }
 

src/main/java/cmf/commitField/global/error/ErrorCode.java

@@ -23,6 +23,7 @@ public enum ErrorCode {
     PASSWORD_MISMATCH(HttpStatus.BAD_REQUEST, "비밀번호가 일치하지 않습니다."),
 
     // Auth
+    LOGIN_REQUIRED(HttpStatus.UNAUTHORIZED, "로그인이 필요합니다."),
     ACCESS_DENIED(HttpStatus.UNAUTHORIZED, "인증되지 않은 유저입니다."),
     SC_FORBIDDEN(HttpStatus.UNAUTHORIZED, "권한이 없는 유저입니다."),
     INVALID_JWT_SIGNATURE(HttpStatus.UNAUTHORIZED, "서명 검증에 실패했습니다." ),
@@ -36,9 +37,15 @@ public enum ErrorCode {
     //chatroom
     NOT_FOUND_ROOM(HttpStatus.NOT_FOUND, "이미 삭제된 방이거나 방을 찾을 수 없습니다."),
     ROOM_USER_FULL(HttpStatus.BAD_REQUEST, "방에 사용자가 다 차 있습니다."),
-    NONE_ROOM(HttpStatus.NOT_FOUND, "현재 방이 없습니다."),
     CHAT_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "채팅 전송에 오류가 있습니다."),
-    NOT_ROOM_CREATOR(HttpStatus.FORBIDDEN, "방 생성자가 아닙니다.");
+    NO_ROOM_FOUND(HttpStatus.NOT_FOUND, "채팅방이 없습니다."),
+
+    //user_chatroom
+    NONE_ROOM(HttpStatus.NOT_FOUND, "사용자가 들어가 있는 방이 없습니다."),
+    NOT_ROOM_CREATOR(HttpStatus.FORBIDDEN, "방 생성자가 아닙니다."),
+    USER_CREATED_ROOM_NOT_FOUND(HttpStatus.NOT_FOUND, "사용자가 생성한 방이 없습니다."),
+    ALREADY_JOIN_ROOM(HttpStatus.BAD_REQUEST, "사용자는 이미 해당 방에 참여하고 있습니다."),
+    NOT_EXIST_CLIENT(HttpStatus.NOT_FOUND, "채팅방에 사용자가 존재하지 않습니다.");
 
     private final HttpStatus httpStatus;
     private final String message;

src/main/java/cmf/commitField/global/globalDto/GlobalResponse.java

@@ -29,21 +29,39 @@ private GlobalResponse(ErrorCode errorCode, T data) {
         this.data = data;
     }
 
+    // 메시지와 데이터를 받는 생성자
+    private GlobalResponse(int statusCode, String message, T data) {
+        this.timestamp = LocalDateTime.now();
+        this.statusCode = statusCode;
+        this.message = message;
+        this.data = data;
+    }
+
+    // 성공 응답 (데이터 포함)
+    public static <T> GlobalResponse<T> success(String message, T data) {
+        return new GlobalResponse<>(GlobalResponseCode.OK.getCode(), message, data);
+    }
+
     // 성공 응답 (데이터 포함)
     public static <T> GlobalResponse<T> success(T data) {
         return new GlobalResponse<>(GlobalResponseCode.OK, data);
     }
 
     // 성공 응답 (데이터 없음)
-    public static <T> GlobalResponse<T> success() {
-        return success(null);
+    public static <T> GlobalResponse<T> success(String message) {
+        return success(message, null);
     }
 
     // 에러 응답 (데이터 포함)
     public static <T> GlobalResponse<T> error(ErrorCode errorCode, T data) {
         return new GlobalResponse<>(errorCode, data);
     }
 
+    // 성공 응답 (기본 메세지)
+    public static <T> GlobalResponse<T> success() {
+        return success(null);
+    }
+
     // 에러 응답 (데이터 없음)
     public static <T> GlobalResponse<T> error(ErrorCode errorCode) {
         return error(errorCode, null);