From e8ac5389e7c60228e51de2730e3dbbfa029332d6 Mon Sep 17 00:00:00 2001 From: rapterjet2004 Date: Thu, 6 Mar 2025 15:18:34 -0600 Subject: [PATCH] refactoring Signed-off-by: rapterjet2004 --- .../conversationlist/ConversationsListActivity.kt | 2 +- .../viewmodels/ConversationsListViewModel.kt | 15 ++------------- 2 files changed, 3 insertions(+), 14 deletions(-) diff --git a/app/src/main/java/com/nextcloud/talk/conversationlist/ConversationsListActivity.kt b/app/src/main/java/com/nextcloud/talk/conversationlist/ConversationsListActivity.kt index b6cd59d3a..b0a9a4663 100644 --- a/app/src/main/java/com/nextcloud/talk/conversationlist/ConversationsListActivity.kt +++ b/app/src/main/java/com/nextcloud/talk/conversationlist/ConversationsListActivity.kt @@ -515,7 +515,7 @@ class ConversationsListActivity : private fun setConversationList(list: List) { // Refreshes conversation messages in the background asynchronously - conversationsListViewModel.updateRoomMessages(credentials!!, list) + conversationsListViewModel.updateRoomMessages(list) // Update Conversations conversationItems.clear() diff --git a/app/src/main/java/com/nextcloud/talk/conversationlist/viewmodels/ConversationsListViewModel.kt b/app/src/main/java/com/nextcloud/talk/conversationlist/viewmodels/ConversationsListViewModel.kt index ed6c2860e..78ebdeaaf 100644 --- a/app/src/main/java/com/nextcloud/talk/conversationlist/viewmodels/ConversationsListViewModel.kt +++ b/app/src/main/java/com/nextcloud/talk/conversationlist/viewmodels/ConversationsListViewModel.kt @@ -17,7 +17,6 @@ import com.nextcloud.talk.invitation.data.InvitationsModel import com.nextcloud.talk.invitation.data.InvitationsRepository import com.nextcloud.talk.models.domain.ConversationModel import com.nextcloud.talk.users.UserManager -import com.nextcloud.talk.utils.ApiUtils import com.nextcloud.talk.utils.database.user.CurrentUserProviderNew import io.reactivex.Observer import io.reactivex.android.schedulers.AndroidSchedulers @@ -95,30 +94,20 @@ class ConversationsListViewModel @Inject constructor( repository.getRooms() } - fun updateRoomMessages( - credentials: String, - list: List - ) { + fun updateRoomMessages(list: List) { val current = list.associateWith { model -> val unreadMessages = model.unreadMessages unreadMessages } - val baseUrl = userManager.currentUser.blockingGet().baseUrl!! viewModelScope.launch(Dispatchers.IO) { for ((model, unreadMessages) in current) { if (unreadMessages > 0) { - updateRoomMessage(model, unreadMessages, credentials, baseUrl) + chatRepository.updateRoomMessages(model.internalId, unreadMessages) } } } } - private suspend fun updateRoomMessage(model: ConversationModel, limit: Int, credentials: String, baseUrl: String) { - val urlForChatting = ApiUtils.getUrlForChat(1, baseUrl, model.token) // FIXME v1? - chatRepository.setData(model, credentials, urlForChatting) - chatRepository.updateRoomMessages(model.internalId, limit) - } - inner class FederatedInvitationsObserver : Observer { override fun onSubscribe(d: Disposable) { // unused atm