feat: 채팅 기능 구현

src/main/java/com/example/solidconnection/chat/controller/ChatController.java

@@ -0,0 +1,52 @@
+package com.example.solidconnection.chat.controller;
+
+import com.example.solidconnection.chat.dto.ChatMessageResponse;
+import com.example.solidconnection.chat.dto.ChatRoomListResponse;
+import com.example.solidconnection.chat.service.ChatService;
+import com.example.solidconnection.common.dto.SliceResponse;
+import com.example.solidconnection.common.resolver.AuthorizedUser;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.web.PageableDefault;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/chats")
+public class ChatController {
+
+    private final ChatService chatService;
+
+    @GetMapping("/rooms")
+    public ResponseEntity<ChatRoomListResponse> getChatRooms(
+            @AuthorizedUser long siteUserId
+    ) {
+        ChatRoomListResponse chatRoomListResponse = chatService.getChatRooms(siteUserId);
+        return ResponseEntity.ok(chatRoomListResponse);
+    }
+
+    @GetMapping("/rooms/{room-id}")
+    public ResponseEntity<SliceResponse<ChatMessageResponse>> getChatMessages(
+            @AuthorizedUser long siteUserId,
+            @PathVariable("room-id") Long roomId,
+            @PageableDefault(size = 20, sort = "createdAt", direction = Sort.Direction.DESC) Pageable pageable
+    ) {
+        SliceResponse<ChatMessageResponse> response = chatService.getChatMessages(siteUserId, roomId, pageable);
+        return ResponseEntity.ok(response);
+    }
+
+    @PutMapping("/rooms/{room-id}/read")
+    public ResponseEntity<Void> markChatMessagesAsRead(
+            @AuthorizedUser long siteUserId,
+            @PathVariable("room-id") Long roomId
+    ) {
+        chatService.markChatMessagesAsRead(siteUserId, roomId);
+        return ResponseEntity.ok().build();
+    }
+}

src/main/java/com/example/solidconnection/chat/domain/ChatAttachment.java

@@ -32,4 +32,14 @@ public class ChatAttachment extends BaseEntity {
 
     @ManyToOne(fetch = FetchType.LAZY)
     private ChatMessage chatMessage;
+
+    public ChatAttachment(boolean isImage, String url, String thumbnailUrl, ChatMessage chatMessage) {
+        this.isImage = isImage;
+        this.url = url;
+        this.thumbnailUrl = thumbnailUrl;
+        this.chatMessage = chatMessage;
+        if (chatMessage != null) {
+            chatMessage.getChatAttachments().add(this);
+        }
+    }
 }

src/main/java/com/example/solidconnection/chat/domain/ChatMessage.java

@@ -34,5 +34,14 @@ public class ChatMessage extends BaseEntity {
     private ChatRoom chatRoom;
 
     @OneToMany(mappedBy = "chatMessage", cascade = CascadeType.ALL)
-    private List<ChatAttachment> chatAttachments = new ArrayList<>();
+    private final List<ChatAttachment> chatAttachments = new ArrayList<>();
+
+    public ChatMessage(String content, long senderId, ChatRoom chatRoom) {
+        this.content = content;
+        this.senderId = senderId;
+        this.chatRoom = chatRoom;
+        if (chatRoom != null) {
+            chatRoom.getChatMessages().add(this);
+        }
+    }
 }

src/main/java/com/example/solidconnection/chat/domain/ChatParticipant.java

@@ -34,4 +34,12 @@ public class ChatParticipant extends BaseEntity {
 
     @ManyToOne(fetch = FetchType.LAZY)
     private ChatRoom chatRoom;
+
+    public ChatParticipant(long siteUserId, ChatRoom chatRoom) {
+        this.siteUserId = siteUserId;
+        this.chatRoom = chatRoom;
+        if (chatRoom != null) {
+            chatRoom.getChatParticipants().add(this);
+        }
+    }
 }

src/main/java/com/example/solidconnection/chat/domain/ChatReadStatus.java

@@ -32,4 +32,9 @@ public class ChatReadStatus extends BaseEntity {
 
     @Column(name = "chat_participant_id")
     private long chatParticipantId;
+
+    public ChatReadStatus(long chatRoomId, long chatParticipantId) {
+        this.chatRoomId = chatRoomId;
+        this.chatParticipantId = chatParticipantId;
+    }
 }

