gronod/talk-android
1
0
Fork 1
mirror of https://github.com/nextcloud/talk-android synced 2025-03-06 22:29:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

temp message is added (values are still wrong)

Browse Source 
Signed-off-by: Marcel Hibbe <dev@mhibbe.de>
This commit is contained in:
Marcel Hibbe 2024-12-04 10:30:51 +01:00
parent 80d2e75b60
commit 048551e9fb
No known key found for this signature in database
GPG Key ID: C793F8B59F43CE7B
4 changed files with 23 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/main/java/com/nextcloud/talk/chat/data/ChatMessageRepository.kt
View File

@ -85,14 +85,14 @@ interface ChatMessageRepository : LifecycleAwareManager {
replyTo: Int,
sendWithoutNotification: Boolean,
referenceId: String
): Flow<Result<ChatOverallSingleMessage>>
): Flow<Result<ChatMessage?>>
suspend fun addTemporaryMessage(
message: CharSequence,
displayName: String,
replyTo: Int,
referenceId: String
): Flow<Result<ChatOverallSingleMessage>>
): Flow<Result<ChatMessage?>>
suspend fun editChatMessage(credentials: String, url: String, text: String): Flow<Result<ChatOverallSingleMessage>>
}

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

@ -762,7 +762,7 @@ class OfflineFirstChatRepository @Inject constructor(
replyTo: Int,
sendWithoutNotification: Boolean,
referenceId: String
): Flow<Result<ChatOverallSingleMessage>> =
): Flow<Result<ChatMessage?>> =
flow {
try {
val response = network.sendChatMessage(
@ -774,8 +774,12 @@ class OfflineFirstChatRepository @Inject constructor(
sendWithoutNotification,
referenceId
)
emit(Result.success(response))
val chatMessageModel = response.ocs?.data?.asModel()
emit(Result.success(chatMessageModel))
} catch (e: Exception) {
Log.e(TAG, "Error when sending message", e)
emit(Result.failure(e))
}
}
@ -803,7 +807,7 @@ class OfflineFirstChatRepository @Inject constructor(
displayName: String,
replyTo: Int,
referenceId: String
): Flow<Result<ChatOverallSingleMessage>> =
): Flow<Result<ChatMessage?>> =
flow {
try {
val tempChatMessageEntity = createChatMessageEntity(internalConversationId, message.toString())
@ -815,11 +819,13 @@ class OfflineFirstChatRepository @Inject constructor(
val tempChatMessageModel = tempChatMessageEntity.asModel()
// emit(Result.success(response))
emit(Result.success(tempChatMessageModel))
val triple = Triple(false, false, listOf(tempChatMessageModel))
val triple = Triple(true, false, listOf(tempChatMessageModel))
_messageFlow.emit(triple)
// emit()
} catch (e: Exception) {
Log.e(TAG, "Something went wrong when adding temporary message", e)
emit(Result.failure(e))
@ -855,11 +861,11 @@ class OfflineFirstChatRepository @Inject constructor(
parentMessageId = null,
systemMessageType = ChatMessage.SystemMessageType.DUMMY,
replyable = false,
timestamp = 0,
timestamp = System.currentTimeMillis(),
expirationTimestamp = 0,
actorDisplayName = "",
actorDisplayName = "test",
lastEditActorType = null,
lastEditTimestamp = null,
lastEditTimestamp = 0L,
renderMarkdown = true,
lastEditActorId = "",
lastEditActorDisplayName = ""

8
app/src/main/java/com/nextcloud/talk/chat/viewmodels/MessageInputViewModel.kt
View File

@ -158,9 +158,11 @@ class MessageInputViewModel @Inject constructor(
referenceId
).collect { result ->
if (result.isSuccess) {
Log.d(TAG, "bbbb")
Log.d(TAG, "temp message ref id: " + (result.getOrNull()?.referenceId ?: "none"))
_sendChatMessageViewState.value = SendChatMessageSuccessState(message)
} else {
Log.d(TAG, "xxxx")
_sendChatMessageViewState.value = SendChatMessageErrorState(message)
}
}
}
@ -188,7 +190,7 @@ class MessageInputViewModel @Inject constructor(
referenceId
).collect { result ->
if (result.isSuccess) {
Log.d(TAG, "received ref id: " + (result.getOrNull()?.ocs?.data?.referenceId ?: "none"))
Log.d(TAG, "received ref id: " + (result.getOrNull()?.referenceId ?: "none"))
_sendChatMessageViewState.value = SendChatMessageSuccessState(message)
} else {

2
app/src/main/java/com/nextcloud/talk/dagger/modules/RepositoryModule.kt
View File

@ -65,6 +65,7 @@ import com.nextcloud.talk.utils.preferences.AppPreferences
import dagger.Module
import dagger.Provides
import okhttp3.OkHttpClient
import javax.inject.Singleton
@Module
class RepositoryModule {
@ -151,6 +152,7 @@ class RepositoryModule {
@Provides
fun provideInvitationsRepository(ncApi: NcApi): InvitationsRepository = InvitationsRepositoryImpl(ncApi)
@Singleton
@Provides
fun provideOfflineFirstChatRepository(
chatMessagesDao: ChatMessagesDao,