feat: 번개 참가 나가기시 채팅방 자동 참가/나가기

Author: Coen90

src/main/java/com/codeit/side/chat/adapter/out/persistence/ChatMemberRepositoryImpl.java

@@ -46,4 +46,9 @@ public void join(Long id, Long userId) {
     public List<ChatMemberEntity> findAllMemberById(Long roomId) {
         return chatMemberJpaRepository.findAllByChatRoomId(roomId);
     }
+
+    @Override
+    public void leave(Long chatRoomId, Long userId) {
+        chatMemberJpaRepository.deleteByChatRoomIdAndUserId(chatRoomId, userId);
+    }
 }

src/main/java/com/codeit/side/chat/adapter/out/persistence/jpa/ChatMemberJpaRepository.java

@@ -10,4 +10,6 @@ public interface ChatMemberJpaRepository extends JpaRepository<ChatMemberEntity,
     List<ChatMemberEntity> findAllByChatRoomId(Long chatRoomId);
 
     Optional<ChatMemberEntity> findByChatRoomIdAndUserId(Long chatRoomId, Long userId);
+
+    void deleteByChatRoomIdAndUserId(Long chatRoomId, Long userId);
 }

src/main/java/com/codeit/side/chat/application/port/in/ChatMessageUseCase.java

@@ -25,4 +25,8 @@ public interface ChatMessageUseCase {
     List<ChatRoom> findAllChatRoomsByLighteningIds(List<Long> lighteningIds);
 
     void read(Long roomId, Long userId);
+
+    void leaveChatRoom(Long id, String email);
+
+    void joinChatRoomByLighteningId(Long id, String email);
 }

src/main/java/com/codeit/side/chat/application/port/out/ChatMemberRepository.java

@@ -16,4 +16,6 @@ public interface ChatMemberRepository {
     void join(Long id, Long userId);
 
     List<ChatMemberEntity> findAllMemberById(Long roomId);
+
+    void leave(Long chatRoomId, Long userId);
 }

src/main/java/com/codeit/side/chat/application/service/ChatMessageService.java

@@ -108,10 +108,16 @@ public void joinChatRoom(Long id, String email) {
         User user = userQueryRepository.getByEmail(email)
                 .toDomain();
         ChatRoom chatRoom = chatRoomRepository.getBy(id);
-        if (chatMemberRepository.existsByChatRoomIdAndUserId(chatRoom.getId(), user.getId())) {
-            throw new IllegalRequestException("이미 채팅방에 참여하고 있는 사용자입니다.");
-        }
-        chatMemberRepository.join(id, user.getId());
+        chatMemberRepository.join(chatRoom.getId(), user.getId());
+    }
+
+    @Override
+    @Transactional
+    public void joinChatRoomByLighteningId(Long id, String email) {
+        User user = userQueryRepository.getByEmail(email)
+                .toDomain();
+        ChatRoom chatRoom = chatRoomRepository.getByLighteningId(id);
+        chatMemberRepository.join(chatRoom.getId(), user.getId());
     }
 
     @Override
@@ -130,6 +136,15 @@ public void read(Long roomId, Long userId) {
         chatMessageReadRepository.read(roomId, userId);
     }
 
+    @Override
+    @Transactional
+    public void leaveChatRoom(Long id, String email) {
+        User user = userQueryRepository.getByEmail(email)
+                .toDomain();
+        ChatRoom chatRoom = chatRoomRepository.getByLighteningId(id);
+        chatMemberRepository.leave(chatRoom.getId(), user.getId());
+    }
+
     private List<ChatRoomInfo> createChatRoomInfos(List<ChatRoom> chatRooms, Map<Long, ChatMessage> allLastMessageByIds, Map<Long, Integer> idToMemberSize) {
         return chatRooms.stream()
                 .map(chatRoom -> createChatRoomInfo(chatRoom, allLastMessageByIds.get(chatRoom.getId()), idToMemberSize.get(chatRoom.getId())))

src/main/java/com/codeit/side/lightening/application/service/LighteningService.java

@@ -56,6 +56,7 @@ public void join(String email, Long id) {
         Lightening lightening = lighteningReadRepository.getById(id);
         validateLightening(email, lightening);
         lighteningCommandRepository.join(email, lightening.getId());
+        chatMessageUseCase.joinChatRoomByLighteningId(id, email);
     }
 
     @Override
@@ -66,6 +67,7 @@ public void leave(String email, Long id) {
             throw new UserNotJoinedException(lightening.getId());
         }
         lighteningCommandRepository.leave(email, lightening.getId());
+        chatMessageUseCase.leaveChatRoom(id, email);
     }
 
     @Override