src/main/java/com/example/solidconnection/chat/domain/ChatRoom.java

@@ -12,6 +12,7 @@
 import lombok.AccessLevel;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
+import org.hibernate.annotations.BatchSize;
 
 @Entity
 @Getter
@@ -25,8 +26,13 @@ public class ChatRoom extends BaseEntity {
     private boolean isGroup = false;
 
     @OneToMany(mappedBy = "chatRoom", cascade = CascadeType.ALL)
-    private List<ChatParticipant> chatParticipants = new ArrayList<>();
+    @BatchSize(size = 10)
+    private final List<ChatParticipant> chatParticipants = new ArrayList<>();
 
     @OneToMany(mappedBy = "chatRoom", cascade = CascadeType.ALL)
-    private List<ChatMessage> chatMessages = new ArrayList<>();
+    private final List<ChatMessage> chatMessages = new ArrayList<>();
+
+    public ChatRoom(boolean isGroup) {
+        this.isGroup = isGroup;
+    }
 }

src/main/java/com/example/solidconnection/chat/dto/ChatAttachmentResponse.java

@@ -0,0 +1,17 @@
+package com.example.solidconnection.chat.dto;
+
+import java.time.ZonedDateTime;
+
+public record ChatAttachmentResponse(
+        long id,
+        boolean isImage,
+        String url,
+        String thumbnailUrl,
+        ZonedDateTime createdAt
+) {
+
+    public static ChatAttachmentResponse of(long id, boolean isImage, String url,
+                                            String thumbnailUrl, ZonedDateTime createdAt) {
+        return new ChatAttachmentResponse(id, isImage, url, thumbnailUrl, createdAt);
+    }
+}

src/main/java/com/example/solidconnection/chat/dto/ChatMessageResponse.java

@@ -0,0 +1,18 @@
+package com.example.solidconnection.chat.dto;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+
+public record ChatMessageResponse(
+        long id,
+        String content,
+        long senderId,
+        ZonedDateTime createdAt,
+        List<ChatAttachmentResponse> attachments
+) {
+
+    public static ChatMessageResponse of(long id, String content, long senderId,
+                                         ZonedDateTime createdAt, List<ChatAttachmentResponse> attachments) {
+        return new ChatMessageResponse(id, content, senderId, createdAt, attachments);
+    }
+}

src/main/java/com/example/solidconnection/chat/dto/ChatParticipantResponse.java

@@ -0,0 +1,12 @@
+package com.example.solidconnection.chat.dto;
+
+public record ChatParticipantResponse(
+        long partnerId,
+        String nickname,
+        String profileUrl
+) {
+
+    public static ChatParticipantResponse of(long partnerId, String nickname, String profileUrl) {
+        return new ChatParticipantResponse(partnerId, nickname, profileUrl);
+    }
+}

src/main/java/com/example/solidconnection/chat/dto/ChatRoomListResponse.java

@@ -0,0 +1,12 @@
+package com.example.solidconnection.chat.dto;
+
+import java.util.List;
+
+public record ChatRoomListResponse(
+        List<ChatRoomResponse> chatRooms
+) {
+
+    public static ChatRoomListResponse of(List<ChatRoomResponse> chatRooms) {
+        return new ChatRoomListResponse(chatRooms);
+    }
+}

src/main/java/com/example/solidconnection/chat/dto/ChatRoomResponse.java

@@ -0,0 +1,22 @@
+package com.example.solidconnection.chat.dto;
+
+import java.time.ZonedDateTime;
+
+public record ChatRoomResponse(
+        long id,
+        String lastChatMessage,
+        ZonedDateTime lastReceivedTime,
+        ChatParticipantResponse partner,
+        long unReadCount
+) {
+
+    public static ChatRoomResponse of(
+            long id,
+            String lastChatMessage,
+            ZonedDateTime lastReceivedTime,
+            ChatParticipantResponse partner,
+            long unReadCount
+    ) {
+        return new ChatRoomResponse(id, lastChatMessage, lastReceivedTime, partner, unReadCount);
+    }
+}

src/main/java/com/example/solidconnection/chat/repository/ChatAttachmentRepository.java

