From a2504e3c4b837fd64f7863b28da8dca11a2421b6 Mon Sep 17 00:00:00 2001 From: Tangem Date: Fri, 7 Feb 2025 19:25:20 +0400 Subject: [PATCH] Updated on 2026-08-14 --- .../tangem/data/staking/DefaultStakingRepository.kt | 12 +++++++++++- .../domain/staking/repositories/StakingRepository.kt | 5 +++++ .../operations/CurrenciesStatusesLceOperations.kt | 2 +- .../operations/CurrenciesStatusesOperations.kt | 4 ++-- .../tokens/repository/MockStakingRepository.kt | 7 +++++++ 5 files changed, 26 insertions(+), 4 deletions(-) diff --git a/data/staking/src/main/java/com/tangem/data/staking/DefaultStakingRepository.kt b/data/staking/src/main/java/com/tangem/data/staking/DefaultStakingRepository.kt index 74c4a84423..90f71a6274 100644 --- a/data/staking/src/main/java/com/tangem/data/staking/DefaultStakingRepository.kt +++ b/data/staking/src/main/java/com/tangem/data/staking/DefaultStakingRepository.kt @@ -35,7 +35,10 @@ import com.tangem.datasource.local.token.StakingYieldsStore import com.tangem.domain.staking.model.StakingApproval import com.tangem.domain.staking.model.StakingAvailability import com.tangem.domain.staking.model.StakingEntryInfo -import com.tangem.domain.staking.model.stakekit.* +import com.tangem.domain.staking.model.stakekit.NetworkType +import com.tangem.domain.staking.model.stakekit.Yield +import com.tangem.domain.staking.model.stakekit.YieldBalance +import com.tangem.domain.staking.model.stakekit.YieldBalanceList import com.tangem.domain.staking.model.stakekit.action.StakingAction import com.tangem.domain.staking.model.stakekit.action.StakingActionCommonType import com.tangem.domain.staking.model.stakekit.action.StakingActionStatus @@ -480,6 +483,13 @@ internal class DefaultStakingRepository( override fun getMultiYieldBalanceUpdates( userWalletId: UserWalletId, cryptoCurrencies: List, + ): Flow { + TODO("Will be implemented in [REDACTED_TASK_KEY]") + } + + override fun getMultiYieldBalanceUpdatesLegacy( + userWalletId: UserWalletId, + cryptoCurrencies: List, ): Flow = channelFlow { stakingBalanceStore.get(userWalletId) .onEach { diff --git a/domain/staking/src/main/java/com/tangem/domain/staking/repositories/StakingRepository.kt b/domain/staking/src/main/java/com/tangem/domain/staking/repositories/StakingRepository.kt index cc53ade06f..35d7f0c0d9 100644 --- a/domain/staking/src/main/java/com/tangem/domain/staking/repositories/StakingRepository.kt +++ b/domain/staking/src/main/java/com/tangem/domain/staking/repositories/StakingRepository.kt @@ -63,6 +63,11 @@ interface StakingRepository { cryptoCurrencies: List, ): Flow + fun getMultiYieldBalanceUpdatesLegacy( + userWalletId: UserWalletId, + cryptoCurrencies: List, + ): Flow + suspend fun getMultiYieldBalanceSync( userWalletId: UserWalletId, cryptoCurrencies: List, diff --git a/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesLceOperations.kt b/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesLceOperations.kt index d2e77a480c..6ac673ec1a 100644 --- a/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesLceOperations.kt +++ b/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesLceOperations.kt @@ -189,7 +189,7 @@ internal class CurrenciesStatusesLceOperations( userWalletId: UserWalletId, cryptoCurrencies: List, ): EitherFlow { - return stakingRepository.getMultiYieldBalanceUpdates(userWalletId, cryptoCurrencies) + return stakingRepository.getMultiYieldBalanceUpdatesLegacy(userWalletId, cryptoCurrencies) .map> { it.right() } .catch { emit(TokenListError.DataError(it).left()) } .distinctUntilChanged() diff --git a/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesOperations.kt b/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesOperations.kt index 1035011308..eb0e4023b1 100644 --- a/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesOperations.kt +++ b/domain/tokens/src/main/kotlin/com/tangem/domain/tokens/operations/CurrenciesStatusesOperations.kt @@ -349,7 +349,7 @@ internal class CurrenciesStatusesOperations( private fun getQuotes(tokensIds: NonEmptySet): Flow>> { val rawIds = tokensIds.mapNotNull { it.rawCurrencyId }.toSet() - return quotesRepository.getQuotesUpdates(rawIds) + return quotesRepository.getQuotesUpdatesLegacy(rawIds) .map, Either>> { quotes -> if (quotes.isEmpty()) Error.EmptyQuotes.left() else quotes.right() } @@ -360,7 +360,7 @@ internal class CurrenciesStatusesOperations( } private fun getNetworksStatuses(networks: NonEmptySet): Flow>> { - return networksRepository.getNetworkStatusesUpdates(userWalletId, networks) + return networksRepository.getNetworkStatusesUpdatesLegacy(userWalletId, networks) .map, Either>> { it.right() } .catch { emit(Error.DataError(it).left()) } .onEmpty { emit(Error.EmptyNetworksStatuses.left()) } diff --git a/domain/tokens/src/test/kotlin/com/tangem/domain/tokens/repository/MockStakingRepository.kt b/domain/tokens/src/test/kotlin/com/tangem/domain/tokens/repository/MockStakingRepository.kt index b66b4ccaf9..d88dda9050 100644 --- a/domain/tokens/src/test/kotlin/com/tangem/domain/tokens/repository/MockStakingRepository.kt +++ b/domain/tokens/src/test/kotlin/com/tangem/domain/tokens/repository/MockStakingRepository.kt @@ -157,6 +157,13 @@ class MockStakingRepository : StakingRepository { override fun getMultiYieldBalanceUpdates( userWalletId: UserWalletId, cryptoCurrencies: List, + ): Flow { + return flowOf(YieldBalanceList.Data(listOf(YieldBalance.Error))) + } + + override fun getMultiYieldBalanceUpdatesLegacy( + userWalletId: UserWalletId, + cryptoCurrencies: List, ): Flow = flowOf() override suspend fun getMultiYieldBalanceSync(