@@ -11,11 +11,14 @@ import kotlinx.coroutines.delay
11
11
import kotlinx.coroutines.flow.MutableStateFlow
12
12
import kotlinx.coroutines.flow.StateFlow
13
13
import kotlinx.coroutines.flow.asStateFlow
14
+ import kotlinx.coroutines.flow.filter
14
15
import kotlinx.coroutines.flow.first
16
+ import kotlinx.coroutines.flow.map
15
17
import kotlinx.coroutines.flow.update
16
18
import kotlinx.coroutines.launch
17
19
import kotlinx.coroutines.withContext
18
20
import network.loki.messenger.R
21
+ import network.loki.messenger.libsession_util.ConfigBase.Companion.PRIORITY_HIDDEN
19
22
import nl.komponents.kovenant.Promise
20
23
import org.session.libsession.LocalisedTimeUtil.toShortSinglePartString
21
24
import org.session.libsession.snode.OnionRequestAPI
@@ -37,6 +40,7 @@ import org.thoughtcrime.securesms.util.NumberUtil.formatAbbreviated
37
40
import org.thoughtcrime.securesms.util.NumberUtil.formatWithDecimalPlaces
38
41
import javax.inject.Inject
39
42
import kotlin.math.min
43
+ import kotlin.sequences.filter
40
44
import kotlin.time.Duration.Companion.milliseconds
41
45
import kotlin.time.Duration.Companion.minutes
42
46
@@ -255,7 +259,11 @@ class TokenPageViewModel @Inject constructor(
255
259
var numGroupV2Convos = 0
256
260
257
261
// Grab the database and reader details we need to count the conversations / groups
258
- val convoList = conversationRepository.observeConversationList().first()
262
+ val convoList = conversationRepository.observeConversationList()
263
+ .map{ convo ->
264
+ convo.filter { it.recipient.approved }
265
+ }
266
+ .first()
259
267
val result = mutableSetOf<Recipient >()
260
268
261
269
// Look through the database to build up our conversation & group counts (still on Dispatchers.IO not the main thread)
0 commit comments