GiftedHacker/tangem-app-android-audited
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Updated on 2026-08-14

Browse source
This commit is contained in:
Tangem 2026-07-10 16:39:11 +01:00
parent d0d268e59a
commit 0b43caf853
3 changed files with 20 additions and 30 deletions
Download patch file Download diff file Expand all files Collapse all files

2
features/address-book/impl/src/main/kotlin/com/tangem/features/addressbook/block/model/ContactsBlockModel.kt
View file

@ -37,7 +37,7 @@ internal class ContactsBlockModel @Inject constructor(
val state: StateFlow<ContactsBlockUM> get() = stateController.uiState
init {
modelScope.launch { syncAddressBooksUseCase() }
modelScope.launch(context = dispatchers.default) { syncAddressBooksUseCase() }
combine(
params.queryFlow.flatMapLatest { query ->

46
features/address-book/impl/src/main/kotlin/com/tangem/features/addressbook/list/model/AddressBookListModel.kt
View file

@ -48,8 +48,8 @@ internal class AddressBookListModel @Inject constructor(
private val contactSelectionTrigger: ContactSelectionTrigger,
private val analyticsSender: AddressBookAnalyticsSender,
private val syncAddressBooksUseCase: SyncAddressBooksUseCase,
getVerifiedContactsInteractor: GetVerifiedContactsInteractor,
getWalletsUseCase: GetWalletsUseCase,
private val getVerifiedContactsInteractor: GetVerifiedContactsInteractor,
private val getWalletsUseCase: GetWalletsUseCase,
) : Model() {
private val params = paramsContainer.require<DefaultAddressBookListComponent.Params>()
@ -63,22 +63,19 @@ internal class AddressBookListModel @Inject constructor(
private val searchActive = MutableStateFlow(value = false)
private val selectedWalletId = MutableStateFlow<String?>(value = null)
// We keep skeletons during stale state
private val isInitialSyncDone = MutableStateFlow(value = false)
private val allContacts: SharedFlow<List<VerifiedContact>> =
getVerifiedContactsInteractor.getVerifiedContacts(query = "", userWalletId = null)
.shareIn(modelScope, SharingStarted.Lazily, replay = 1)
init {
modelScope.launch {
try {
syncAddressBooksUseCase()
} finally {
isInitialSyncDone.value = true
}
modelScope.launch(context = dispatchers.default) {
syncAddressBooksUseCase()
sendContactListScreenOpenedEvent()
observeContacts()
}
}
private suspend fun observeContacts() {
val matchedContacts = searchQuery.flatMapLatest { query ->
if (query.isBlank()) {
allContacts
@ -86,7 +83,7 @@ internal class AddressBookListModel @Inject constructor(
getVerifiedContactsInteractor.getVerifiedContacts(query = query, userWalletId = null)
}
}
val listInputs = combine(
combine(
allContacts,
matchedContacts,
searchQuery,
@ -101,12 +98,9 @@ internal class AddressBookListModel @Inject constructor(
wallets = wallets,
)
}
combine(listInputs, isInitialSyncDone) { inputs, syncDone -> inputs to syncDone }
.onEach { (inputs, syncDone) -> if (syncDone) updateState(inputs) }
.onEach(::updateState)
.flowOn(dispatchers.default)
.launchIn(modelScope)
sendContactListScreenOpenedEvent()
.collect()
}
fun deliverSelection(contact: SelectedContact) {
@ -170,17 +164,13 @@ internal class AddressBookListModel @Inject constructor(
}
}
private fun sendContactListScreenOpenedEvent() {
allContacts
.take(count = 1)
.onEach { contacts ->
analyticsSender.sendContactListScreenOpened(
source = params.mode.toAnalyticsSource(),
contactsCount = contacts.size,
scope = modelScope,
)
}
.launchIn(modelScope)
private suspend fun sendContactListScreenOpenedEvent() {
val contacts = allContacts.first()
analyticsSender.sendContactListScreenOpened(
source = params.mode.toAnalyticsSource(),
contactsCount = contacts.size,
scope = modelScope,
)
}
private fun AddressBookRoute.ListMode.toAnalyticsSource(): Source = when (this) {

2
features/send/impl/src/main/java/com/tangem/features/send/subcomponents/destination/model/SendDestinationModel.kt
View file

@ -141,7 +141,7 @@ internal class SendDestinationModel @Inject constructor(
private val backupProblematicWalletCache = AtomicReference<Pair<String, UserWalletId?>?>(null)
init {
modelScope.launch { syncAddressBooksUseCase() }
modelScope.launch(context = dispatchers.default) { syncAddressBooksUseCase() }
subscribeOnQRScannerResult()
initialState()
resetContactOnEdit()