[FEAT] 채팅 기능 구현 및 개선

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/event/ChatRoomLeaveEvent.java

@@ -0,0 +1,10 @@
+package mannabom_server.manabom.application.chat.dto.event;
+
+import mannabom_server.manabom.domain.chat.enums.ChatRoomType;
+
+public record ChatRoomLeaveEvent(
+        Long userId,
+        ChatRoomType roomType,
+        Long referenceId
+) {
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/request/ChatMessageRequest.java

@@ -0,0 +1,10 @@
+package mannabom_server.manabom.application.chat.dto.request;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class ChatMessageRequest {
+    private Long lastReadMessageId;
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/request/ChatSendRequest.java

@@ -1,15 +1,15 @@
 package mannabom_server.manabom.application.chat.dto.request;
 
+import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 import mannabom_server.manabom.domain.chat.enums.ChatMessageType;
-import mannabom_server.manabom.domain.chat.enums.ChatRoomType;
 
 @Getter
+@AllArgsConstructor
 public class ChatSendRequest {
     private Long roomId;
-    private ChatRoomType chatRoomType;
     private ChatMessageType messageType;
     private String content;
-    private String clientMeesageId;
+    private String clientMessageId;
 }

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatHistoryResponse.java

@@ -0,0 +1,16 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.util.List;
+
+@Getter
+@Builder
+@AllArgsConstructor
+public class ChatHistoryResponse {
+    private Long roomId;
+    private List<ChatMessageResponse> messages;
+    private boolean hasNext;
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatInitialSyncResponse.java

@@ -0,0 +1,11 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public class ChatInitialSyncResponse {
+    private int unreadMessageCount;
+    private boolean hasNewRoom;
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatMemberInfo.java

@@ -0,0 +1,25 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.Builder;
+import lombok.Getter;
+import mannabom_server.manabom.domain.user.entity.Profile;
+import mannabom_server.manabom.domain.user.enums.Gender;
+
+@Getter
+@Builder
+public class ChatMemberInfo {
+    private Long userId;
+    private String nickname;
+    private String profileImageUrl;
+    private Gender gender;
+
+    public static ChatMemberInfo of(Profile profile, String displayImageUrl){
+        return ChatMemberInfo.builder()
+                .userId(profile.getUser().getUserId())
+                .nickname(profile.getNickName())
+                .profileImageUrl(displayImageUrl)
+                .gender(profile.getGender())
+                .build();
+    }
+
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatMessageEvent.java

@@ -10,11 +10,11 @@
 @Builder
 public class ChatMessageEvent {
     private Long roomId;
-    private String roomType;
 
     private Long senderUserId;
     private String messageType;
     private String content;
+    private int unreadCount;
 
     private Long messageId;
     private String clientMessageId;

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatMessageResponse.java

@@ -0,0 +1,30 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.Builder;
+import lombok.Getter;
+import mannabom_server.manabom.domain.chat.entity.ChatMessage;
+
+import java.time.Instant;
+
+@Getter
+@Builder
+public class ChatMessageResponse {
+    private Long messageId;
+    private String content;
+    private String messageType;
+    private Instant createdAt;
+
+    private Long senderId;
+    private int unreadCount;
+
+    public static ChatMessageResponse of(ChatMessage msg, int unreadCount){
+        return ChatMessageResponse.builder()
+                .messageId(msg.getId())
+                .createdAt(msg.getCreatedAt())
+                .messageType(msg.getType().name())
+                .unreadCount(unreadCount)
+                .senderId(msg.getUser().getUserId())
+                .content(msg.getContent())
+                .build();
+    }
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatReadEvent.java

@@ -0,0 +1,12 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.Builder;
+import lombok.Getter;
+
+@Builder
+@Getter
+public class ChatReadEvent {
+    private Long roomId;
+    private Long userId;
+    private Long lastReadMessageId;
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatRoomListResponse.java

@@ -0,0 +1,29 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.Builder;
+import lombok.Getter;
+import mannabom_server.manabom.domain.chat.entity.ChatMessage;
+import mannabom_server.manabom.domain.chat.entity.ChatRoom;
+import mannabom_server.manabom.domain.chat.enums.ChatRoomType;
+
+import java.time.Instant;
+
+@Builder
+@Getter
+public class ChatRoomListResponse {
+     private Long roomId;
+     private String roomName;
+     private String lastMessage;
+     private Instant lastmessageAt;
+     private int unreadCount;
+
+    public static ChatRoomListResponse of(ChatRoom room,String roomName, ChatMessage lastMsg, int unreadCount){
+        return ChatRoomListResponse.builder()
+                .roomId(room.getId())
+                .roomName(roomName)
+                .lastMessage(lastMsg!=null ? lastMsg.getType().getDisplayMessage(lastMsg.getContent()): null )
+                .unreadCount(unreadCount)
+                .build();
+    }
+
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatSyncResponse.java

@@ -0,0 +1,15 @@
+package mannabom_server.manabom.application.chat.dto.response;
+
+import lombok.Builder;
+import lombok.Getter;
+
+import java.util.List;
+
+@Builder
+@Getter
+public class ChatSyncResponse {
+    private Long roomId;
+    private List<ChatMemberInfo> members;
+    private List<ChatMessageResponse> messages;
+    private boolean hasGap;
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/handler/MeetingChatEventHandler.java

@@ -0,0 +1,27 @@
+package mannabom_server.manabom.application.chat.handler;
+
+import lombok.RequiredArgsConstructor;
+import mannabom_server.manabom.application.chat.dto.event.ChatRoomLeaveEvent;
+import mannabom_server.manabom.application.meeting.service.MeetingMatchingService;
+import mannabom_server.manabom.application.meeting.service.MeetingService;
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class MeetingChatEventHandler {
+    private final MeetingService meetingService;
+    private final MeetingMatchingService meetingMatchingService;
+
+    @EventListener
+    public void handleChatRoomLeave(ChatRoomLeaveEvent event){
+        switch (event.roomType()){
+            case MEETING_GROUP -> {
+                meetingService.handleMemberLeave(event.referenceId(), event.userId());
+            }
+            case MEETING_MATCH -> {
+                meetingMatchingService.handleMatchMemberLeave(event.referenceId(), event.userId());
+            }
+        }
+    }
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/service/ChatMemberService.java

@@ -0,0 +1,54 @@
+package mannabom_server.manabom.application.chat.service;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import mannabom_server.manabom.application.chat.dto.response.ChatReadEvent;
+import mannabom_server.manabom.domain.chat.entity.ChatMember;
+import mannabom_server.manabom.domain.chat.entity.ChatMessage;
+import mannabom_server.manabom.domain.chat.enums.ChatMemberStatus;
+import mannabom_server.manabom.domain.chat.repository.ChatMemberRepository;
+import mannabom_server.manabom.domain.chat.repository.ChatMessageRepository;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@Slf4j
+@RequiredArgsConstructor
+public class ChatMemberService {
+    private static final String UNREAD_PREFIX = "unread:count:";
+    private final ChatMemberRepository chatMemberRepository;
+    private final ChatMessageRepository chatMessageRepository;
+    private final SimpMessagingTemplate messagingTemplate;
+    private final StringRedisTemplate stringRedisTemplate;
+
+    public void updateReadStatus(Long roomId, Long userId,Long lastSeenMessageId) {
+        ChatMember chatMember = chatMemberRepository.findByRoomIdAndUser_UserIdAndStatus(roomId, userId, ChatMemberStatus.ACTIVATE)
+                .orElseThrow(() -> new IllegalArgumentException("해당 채팅방 멤버가 아닙니다."));
+
+        long lastReadId = chatMember.getLastReadMessageId() == null ? 0L : chatMember.getLastReadMessageId();
+
+        if (lastSeenMessageId <= lastReadId) return;
+
+        List<ChatMessage> unreadMessages = chatMessageRepository.findByRoomIdAndIdBetween(roomId, lastReadId + 1, lastSeenMessageId);
+        for (ChatMessage m : unreadMessages) {
+            String key = UNREAD_PREFIX + m.getId();
+            Long count = stringRedisTemplate.opsForValue().decrement(key);
+            if (count != null && count < 0) {
+                stringRedisTemplate.opsForValue().set(key, "0");
+            }
+        }
+
+
+        ChatReadEvent readEvent = ChatReadEvent.builder()
+                .roomId(roomId)
+                .userId(userId)
+                .lastReadMessageId(lastSeenMessageId)
+                .build();
+        messagingTemplate.convertAndSend("/topic/rooms/" + roomId + "/read", readEvent);
+
+
+    }
+}