Merge pull request #338 from tangem/bugfix/AND-4848_Redesign_Request_…

…for_the_balance_is_sent_at_every_pull-to-refresh_in_the_Token_Details AND-4848 Redesign: Request for the balance is sent at every pull-to-refresh in the Token Details
tangem · Oct 11, 2023 · 026a7d3 · 026a7d3
2 parents e911b32 + 229987b
commit 026a7d3
Show file tree

Hide file tree

Showing 18 changed files with 55 additions and 17 deletions.
diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/binance/BinanceWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/binance/BinanceWalletManager.kt
@@ -21,7 +21,7 @@ class BinanceWalletManager(
     override val currentHost: String
         get() = networkProvider.host
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         val result = networkProvider.getInfo(wallet.address)
         when (result) {
             is Result.Success -> updateWallet(result.data)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/bitcoin/BitcoinWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/bitcoin/BitcoinWalletManager.kt
@@ -45,7 +45,7 @@ open class BitcoinWalletManager(
     override val currentHost: String
         get() = networkProvider.baseUrl
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         coroutineScope {
             val addressInfos = mutableListOf<BitcoinAddressInfo>()
             val responsesDeferred =

diff --git a/...n/src/main/java/com/tangem/blockchain/blockchains/bitcoincash/BitcoinCashWalletManager.kt b/...n/src/main/java/com/tangem/blockchain/blockchains/bitcoincash/BitcoinCashWalletManager.kt
@@ -15,7 +15,7 @@ class BitcoinCashWalletManager(
 
     override val minimalFee = 0.00001.toBigDecimal()
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val response = networkProvider.getInfo(wallet.address)) {
             is Result.Success -> updateWallet(response.data)
             is Result.Failure -> updateError(response.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/cardano/CardanoWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/cardano/CardanoWalletManager.kt
@@ -33,7 +33,7 @@ class CardanoWalletManager(
     override val currentHost: String
         get() = networkProvider.baseUrl
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val response = networkProvider.getInfo(wallet.addresses.map { it.value }.toSet())) {
             is Result.Success -> updateWallet(response.data)
             is Result.Failure -> updateError(response.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/chia/ChiaWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/chia/ChiaWalletManager.kt
@@ -32,7 +32,7 @@ class ChiaWalletManager(
     private val blockchain = wallet.blockchain
     private val puzzleHash = ChiaAddressService.getPuzzleHash(wallet.address).toHexString()
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val response = networkProvider.getUnspents(puzzleHash)) {
             is Result.Success -> updateWallet(response.data)
             is Result.Failure -> updateError(response.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/cosmos/CosmosWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/cosmos/CosmosWalletManager.kt
@@ -40,7 +40,7 @@ class CosmosWalletManager(
         get() = networkService.host
 
     override val allowsFeeSelection: FeeSelectionState = cosmosChain.allowsFeeSelection
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         val unconfirmedTxHashes = wallet.recentTransactions
             .filter { it.status == TransactionStatus.Unconfirmed }
             .mapNotNull { it.hash }

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/ethereum/EthereumWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/ethereum/EthereumWalletManager.kt
@@ -43,7 +43,7 @@ open class EthereumWalletManager(
     override val currentHost: String
         get() = networkProvider.baseUrl
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val result = networkProvider.getInfo(wallet.address, cardTokens)) {
             is Result.Success -> updateWallet(result.data)
             is Result.Failure -> updateError(result.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/kaspa/KaspaWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/kaspa/KaspaWalletManager.kt
@@ -32,7 +32,7 @@ class KaspaWalletManager(
     private val blockchain = wallet.blockchain
     override val dustValue: BigDecimal = FEE_PER_UNSPENT_OUTPUT.toBigDecimal()
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val response = networkProvider.getInfo(wallet.address)) {
             is Result.Success -> updateWallet(response.data)
             is Result.Failure -> updateError(response.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/near/NearWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/near/NearWalletManager.kt
@@ -23,7 +23,7 @@ class NearWalletManager(
     override val currentHost: String
         get() = networkService.host
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val walletInfoResult = networkService.getAccount(wallet.address)) {
             is Result.Success -> {
                 when (val account = walletInfoResult.data) {

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/polkadot/PolkadotWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/polkadot/PolkadotWalletManager.kt
@@ -50,7 +50,7 @@ class PolkadotWalletManager(
     override val currentHost: String
         get() = networkProvider.baseUrl
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         val amount = networkProvider.getBalance(wallet.address).successOr {
             wallet.removeAllTokens()
             throw (it.error as BlockchainSdkError)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/solana/SolanaWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/solana/SolanaWalletManager.kt
@@ -55,7 +55,7 @@ class SolanaWalletManager(
     private val feeRentHolder = mutableMapOf<Fee, BigDecimal>()
     private val valueConverter = ValueConverter()
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         val accountInfo = multiNetworkProvider.performRequest {
             getMainAccountInfo(accountPubK)
         }.successOr {

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/stellar/StellarWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/stellar/StellarWalletManager.kt
@@ -25,7 +25,7 @@ class StellarWalletManager(
     private var baseReserve = BASE_RESERVE
     private var sequence = 0L
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val result = networkProvider.getInfo(wallet.address)) {
             is Result.Failure -> updateError(result.error)
             is Result.Success -> updateWallet(result.data)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/tezos/TezosWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/tezos/TezosWalletManager.kt
@@ -44,7 +44,7 @@ class TezosWalletManager(
     private val blockchain = wallet.blockchain
     private var publicKeyRevealed: Boolean? = null
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val response = networkProvider.getInfo(wallet.address)) {
             is Result.Success -> updateWallet(response.data)
             is Result.Failure -> updateError(response.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/ton/TonWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/ton/TonWalletManager.kt
@@ -37,7 +37,7 @@ class TonWalletManager(
     override val currentHost: String
         get() = networkService.host
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val walletInfoResult = networkService.getWalletInformation(wallet.address)) {
             is Result.Failure -> updateError(walletInfoResult.error)
             is Result.Success -> updateWallet(walletInfoResult.data)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/tron/TronWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/tron/TronWalletManager.kt
@@ -39,7 +39,7 @@ class TronWalletManager(
 
     private val dummySigner = DummySigner()
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         val transactionIds = wallet.recentTransactions
             .filter { it.status == TransactionStatus.Unconfirmed }
             .mapNotNull { it.hash }

diff --git a/blockchain/src/main/java/com/tangem/blockchain/blockchains/xrp/XrpWalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/blockchains/xrp/XrpWalletManager.kt
@@ -30,7 +30,7 @@ class XrpWalletManager(
 
     private val blockchain = wallet.blockchain
 
-    override suspend fun update() {
+    override suspend fun updateInternal() {
         when (val result = networkProvider.getInfo(wallet.address)) {
             is Result.Success -> updateWallet(result.data)
             is Result.Failure -> updateError(result.error)

diff --git a/blockchain/src/main/java/com/tangem/blockchain/common/WalletManager.kt b/blockchain/src/main/java/com/tangem/blockchain/common/WalletManager.kt
@@ -1,5 +1,6 @@
 package com.tangem.blockchain.common
 
+import com.tangem.blockchain.extensions.DebouncedInvoke
 import com.tangem.blockchain.common.transaction.Fee
 import com.tangem.blockchain.common.transaction.TransactionFee
 import com.tangem.blockchain.common.txhistory.DefaultTransactionHistoryProvider
@@ -28,7 +29,18 @@ abstract class WalletManager(
 
     open val dustValue: BigDecimal? = null
 
-    abstract suspend fun update()
+    private val updateDebounced = DebouncedInvoke()
+
+    /**
+     * Update wallet state. [forceUpdate] to skip debounce
+     */
+    suspend fun update(forceUpdate: Boolean = false) {
+        updateDebounced.invokeOnExpire(forceUpdate) {
+            updateInternal()
+        }
+    }
+
+    internal abstract suspend fun updateInternal()
 
     protected open fun updateRecentTransactionsBasic(transactions: List<BasicTransactionData>) {
         val (confirmedTransactions, unconfirmedTransactions) =

diff --git a/blockchain/src/main/java/com/tangem/blockchain/extensions/DebouncedInvoke.kt b/blockchain/src/main/java/com/tangem/blockchain/extensions/DebouncedInvoke.kt
@@ -0,0 +1,26 @@
+package com.tangem.blockchain.extensions
+
+/**
+ * Class wrapping method invocation to be debounced within specified interval [invokeIntervalMillis].
+ *
+ * @param invokeIntervalMillis interval [invokeIntervalMillis]
+ */
+internal class DebouncedInvoke(
+    private val invokeIntervalMillis: Long = 10000L,
+) {
+    private var lastInvokeTime = 0L
+
+    /** Call executable [block] with specified interval or force execution with [forceUpdate] */
+    suspend fun invokeOnExpire(forceUpdate: Boolean = false, block: suspend () -> Unit) {
+        if (forceUpdate) {
+            block()
+        } else if (isExpired()) {
+            lastInvokeTime = System.currentTimeMillis()
+            block()
+        }
+    }
+
+    private fun isExpired(): Boolean {
+        return System.currentTimeMillis() - lastInvokeTime >= invokeIntervalMillis
+    }
+}