chore(ocp): warm up managed channel with lifecycle resume

ensure we have near-instant access to the gRPC channel

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

Author: bmc08gt

apps/flipcash/core/src/main/kotlin/com/flipcash/app/core/ui/TokenSelectionPill.kt

@@ -16,7 +16,6 @@ import androidx.compose.ui.res.painterResource
 import com.getcode.opencode.model.financial.Token
 import com.getcode.theme.CodeTheme
 import com.getcode.ui.core.R
-import com.getcode.ui.core.debugBounds
 import com.getcode.ui.core.rememberedClickable
 
 @Composable

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

@@ -164,6 +164,7 @@ class MessagingController @Inject constructor(
         return repository.pollMessages(rendezvous)
             .map { messages ->
                 messages.filter {
+                    trace(message = "Polled message kind: ${it.kindCase}")
                     it.kindCase == MessagingService.Message.KindCase.REQUEST_TO_GIVE_BILL
                 }
             }.mapCatching { messages ->

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

@@ -152,7 +152,7 @@ class TokenController @Inject constructor(
             .launchIn(scope)
     }
 
-    override fun onResume(owner: LifecycleOwner) {
+    override fun onStart(owner: LifecycleOwner) {
         trace(
             tag = TAG,
             message = "Lifecycle resumed, starting reserve state stream",

services/opencode/src/main/kotlin/com/getcode/opencode/internal/exchange/OpenCodeExchange.kt

@@ -52,8 +52,7 @@ internal class OpenCodeExchange @Inject constructor(
         }
     }
 
-    override fun onResume(owner: LifecycleOwner) {
-        super.onResume(owner)
+    override fun onStart(owner: LifecycleOwner) {
         streamRates()
     }
 

services/opencode/src/main/kotlin/com/getcode/opencode/internal/network/api/MessagingApi.kt

@@ -15,7 +15,6 @@ import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.withContext
 import java.io.ByteArrayOutputStream
-import java.util.concurrent.TimeUnit
 import javax.inject.Inject
 
 internal class MessagingApi @Inject constructor(

services/opencode/src/main/kotlin/com/getcode/opencode/internal/network/core/GrpcApi.kt

@@ -1,5 +1,23 @@
 package com.getcode.opencode.internal.network.core
 
+import androidx.lifecycle.DefaultLifecycleObserver
+import androidx.lifecycle.LifecycleOwner
+import androidx.lifecycle.ProcessLifecycleOwner
 import io.grpc.ManagedChannel
 
-abstract class GrpcApi(protected val managedChannel: ManagedChannel)
+abstract class GrpcApi(protected val managedChannel: ManagedChannel): DefaultLifecycleObserver {
+
+    init {
+        ProcessLifecycleOwner.get().lifecycle.addObserver(this)
+    }
+
+
+    override fun onStart(owner: LifecycleOwner) {
+        super.onStart(owner)
+        warmUp()
+    }
+
+    private fun warmUp() {
+        managedChannel.getState(true)
+    }
+}

services/opencode/src/main/kotlin/com/getcode/opencode/internal/network/services/MessagingService.kt

@@ -1,5 +1,8 @@
 package com.getcode.opencode.internal.network.services
 
+import androidx.lifecycle.DefaultLifecycleObserver
+import androidx.lifecycle.LifecycleOwner
+import androidx.lifecycle.ProcessLifecycleOwner
 import com.codeinc.opencode.gen.messaging.v1.MessagingService
 import com.getcode.ed25519.Ed25519.KeyPair
 import com.getcode.opencode.internal.bidi.BidirectionalStreamReference
@@ -123,6 +126,7 @@ internal class MessagingService @Inject constructor(
     suspend fun pollMessages(
         rendezvous: KeyPair,
     ): Result<List<MessagingService.Message>> {
+        trace("Message polling.")
         return runCatching { api.pollMessages(rendezvous) }
             .foldWithSuppression(
                 onSuccess = { response ->

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

@@ -10,7 +10,6 @@ import com.getcode.opencode.model.accounts.AccountCluster
 import com.getcode.opencode.model.core.OpenCodePayload
 import com.getcode.opencode.model.core.PayloadKind
 import com.getcode.opencode.model.transactions.TransactionMetadata
-import com.getcode.solana.keys.PublicKey
 import com.getcode.utils.CodeServerError
 import com.getcode.utils.ErrorUtils
 import kotlinx.coroutines.CoroutineScope