@@ -0,0 +1,8 @@
+package com.example.solidconnection.chat.repository;
+
+import com.example.solidconnection.chat.domain.ChatAttachment;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ChatAttachmentRepository extends JpaRepository<ChatAttachment, Long> {
+
+}

src/main/java/com/example/solidconnection/chat/repository/ChatMessageRepository.java

@@ -0,0 +1,22 @@
+package com.example.solidconnection.chat.repository;
+
+import com.example.solidconnection.chat.domain.ChatMessage;
+import java.util.Optional;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Slice;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+public interface ChatMessageRepository extends JpaRepository<ChatMessage, Long> {
+
+    @Query("""
+           SELECT cm FROM ChatMessage cm
+           LEFT JOIN FETCH cm.chatAttachments
+           WHERE cm.chatRoom.id = :roomId
+           ORDER BY cm.createdAt DESC
+           """)
+    Slice<ChatMessage> findByRoomIdWithPaging(@Param("roomId") long roomId, Pageable pageable);
+
+    Optional<ChatMessage> findFirstByChatRoomIdOrderByCreatedAtDesc(long chatRoomId);
+}

src/main/java/com/example/solidconnection/chat/repository/ChatParticipantRepository.java

@@ -0,0 +1,12 @@
+package com.example.solidconnection.chat.repository;
+
+import com.example.solidconnection.chat.domain.ChatParticipant;
+import java.util.Optional;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ChatParticipantRepository extends JpaRepository<ChatParticipant, Long> {
+
+    boolean existsByChatRoomIdAndSiteUserId(long chatRoomId, long siteUserId);
+
+    Optional<ChatParticipant> findByChatRoomIdAndSiteUserId(long chatRoomId, long siteUserId);
+}

src/main/java/com/example/solidconnection/chat/repository/ChatReadStatusRepository.java

@@ -0,0 +1,18 @@
+package com.example.solidconnection.chat.repository;
+
+import com.example.solidconnection.chat.domain.ChatReadStatus;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+public interface ChatReadStatusRepository extends JpaRepository<ChatReadStatus, Long> {
+
+    @Modifying(clearAutomatically = true, flushAutomatically = true)
+    @Query(value = """
+                   INSERT INTO chat_read_status (chat_room_id, chat_participant_id, created_at, updated_at)
+                   VALUES (:chatRoomId, :chatParticipantId, NOW(6), NOW(6))
+                   ON DUPLICATE KEY UPDATE updated_at = NOW(6)
+                   """, nativeQuery = true)
+    void upsertReadStatus(@Param("chatRoomId") long chatRoomId, @Param("chatParticipantId") long chatParticipantId);
+}

src/main/java/com/example/solidconnection/chat/repository/ChatRoomRepository.java

@@ -0,0 +1,36 @@
+package com.example.solidconnection.chat.repository;
+
+import com.example.solidconnection.chat.domain.ChatRoom;
+import java.util.List;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+public interface ChatRoomRepository extends JpaRepository<ChatRoom, Long> {
+
+    @Query("""
+           SELECT cr FROM ChatRoom cr
+           JOIN cr.chatParticipants cp
+           WHERE cp.siteUserId = :userId AND cr.isGroup = false
+           ORDER BY (
+               SELECT MAX(cm.createdAt)
+               FROM ChatMessage cm
+               WHERE cm.chatRoom = cr
+           ) DESC NULLS LAST
+           """)
+    List<ChatRoom> findOneOnOneChatRoomsByUserId(@Param("userId") long userId);
+
+    @Query("""
+           SELECT COUNT(cm) FROM ChatMessage cm
+           LEFT JOIN ChatReadStatus crs ON crs.chatRoomId = cm.chatRoom.id 
+               AND crs.chatParticipantId = (
+                   SELECT cp.id FROM ChatParticipant cp 
+                   WHERE cp.chatRoom.id = :chatRoomId 
+                   AND cp.siteUserId = :userId
+               )
+           WHERE cm.chatRoom.id = :chatRoomId
+           AND cm.senderId != :userId
+           AND (crs.updatedAt IS NULL OR cm.createdAt > crs.updatedAt)
+           """)
+    long countUnreadMessages(@Param("chatRoomId") long chatRoomId, @Param("userId") long userId);
+}