fix(ocp): prevent excessive cancellation/restart of token-reserves streaming; key balances, mcap, and appreciation at UI

Signed-off-by: Brandon McAnsh <git@bmcreations.dev>

Author: bmc08gt

apps/flipcash/features/balance/src/main/kotlin/com/flipcash/app/balance/internal/components/BalanceHeader.kt

@@ -11,6 +11,7 @@ import androidx.compose.foundation.layout.padding
 import androidx.compose.material.MaterialTheme
 import androidx.compose.material.Text
 import androidx.compose.runtime.Composable
+import androidx.compose.runtime.key
 import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
 import androidx.compose.ui.draw.alpha
@@ -47,16 +48,18 @@ internal fun BalanceHeader(
                 CodeCircularProgressIndicator()
             }
         } else {
-            Crossfade(balance.nativeAmount) { amount ->
-                AmountArea(
-                    amountText = amount.formatted(),
-                    isAltCaption = false,
-                    isAltCaptionKinIcon = false,
-                    currencyResId = exchange.getFlagByCurrency(amount.currencyCode.name),
-                    isClickable = true,
-                    textStyle = CodeTheme.typography.displayLarge,
-                    onClick = onClick
-                )
+            key(balance.nativeAmount) {
+                Crossfade(balance.nativeAmount) { amount ->
+                    AmountArea(
+                        amountText = amount.formatted(),
+                        isAltCaption = false,
+                        isAltCaptionKinIcon = false,
+                        currencyResId = exchange.getFlagByCurrency(amount.currencyCode.name),
+                        isClickable = true,
+                        textStyle = CodeTheme.typography.displayLarge,
+                        onClick = onClick
+                    )
+                }
             }
 
             if (appreciation != null) {

apps/flipcash/features/tokens/src/main/kotlin/com/flipcash/app/tokens/internal/components/info/MarketCapSection.kt

@@ -24,11 +24,13 @@ import androidx.compose.foundation.layout.fillMaxWidth
 import androidx.compose.foundation.layout.height
 import androidx.compose.foundation.layout.padding
 import androidx.compose.foundation.layout.requiredHeight
+import androidx.compose.foundation.layout.size
 import androidx.compose.material.MaterialTheme
 import androidx.compose.material.Text
 import androidx.compose.runtime.Composable
 import androidx.compose.runtime.derivedStateOf
 import androidx.compose.runtime.getValue
+import androidx.compose.runtime.key
 import androidx.compose.runtime.mutableStateOf
 import androidx.compose.runtime.remember
 import androidx.compose.runtime.setValue
@@ -135,6 +137,8 @@ internal fun MarketCapSection(
                             isVisible = highlightedCapPoint == null,
                             period = selectedPeriod,
                         )
+                    } else {
+                        Spacer(Modifier.size(CodeTheme.dimens.grid.x3))
                     }
                 }
 

apps/flipcash/features/tokens/src/main/kotlin/com/flipcash/app/tokens/internal/components/info/TokenBalance.kt

@@ -10,6 +10,7 @@ import androidx.compose.foundation.layout.fillMaxWidth
 import androidx.compose.foundation.layout.padding
 import androidx.compose.material.Text
 import androidx.compose.runtime.Composable
+import androidx.compose.runtime.key
 import androidx.compose.runtime.remember
 import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
@@ -43,22 +44,26 @@ internal fun TokenBalance(
                 CodeCircularProgressIndicator()
             }
         } else {
-            Crossfade(balance) { amount ->
-                AmountArea(
-                    amountText = amount.formatted(),
-                    isAltCaption = false,
-                    isAltCaptionKinIcon = false,
-                    captionText = null,
-                    currencyResId = exchange.getFlagByCurrency(amount.currencyCode.name),
-                    isClickable = true,
-                    textStyle = CodeTheme.typography.displayLarge,
-                    onClick = onClick
-                )
+            key(balance) {
+                Crossfade(balance) { amount ->
+                    AmountArea(
+                        amountText = amount.formatted(),
+                        isAltCaption = false,
+                        isAltCaptionKinIcon = false,
+                        captionText = null,
+                        currencyResId = exchange.getFlagByCurrency(amount.currencyCode.name),
+                        isClickable = true,
+                        textStyle = CodeTheme.typography.displayLarge,
+                        onClick = onClick
+                    )
+                }
             }
 
             if (appreciation != null) {
-                Crossfade(appreciation) { amount ->
-                    CurrencyAppreciationLabel(amount)
+                key(appreciation) {
+                    Crossfade(appreciation) { amount ->
+                        CurrencyAppreciationLabel(amount)
+                    }
                 }
             }
         }

apps/flipcash/shared/tokens/src/main/kotlin/SelectTokenViewModel.kt

@@ -59,7 +59,7 @@ class SelectTokenViewModel @Inject constructor(
             get() = tokens.orEmpty().map { it.balance }.sum()
 
         val aggregateAppreciation: LocalFiat?
-            get() = tokens?.mapNotNull { it.appreciation }?.sum()
+            get() = tokens?.map { it.appreciation }?.sum()
     }
 
     sealed interface Event {

apps/flipcash/shared/tokens/src/main/kotlin/TokenInfoViewModel.kt

@@ -54,6 +54,7 @@ import kotlinx.coroutines.flow.launchIn
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.mapNotNull
 import kotlinx.coroutines.flow.onEach
+import kotlinx.coroutines.flow.onStart
 import javax.inject.Inject
 import kotlin.collections.map
 
@@ -250,10 +251,16 @@ class TokenInfoViewModel @Inject constructor(
                 }
             }.onEach {
                 dispatchEvent(Event.OnMarketCapChanged(it))
-                dispatchEvent(Event.LoadHistoricalDataForPeriod(stateFlow.value.selectedPeriod, evict = true))
             }
             .launchIn(viewModelScope)
 
+        eventFlow
+            .filterIsInstance<Event.OnMarketCapChanged>()
+            .map { it.mcap }
+            .distinctUntilChanged()
+            .onEach { dispatchEvent(Event.LoadHistoricalDataForPeriod(stateFlow.value.selectedPeriod)) }
+            .launchIn(viewModelScope)
+
         eventFlow
             .filterIsInstance<Event.OpenPurchaseMethods>()
             .onEach {

services/opencode/src/main/kotlin/com/getcode/opencode/controllers/TokenController.kt

@@ -21,6 +21,7 @@ import com.getcode.opencode.model.financial.DataSource
 import com.getcode.opencode.model.financial.Fiat
 import com.getcode.opencode.model.financial.HistoricalMintData
 import com.getcode.opencode.model.financial.LocalFiat
+import com.getcode.opencode.model.financial.Rate
 import com.getcode.opencode.model.financial.Token
 import com.getcode.opencode.model.financial.TokenResult
 import com.getcode.opencode.model.financial.TokenWithBalance
@@ -527,7 +528,6 @@ class TokenController @Inject constructor(
             launchpadMetadata = metadata.launchpadMetadata?.copy(currentCirculatingSupplyQuarks = currentSupply)
         )
         val tokenBalance = Fiat.tokenBalance(balance, token)
-        println("balance = ${tokenBalance.decimalValue} for ${token.symbol}")
         val appreciation = tokenBalance - Fiat(fiat = usdCostBasis)
 
         return TokenWithBalance(token, tokenBalance, appreciation)
@@ -591,7 +591,8 @@ class TokenController @Inject constructor(
 
             currencyController.streamLiveMintData(
                 scope = this,
-                mints = _state.map { it.tokens.keys.toList() },
+                mints = _state.map { it.tokens.keys.toList() }
+                    .distinctUntilChanged().debounce(300),
                 tag = "token-reserves"
             ).filterIsInstance<LiveMintDataResponse.LaunchpadReserveState>()
                 .collect { response ->
@@ -618,7 +619,16 @@ class TokenController @Inject constructor(
                             updatedTokens = updatedTokens + (mint to updatedToken)
 
                             state.balances[mint]?.let { balance ->
-                                val newBalance = Fiat.tokenBalance(balance.quarks, updatedToken)
+                                val exchangedValue = LocalFiat.valueExchangeIn(
+                                    amount = balance,
+                                    token = token,
+                                    balance = balance,
+                                    rate = Rate.oneToOne,
+                                    debug = false,
+                                    trace = false,
+                                ).underlyingTokenAmount
+
+                                val newBalance = Fiat.tokenBalance(quarks = exchangedValue.quarks, token = token)
                                 updatedBalances = updatedBalances + (mint to newBalance)
 
                                 trace(
@@ -707,7 +717,6 @@ class TokenController @Inject constructor(
             )
 
             val updates = response.accounts.values.mapNotNull { account ->
-                println("cost basis = ${account.usdCostBasis} for ${account.mint.base58()}")
                 buildTokenWithBalance(account.mint, account.balance, account.usdCostBasis)
             }
 

services/opencode/src/main/kotlin/com/getcode/opencode/model/financial/Fiat.kt

@@ -50,10 +50,10 @@ data class Fiat(
         estimation: () -> BigDecimal,
         tokenMintDecimals: Int,
     ) : this(
-        quarks = parseStringToDouble(
+        fiat = parseStringToDouble(
             estimation().toPlainString(),
             decimalPlaces = tokenMintDecimals
-        ).let { (it * MULTIPLIER).toLong() },
+        ),
         currencyCode = CurrencyCode.USD
     )