eric/technologia-jetpack-compose
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

dm-padding message-3

Browse source
This commit is contained in:
eric 2026-07-07 17:43:47 +08:00
parent 1fa6293bbb
commit b9da88202e
1 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
app/src/main/java/com/example/login_v3/data/repository/dm/DM_Basic_Repository.kt
View file

@ -10,6 +10,7 @@ import android.util.Log
import com.example.login_v3.data.api.TecnologiaApi import com.example.login_v3.data.api.TecnologiaApi
import com.example.login_v3.data.api.api_class.ChatRoom import com.example.login_v3.data.api.api_class.ChatRoom
import com.example.login_v3.data.api.api_class.Message import com.example.login_v3.data.api.api_class.Message
import com.example.login_v3.data.api.api_class.MessageResponse
import com.example.login_v3.data.api.api_class.Reaction import com.example.login_v3.data.api.api_class.Reaction
import com.example.login_v3.data.api.api_class.RoomListResponse import com.example.login_v3.data.api.api_class.RoomListResponse
import com.example.login_v3.data.api.api_class.SendMessageRequest import com.example.login_v3.data.api.api_class.SendMessageRequest
@ -172,15 +173,18 @@ class ChatRoomsRepository @Inject constructor(
} }
} }
// api get data and put to local
suspend fun refreshChatMessages(roomId: String): Result<Unit> { //api get message and push to local
suspend fun refreshChatMessages(roomId: String, cursor: String? = null): Result<MessageResponse> {
return try { return try {
val response = api.getChatMessages(roomId) // 1. 把 cursor 傳給 API
val response = api.getChatMessages(roomId, cursor = cursor)
if (response.isSuccessful) { if (response.isSuccessful) {
val body = response.body() val body = response.body()
if (body != null) { if (body != null) {
// 1. 使用 map 把網路資料轉換成 Entity 列表 // 2. 轉換成 Entity 列表
val entities = body.messages.map { networkMessage -> val entities = body.messages.map { networkMessage ->
MessageEntity( MessageEntity(
id = networkMessage.id, id = networkMessage.id,
@ -197,10 +201,13 @@ class ChatRoomsRepository @Inject constructor(
) )
} }
// 2. 一口氣整批塞進資料庫，Room 只會開啟一次資料庫事務 (Transaction) // 3. 寫入資料庫
// 因為你寫了 OnConflictStrategy.REPLACE，歷史訊息會被乖乖追加進去，不會影響現有訊息！
messageDao.insertOrUpdateList(entities) messageDao.insertOrUpdateList(entities)
Result.success(Unit) // 🎯 4. 關鍵：把整個 body 回傳回去（包含 nextCursor 和 hasMore）
// 這樣 ViewModel 才能知道下一次往上滑時，要帶哪一個 cursor！
Result.success(body)
} else { } else {
Result.failure(Exception("Empty body")) Result.failure(Exception("Empty body"))
} }