Skip to content
Snippets Groups Projects
Commit 54323da4 authored by Kamal Bramwell's avatar Kamal Bramwell
Browse files

Implemented getContactRequests once for failedVerifiedRequests()

parent faf24a3f
Branches
Tags
3 merge requests!84Version 2.92 build 629,!77v2.9 b627,!74FE-957: Requests stuck verifying
...@@ -10,6 +10,8 @@ import io.xxlabs.messenger.requests.bindings.VerificationResult ...@@ -10,6 +10,8 @@ import io.xxlabs.messenger.requests.bindings.VerificationResult
import io.xxlabs.messenger.requests.data.LocalRequestsDataSource import io.xxlabs.messenger.requests.data.LocalRequestsDataSource
import io.xxlabs.messenger.requests.data.RequestDataSource import io.xxlabs.messenger.requests.data.RequestDataSource
import io.xxlabs.messenger.requests.model.ContactRequest import io.xxlabs.messenger.requests.model.ContactRequest
import io.xxlabs.messenger.support.appContext
import io.xxlabs.messenger.support.extensions.toast
import io.xxlabs.messenger.support.util.value import io.xxlabs.messenger.support.util.value
import kotlinx.coroutines.* import kotlinx.coroutines.*
import kotlinx.coroutines.flow.* import kotlinx.coroutines.flow.*
...@@ -121,8 +123,15 @@ class ContactRequestsRepository @Inject constructor( ...@@ -121,8 +123,15 @@ class ContactRequestsRepository @Inject constructor(
override fun failUnverifiedRequests() { override fun failUnverifiedRequests() {
scope.launch { scope.launch {
getRequests().take(1).collect { requests -> localDataSource.getContactRequestsOnce().let { requestDataList ->
requests.filter { requestDataList.mapNotNull { requestData ->
val contactData = daoRepository
.getContactByUserId(requestData.requestId)
.value()
contactData?.let {
ContactRequestData(it, requestData.unread)
}
}.filter {
it.requestStatus == VERIFYING it.requestStatus == VERIFYING
}.forEach { }.forEach {
update(it, VERIFICATION_FAIL) update(it, VERIFICATION_FAIL)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment