MERGE :: #12 attach latest message from ai on GET /room/list

Author: jombidev

src/main/kotlin/com/teamapi/palette/dto/room/RoomResponse.kt

@@ -2,5 +2,6 @@ package com.teamapi.palette.dto.room
 
 data class RoomResponse(
     val id: Long,
-    val title: String?
+    val title: String?,
+    val message: String?
 )

src/main/kotlin/com/teamapi/palette/repository/RoomRepository.kt

@@ -1,11 +1,47 @@
 package com.teamapi.palette.repository
 
+import com.teamapi.palette.dto.room.RoomResponse
 import com.teamapi.palette.entity.Room
-import kotlinx.coroutines.flow.Flow
+import org.jooq.DSLContext
+import org.jooq.impl.DSL
 import org.springframework.data.repository.kotlin.CoroutineCrudRepository
 import org.springframework.stereotype.Repository
+import com.teamapi.palette.entity.tables.TblChat.TBL_CHAT as CHAT
+import com.teamapi.palette.entity.tables.TblChat.TblChatPath.TBL_CHAT as CHAT_PATH
+import com.teamapi.palette.entity.tables.TblRoom.TBL_ROOM as ROOM
+import com.teamapi.palette.entity.tables.TblRoom.TblRoomPath.TBL_ROOM as ROOM_PATH
 
 @Repository
-interface RoomRepository : CoroutineCrudRepository<Room, Long> {
-    suspend fun findByUserId(userId: Long): Flow<Room>
+interface RoomRepository : CoroutineCrudRepository<Room, Long>, RoomQueryRepository
+
+interface RoomQueryRepository {
+    suspend fun findRoomByUserId(userId: Long): List<RoomResponse>
+}
+
+@Repository
+class RoomQueryRepositoryImpl(
+    private val ctx: DSLContext
+) : RoomQueryRepository {
+    override suspend fun findRoomByUserId(userId: Long): List<RoomResponse> {
+        val dsl = ctx.dsl()
+        return dsl
+            .select(
+                ROOM_PATH,
+                DSL.field(
+                    dsl
+                        .select(CHAT_PATH)
+                        .from(CHAT)
+                        .where(
+                            CHAT.ROOM_ID.eq(ROOM.ID)
+                                .and(CHAT.IS_AI.eq(true))
+                                .and(CHAT.RESOURCE.eq("CHAT"))
+                        )
+                        .orderBy(CHAT.ID.desc())
+                        .limit(1)
+                )
+            )
+            .from(ROOM)
+            .where(ROOM_PATH.USER_ID.eq(userId))
+            .awaitAll { RoomResponse(it.value1().id, it.value1().title, it.value2().message) }
+    }
 }

src/main/kotlin/com/teamapi/palette/service/RoomService.kt

@@ -6,8 +6,6 @@ import com.teamapi.palette.entity.Room
 import com.teamapi.palette.repository.RoomRepository
 import com.teamapi.palette.response.ErrorCode
 import com.teamapi.palette.response.exception.CustomException
-import kotlinx.coroutines.flow.map
-import kotlinx.coroutines.flow.toList
 import org.springframework.stereotype.Service
 
 @Service
@@ -17,13 +15,11 @@ class RoomService(
 ) {
     suspend fun createRoom(): RoomResponse {
         val room = roomRepository.save(Room(userId = sessionHolder.me()))
-        return RoomResponse(room.id!!, room.title ?: "")
+        return RoomResponse(room.id!!, room.title, null)
     }
 
     suspend fun getRoomList(): List<RoomResponse> {
-        return roomRepository.findByUserId(sessionHolder.me())
-            .map { RoomResponse(it.id!!, it.title ?: "") }
-            .toList()
+        return roomRepository.findRoomByUserId(sessionHolder.me())
     }
 
     suspend fun updateRoomTitle(updateRoomTitleRequest: UpdateRoomTitleRequest) {