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