[Feat]: 채팅방 메세지를 조회할 수 있다

domain/src/main/kotlin/gloddy/groupChat/dto/command/GroupChatGetMessageCommand.kt

@@ -0,0 +1,10 @@
+package gloddy.groupChat.dto.command
+
+import gloddy.util.CursorRequest
+import java.util.*
+
+data class GroupChatGetMessageCommand(
+        val userId: Long,
+        val chatId: UUID,
+        val cursorRequest: CursorRequest
+)

domain/src/main/kotlin/gloddy/groupChat/service/GroupChatGetMessageCommander.kt

@@ -0,0 +1,28 @@
+package gloddy.groupChat.service
+
+import gloddy.groupChat.GroupChatMessage
+import gloddy.groupChat.dto.command.GroupChatGetMessageCommand
+import gloddy.port.`in`.GetGroupChatMessageUseCase
+import gloddy.port.out.GetGroupChatMessagePort
+import gloddy.util.CursorRequest
+import gloddy.util.PageCursor
+
+class GroupChatGetMessageCommander(private val getGroupChatMessagePort: GetGroupChatMessagePort) : GetGroupChatMessageUseCase {
+
+    override fun getPosts(command: GroupChatGetMessageCommand): PageCursor<GroupChatMessage> {
+        var posts = findAllBy(command)
+        var nextKey = posts.stream()
+                .mapToLong(GroupChatMessage::sequenceId)
+                .min()
+                .orElse(CursorRequest.NONE_KEY)
+        return PageCursor(command.cursorRequest.next(nextKey), posts.size, posts)
+    }
+
+    private fun findAllBy(command: GroupChatGetMessageCommand): List<GroupChatMessage> {
+        return if (command.cursorRequest.hasKey()) {
+            getGroupChatMessagePort.findWithKey(command)
+        } else {
+            getGroupChatMessagePort.findWithoutKey(command)
+        }
+    }
+}

domain/src/main/kotlin/gloddy/port/in/GetGroupChatMessageUseCase.kt

@@ -0,0 +1,10 @@
+package gloddy.port.`in`
+
+import gloddy.groupChat.GroupChatMessage
+import gloddy.groupChat.dto.command.GroupChatGetMessageCommand
+import gloddy.util.PageCursor
+
+interface GetGroupChatMessageUseCase {
+
+    fun getPosts(groupChatGetMessageCommand: GroupChatGetMessageCommand): PageCursor<GroupChatMessage>
+}

domain/src/main/kotlin/gloddy/port/out/GetGroupChatMessagePort.kt

@@ -0,0 +1,10 @@
+package gloddy.port.out
+
+import gloddy.groupChat.GroupChatMessage
+import gloddy.groupChat.dto.command.GroupChatGetMessageCommand
+
+interface GetGroupChatMessagePort {
+    fun findWithoutKey(groupChatGetMessageCommand: GroupChatGetMessageCommand): List<GroupChatMessage>
+
+    fun findWithKey(groupChatGetMessageCommand: GroupChatGetMessageCommand): List<GroupChatMessage>
+}

domain/src/main/kotlin/gloddy/util/CursorRequest.kt

@@ -0,0 +1,18 @@
+package gloddy.util
+
+
+data class CursorRequest(
+        val key: Long?
+) {
+    companion object {
+        const val NONE_KEY: Long = -1L
+    }
+
+    fun hasKey(): Boolean {
+        return key != null
+    }
+
+    fun next(key: Long?): CursorRequest {
+        return CursorRequest(key)
+    }
+}

domain/src/main/kotlin/gloddy/util/PageCursor.kt

@@ -0,0 +1,7 @@
+package gloddy.util
+
+data class PageCursor<T>(
+        val nextCursorRequest: CursorRequest,
+        val size: Int,
+        val body: List<T>
+)

storage/src/main/kotlin/gloddy/adapter/GroupChatMessageCommandAdapter.kt

@@ -0,0 +1,28 @@
+package gloddy.adapter
+
+import gloddy.groupChat.GroupChatMessage
+import gloddy.groupChat.dto.command.GroupChatGetMessageCommand
+import gloddy.persistence.repository.GroupChatMessageRepository
+import gloddy.port.out.GetGroupChatMessagePort
+
+class GroupChatMessageCommandAdapter(
+        private val repository: GroupChatMessageRepository)
+    : GetGroupChatMessagePort {
+
+    override fun findWithoutKey(command: GroupChatGetMessageCommand): List<GroupChatMessage> {
+        return repository.findAllByMemberIdAndOrderByIdDesc(
+                command.userId,
+                command.chatId
+        )
+    }
+
+    override fun findWithKey(command: GroupChatGetMessageCommand): List<GroupChatMessage> {
+        return repository.findAllByLessThanIdMemberIdAndOrderByIdDesc(
+                command.cursorRequest.key,
+                command.userId,
+                command.chatId
+        )
+    }
+
+
+}

storage/src/main/kotlin/gloddy/persistence/repository/GroupChatMessageRepository.kt

@@ -0,0 +1,58 @@
+package gloddy.persistence.repository
+
+import gloddy.groupChat.GroupChatMessage
+import gloddy.groupChat.vo.MessageType
+import org.springframework.jdbc.core.RowMapper
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate
+import java.time.LocalDateTime
+import java.util.*
+
+class GroupChatMessageRepository(private val namedParameterJdbcTemplate: NamedParameterJdbcTemplate) {
+
+    companion object {
+        private const val TABLE = "GroupChatMessage"
+        private val ROW_MAPPER: RowMapper<GroupChatMessage> = RowMapper { rs, rowNum ->
+            GroupChatMessage(
+                    userId = rs.getLong("userId"),
+                    chatId = rs.getObject("chatId", UUID::class.java),
+                    messageType = MessageType.valueOf(rs.getString("messageType")),
+                    content = rs.getString("content"),
+                    createdAt = rs.getObject("createdAt", LocalDateTime::class.java) ?: LocalDateTime.now(),
+                    deleted = rs.getBoolean("deleted"),
+                    deletedAt = rs.getObject("deletedAt", LocalDateTime::class.java),
+                    id = rs.getObject("id", UUID::class.java),
+                    sequenceId = rs.getLong("sequenceId"))
+        }
+    }
+
+    fun findAllByMemberIdAndOrderByIdDesc(userId: Long, chatId: UUID): List<GroupChatMessage> {
+        val sql = """
+        SELECT *
+        FROM $TABLE as message
+        INNER JOIN GroupChatUser AS user
+            ON user.chatId = message.chatId
+        WHERE chatId = :chatId and user.createdAt < message.createdAt
+        ORDER BY sequenceId desc
+    """.trimIndent()
+        val params = MapSqlParameterSource()
+                .addValue("chatId", chatId)
+
+        return namedParameterJdbcTemplate.query(sql, params, ROW_MAPPER)
+    }
+
+    fun findAllByLessThanIdMemberIdAndOrderByIdDesc(sequenceId: Long?, userId: Long, chatId: UUID): List<GroupChatMessage> {
+        val sql = """
+        SELECT *
+        FROM $TABLE
+        WHERE chatId = :chatId and sequenceId < :sequenceId
+        ORDER BY sequenceId desc
+    """.trimIndent()
+        val params = MapSqlParameterSource()
+                .addValue("sequenceId", sequenceId)
+                .addValue("chatId", chatId)
+
+        return namedParameterJdbcTemplate.query(sql, params, ROW_MAPPER)
+    }
+
+}