mirror of
https://github.com/nextcloud/talk-android
synced 2025-06-23 13:40:43 +01:00
simplify to refresh message
Signed-off-by: Marcel Hibbe <dev@mhibbe.de>
This commit is contained in:
parent
cca4e69cea
commit
7d9c2fdd30
@ -841,10 +841,7 @@ class OfflineFirstChatRepository @Inject constructor(
|
|||||||
chatDao.updateChatMessage(failedMessage)
|
chatDao.updateChatMessage(failedMessage)
|
||||||
|
|
||||||
val failedMessageModel = failedMessage.asModel()
|
val failedMessageModel = failedMessage.asModel()
|
||||||
_removeMessageFlow.emit(failedMessageModel)
|
_updateMessageFlow.emit(failedMessageModel)
|
||||||
|
|
||||||
val tripleChatMessages = Triple(true, false, listOf(failedMessageModel))
|
|
||||||
_messageFlow.emit(tripleChatMessages)
|
|
||||||
|
|
||||||
emit(Result.failure(e))
|
emit(Result.failure(e))
|
||||||
}
|
}
|
||||||
@ -864,10 +861,7 @@ class OfflineFirstChatRepository @Inject constructor(
|
|||||||
chatDao.updateChatMessage(messageToResend)
|
chatDao.updateChatMessage(messageToResend)
|
||||||
|
|
||||||
val messageToResendModel = messageToResend.asModel()
|
val messageToResendModel = messageToResend.asModel()
|
||||||
_removeMessageFlow.emit(messageToResendModel)
|
_updateMessageFlow.emit(messageToResendModel)
|
||||||
|
|
||||||
val tripleChatMessages = Triple(true, false, listOf(messageToResendModel))
|
|
||||||
_messageFlow.emit(tripleChatMessages)
|
|
||||||
|
|
||||||
return sendChatMessage(
|
return sendChatMessage(
|
||||||
credentials,
|
credentials,
|
||||||
@ -911,12 +905,7 @@ class OfflineFirstChatRepository @Inject constructor(
|
|||||||
chatDao.upsertChatMessage(messageToEdit)
|
chatDao.upsertChatMessage(messageToEdit)
|
||||||
|
|
||||||
val editedMessageModel = messageToEdit.asModel()
|
val editedMessageModel = messageToEdit.asModel()
|
||||||
_removeMessageFlow.emit(editedMessageModel)
|
_updateMessageFlow.emit(editedMessageModel)
|
||||||
|
|
||||||
val tripleChatMessages = Triple(true, false, listOf(editedMessageModel))
|
|
||||||
_messageFlow.emit(tripleChatMessages)
|
|
||||||
|
|
||||||
|
|
||||||
emit(true)
|
emit(true)
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
emit(false)
|
emit(false)
|
||||||
|
Loading…
Reference in New Issue
Block a user