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 2025-04-23 14:31:44 +05:00
parent c300a5eaf3
commit d99c4e1405
15 changed files with 316 additions and 56 deletions
Download patch file Download diff file Expand all files Collapse all files

83
data/nft/src/main/kotlin/com/tangem/data/nft/DefaultNFTRepository.kt
View file

@ -64,38 +64,11 @@ internal class DefaultNFTRepository @Inject constructor(
flowOf(NFTCollections.empty(network))
}
override suspend fun refreshCollections(userWalletId: UserWalletId, networks: List<Network>) = coroutineScope {
networks.mapNotNull { network ->
if (network.canHandleNFTs()) {
launch(dispatchers.io) {
Either.catch {
expireCollections(userWalletId, network)
override suspend fun refreshCollections(userWalletId: UserWalletId, networks: List<Network>) =
refreshCollectionsInternal(userWalletId, networks, refreshAssets = false)
val collections = walletManagersFacade.getNFTCollections(userWalletId, network)
val mergedCollections = collections.mergeWithStoredAssets(userWalletId, network)
saveCollectionsInRuntime(
userWalletId = userWalletId,
network = network,
collections = mergedCollections,
)
saveCollectionsInPersistence(
userWalletId = userWalletId,
network = network,
collections = mergedCollections,
)
}.onLeft {
saveFailedStateInRuntime(
userWalletId = userWalletId,
network = network,
error = it,
)
}
}.saveIn(getNetworkJobHolder(network))
} else {
null
}
}.joinAll()
override suspend fun refreshAll(userWalletId: UserWalletId, networks: List<Network>) {
refreshCollectionsInternal(userWalletId, networks, refreshAssets = true)
}
override suspend fun refreshAssets(
@ -162,6 +135,54 @@ internal class DefaultNFTRepository @Inject constructor(
assetIdentifier = NFTSdkAssetIdentifierConverter.convertBack(assetIdentifier),
)
private suspend fun refreshCollectionsInternal(
userWalletId: UserWalletId,
networks: List<Network>,
refreshAssets: Boolean,
) = coroutineScope {
networks.mapNotNull { network ->
if (network.canHandleNFTs()) {
launch(dispatchers.io) {
Either.catch {
expireCollections(userWalletId, network)
val collections = walletManagersFacade.getNFTCollections(userWalletId, network)
val mergedCollections = collections.mergeWithStoredAssets(userWalletId, network)
saveCollectionsInRuntime(
userWalletId = userWalletId,
network = network,
collections = mergedCollections,
)
saveCollectionsInPersistence(
userWalletId = userWalletId,
network = network,
collections = mergedCollections,
)
if (refreshAssets) {
mergedCollections.forEach { collection ->
refreshAssets(
userWalletId = userWalletId,
network = network,
collectionId = NFTSdkCollectionIdentifierConverter.convert(collection.identifier),
)
}
}
}.onLeft {
saveFailedStateInRuntime(
userWalletId = userWalletId,
network = network,
error = it,
)
}
}.saveIn(getNetworkJobHolder(network))
} else {
null
}
}.joinAll()
}
private suspend fun refreshSalePrice(
userWalletId: UserWalletId,
network: Network,