gronod/talk-android
1
0
Fork 1
mirror of https://github.com/nextcloud/talk-android synced 2025-07-14 08:15:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #4867 from nextcloud/bugfix/4866/avoidNpeInSendChatMessage

Browse Source 
Avoid Npe in sendChatMessage
This commit is contained in:
Marcel Hibbe 2025-04-14 14:22:04 +00:00 committed by GitHub
commit 29348689a8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
app/src/main/java/com/nextcloud/talk/chat/data/network/OfflineFirstChatRepository.kt
View File

@ -42,6 +42,7 @@ import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.catch
import kotlinx.coroutines.flow.first
import kotlinx.coroutines.flow.firstOrNull
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.flow.map
import kotlinx.coroutines.isActive
@ -847,13 +848,17 @@ class OfflineFirstChatRepository @Inject constructor(
.catch { e ->
Log.e(TAG, "Error when sending message", e)
val failedMessage = chatDao.getTempMessageForConversation(internalConversationId, referenceId).first()
failedMessage.sendingFailed = true
chatDao.updateChatMessage(failedMessage)
val failedMessageModel = failedMessage.asModel()
_updateMessageFlow.emit(failedMessageModel)
val failedMessage = chatDao.getTempMessageForConversation(
internalConversationId,
referenceId
).firstOrNull()
failedMessage?.let {
it.sendingFailed = true
chatDao.updateChatMessage(it)
val failedMessageModel = it.asModel()
_updateMessageFlow.emit(failedMessageModel)
}
emit(Result.failure(e))
}
}