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-03-03 10:39:48 +04:00
parent 665d56c9e8
commit 7d461390e0
19 changed files with 387 additions and 623 deletions
Download patch file Download diff file Expand all files Collapse all files

47
domain/nft/src/main/kotlin/com/tangem/domain/nft/GetNFTCollectionsUseCase.kt
View file

@ -1,6 +1,5 @@
package com.tangem.domain.nft
import com.tangem.domain.account.featuretoggle.AccountsFeatureToggles
import com.tangem.domain.account.supplier.SingleAccountListSupplier
import com.tangem.domain.models.account.Account
import com.tangem.domain.models.currency.CryptoCurrency
@ -8,52 +7,42 @@ import com.tangem.domain.models.wallet.UserWalletId
import com.tangem.domain.nft.models.NFTCollections
import com.tangem.domain.nft.models.WalletNFTCollections
import com.tangem.domain.nft.repository.NFTRepository
import com.tangem.domain.tokens.repository.CurrenciesRepository
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.*
class GetNFTCollectionsUseCase(
private val currenciesRepository: CurrenciesRepository,
private val nftRepository: NFTRepository,
private val singleAccountListSupplier: SingleAccountListSupplier,
private val accountsFeatureToggles: AccountsFeatureToggles,
) {
@Deprecated("Use invokeForAccounts instead")
@OptIn(ExperimentalCoroutinesApi::class)
operator fun invoke(userWalletId: UserWalletId): Flow<List<NFTCollections>> =
if (accountsFeatureToggles.isFeatureEnabled) {
invokeForAccounts(userWalletId).map { it.flattenCollections }
} else {
currenciesRepository
.getWalletCurrenciesUpdates(userWalletId)
.flatMapLatest {
nftCollections(userWalletId, it)
}
}
@OptIn(ExperimentalCoroutinesApi::class)
fun invokeForAccounts(userWalletId: UserWalletId): Flow<WalletNFTCollections> {
fun Account.flowOfNFTCollections(): Flow<Pair<Account, List<NFTCollections>>>? {
val currencies = (this as? Account.CryptoPortfolio)?.cryptoCurrencies.orEmpty()
if (currencies.isEmpty()) return null
return nftCollections(userWalletId = userWalletId, cryptoCurrencies = currencies.toList())
.map { nfts -> this to nfts }
}
operator fun invoke(userWalletId: UserWalletId): Flow<WalletNFTCollections> {
return singleAccountListSupplier(userWalletId)
.mapLatest { statusList -> statusList.accounts.mapNotNull { it.flowOfNFTCollections() } }
.flatMapLatest { flows -> combine(flows) { WalletNFTCollections(it.toMap()) } }
.mapLatest { statusList -> statusList.accounts.mapNotNull(::flowOfNFTCollections) }
.flatMapLatest { flows ->
combine(flows) { WalletNFTCollections(it.toMap()) }
}
}
private fun nftCollections(
private fun flowOfNFTCollections(account: Account): Flow<Pair<Account, List<NFTCollections>>>? {
val currencies = (account as? Account.CryptoPortfolio)?.cryptoCurrencies.orEmpty()
if (currencies.isEmpty()) return null
return getNftCollections(userWalletId = account.userWalletId, cryptoCurrencies = currencies.toList())
.map { nfts -> account to nfts }
}
private fun getNftCollections(
userWalletId: UserWalletId,
cryptoCurrencies: List<CryptoCurrency>,
): Flow<List<NFTCollections>> {
val networks = cryptoCurrencies
.map { cryptoCurrency -> cryptoCurrency.network }
.map(CryptoCurrency::network)
.distinct()
if (networks.isEmpty()) return flowOf(emptyList())
return nftRepository.observeCollections(userWalletId, networks)
}
}