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-04-14 14:55:39 +01:00
parent 58909db262
commit 4bf6ea717b
1 changed files with 21 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

37
features/staking/impl/src/main/java/com/tangem/features/staking/impl/presentation/model/StakingModel.kt
View file

@ -307,10 +307,10 @@ internal class StakingModel @Inject constructor(
private val sendTransactionJobHolder = JobHolder()
private val stepChangesJobHolder = JobHolder()
private val balanceHidingJobHolder = JobHolder()
private val currencyStatusJobHolder = JobHolder()
init {
subscribeOnSelectedAppCurrency()
subscribeOnCurrencyStatusUpdates()
stateController.initializeWithUserWallet(userWallet)
}
@ -322,6 +322,7 @@ internal class StakingModel @Inject constructor(
sendTransactionJobHolder.cancel()
stepChangesJobHolder.cancel()
balanceHidingJobHolder.cancel()
currencyStatusJobHolder.cancel()
}
override fun onBackClick() {
@ -1243,21 +1244,24 @@ internal class StakingModel @Inject constructor(
isAnyTokenStaked = isAnyTokenStakedUseCase(userWalletId).getOrNull() == true
}
private fun subscribeOnCurrencyStatusUpdates() {
getAccountCurrencyStatusUseCase(
userWalletId = params.userWalletId,
currency = params.cryptoCurrency,
)
.conflate()
.distinctUntilChanged()
.filter { value.currentStep == StakingStep.InitialInfo || isTopHeatupCase() }
.onEach { (maybeAccount, maybeStatus) ->
isAccountsModeEnabled = isAccountsModeEnabledUseCase.invokeSync()
account = maybeAccount
onDataLoaded(maybeStatus)
}
.flowOn(dispatchers.main)
.launchIn(modelScope)
private fun subscribeOnCurrencyStatusUpdatesIfNeeded() {
if (currencyStatusJobHolder.isActive.not()) {
val job = getAccountCurrencyStatusUseCase(
userWalletId = params.userWalletId,
currency = params.cryptoCurrency,
)
.conflate()
.distinctUntilChanged()
.filter { value.currentStep == StakingStep.InitialInfo || isTopHeatupCase() }
.onEach { (maybeAccount, maybeStatus) ->
isAccountsModeEnabled = isAccountsModeEnabledUseCase.invokeSync()
account = maybeAccount
onDataLoaded(maybeStatus)
}
.flowOn(dispatchers.main)
.launchIn(modelScope)
currencyStatusJobHolder.update(job)
}
}
private suspend fun onDataLoaded(status: CryptoCurrencyStatus) {
@ -1318,6 +1322,7 @@ internal class StakingModel @Inject constructor(
.distinctUntilChanged()
.onEach { maybeAppCurrency ->
appCurrency = maybeAppCurrency.getOrElse { AppCurrency.Default }
subscribeOnCurrencyStatusUpdatesIfNeeded()
}
.flowOn(dispatchers.main)
.launchIn(modelScope)