fix(ocp): serially fetch token verified state if not proviced or in cache

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

Author: bmc08gt

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

@@ -13,11 +13,14 @@ import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.flow.emptyFlow
+import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.flatMapLatest
 import kotlinx.coroutines.flow.shareIn
 import kotlinx.coroutines.launch
+import kotlinx.coroutines.suspendCancellableCoroutine
 import javax.inject.Inject
 import javax.inject.Singleton
+import kotlin.coroutines.resume
 
 @Singleton
 class CurrencyController @Inject constructor(
@@ -50,6 +53,19 @@ class CurrencyController @Inject constructor(
         }
     }
 
+    suspend fun getLiveMintData(
+        scope: CoroutineScope,
+        mint: Mint,
+        tag: String? = null
+    ): Result<LiveMintDataResponse> = runCatching {
+        callbackFlow {
+            val reference = repository.streamMintData(scope = scope, mints = listOf(mint), tag = tag) {
+                trySend(it)
+            }
+            awaitClose { reference.cancel() }
+        }.first()
+    }
+
     suspend fun getMintMetadata(
         addresses: List<Mint>
     ): Result<List<MintMetadata>> {

services/opencode/src/main/kotlin/com/getcode/opencode/internal/transactors/GiveBillTransactor.kt

@@ -1,6 +1,7 @@
 package com.getcode.opencode.internal.transactors
 
 import com.getcode.ed25519.Ed25519.KeyPair
+import com.getcode.opencode.controllers.CurrencyController
 import com.getcode.opencode.controllers.MessagingController
 import com.getcode.opencode.controllers.TransactionController
 import com.getcode.opencode.internal.extensions.exchangeDataFor
@@ -25,6 +26,7 @@ import kotlinx.coroutines.cancel
 import kotlin.time.Duration
 
 internal class GiveBillTransactor(
+    private val currencyController: CurrencyController,
     private val messagingController: MessagingController,
     private val transactionController: TransactionController,
     private val scope: CoroutineScope,
@@ -80,14 +82,16 @@ internal class GiveBillTransactor(
         val sendingAmount = amount
             ?: return logAndFail(GiveTransactorError.Other(message = "No amount. Did you call with() first?"))
 
-        val verifiedState = if (providedVerifiedState != null) {
-            providedVerifiedState
-        } else {
-            verifiedProtoManager.getVerifiedStateFor(
-                sendingAmount.rate.currency,
-                desiredToken.address
-            )
-        } ?: return logAndFail(GiveTransactorError.Other(message = "No verified state found"))
+        // Resolve the verified state for the given currency/token pair using a fallback chain:
+        // 1. Use the provided state directly if available
+        // 2. Otherwise, check the local proto store
+        // 3. If still missing, fetch live mint data (which internally persists to the store) and re-query
+        val verifiedState = providedVerifiedState
+            ?: verifiedProtoManager.getVerifiedStateFor(sendingAmount.rate.currency, desiredToken.address)
+            ?: currencyController.getLiveMintData(scope, desiredToken.address)
+                .map { verifiedProtoManager.getVerifiedStateFor(sendingAmount.rate.currency, desiredToken.address) }
+                .getOrNull()
+            ?: return logAndFail(GiveTransactorError.Other("Failed to get verified state"))
 
         val exchangeData = verifiedState.exchangeDataFor(
             amount = sendingAmount,

services/opencode/src/main/kotlin/com/getcode/opencode/internal/transactors/ReceiveGiftCardTransactor.kt

@@ -66,7 +66,6 @@ internal class ReceiveGiftCardTransactor(
                     return@timedTraceSuspend logAndFail(ReceiveGiftTransactorError.FailedToQuery(message = "No accounts found"))
                 }
 
-            onStep("account query")
             val info = accounts.values.first()
 
             if (info.claimState == AccountInfo.ClaimState.Claimed) {

services/opencode/src/main/kotlin/com/getcode/opencode/managers/BillTransactionManager.kt

@@ -1,6 +1,7 @@
 package com.getcode.opencode.managers
 
 import com.getcode.opencode.controllers.AccountController
+import com.getcode.opencode.controllers.CurrencyController
 import com.getcode.opencode.controllers.MessagingController
 import com.getcode.opencode.controllers.TransactionController
 import com.getcode.opencode.internal.manager.VerifiedProtoManager
@@ -33,6 +34,7 @@ import kotlin.time.Duration
 @Singleton
 class BillTransactionManager @Inject constructor(
     private val accountController: AccountController,
+    private val currencyController: CurrencyController,
     private val messagingController: MessagingController,
     private val transactionController: TransactionController,
     private val tokenProvider: TokenMetadataProvider,
@@ -69,10 +71,11 @@ class BillTransactionManager @Inject constructor(
             val childScope = CoroutineScope(sharedScope.coroutineContext + Job())
 
             val transactor = GiveBillTransactor(
-                messagingController,
-                transactionController,
-                childScope,
-                verifiedProtoManager,
+                currencyController = currencyController,
+                messagingController = messagingController,
+                transactionController = transactionController,
+                scope = childScope,
+                verifiedProtoManager = verifiedProtoManager,
             ).apply {
                 with(token, amount, owner, billExchangeDataTimeout, verifiedState)
             }