feat: channel monitor recovery flow

Depends on: synonymdev/ldk-node#76

Author: ben-kaufman

app/src/main/java/to/bitkit/env/Env.kt

@@ -23,6 +23,7 @@ internal object Env {
     val network = Network.valueOf(BuildConfig.NETWORK)
     val locales = BuildConfig.LOCALES.split(",")
     const val walletSyncIntervalSecs = 10_uL
+    const val walletSyncTimeoutSecs = 10_uL
     val platform = "Android ${Build.VERSION.RELEASE} (API ${Build.VERSION.SDK_INT})"
     const val version = "$VERSION_NAME (${BuildConfig.VERSION_CODE})"
 

app/src/main/java/to/bitkit/services/LightningService.kt

@@ -138,7 +138,7 @@ class LightningService @Inject constructor(
         )
     }
 
-    @Suppress("ForbiddenComment")
+    @Suppress("ForbiddenComment", "LongMethod")
     private suspend fun build(
         walletIndex: Int,
         customServerUrl: String?,
@@ -186,11 +186,34 @@ class LightningService @Inject constructor(
                 "Building node with \n\t vssUrl: '$vssUrl'\n\t lnurlAuthServerUrl: '$lnurlAuthServerUrl'",
                 context = TAG,
             )
-            if (lnurlAuthServerUrl.isNotEmpty()) {
-                builder.buildWithVssStore(vssUrl, vssStoreId, lnurlAuthServerUrl, fixedHeaders)
-            } else {
-                builder.buildWithVssStoreAndFixedHeaders(vssUrl, vssStoreId, fixedHeaders)
+
+            fun buildNode() = runCatching {
+                if (lnurlAuthServerUrl.isNotEmpty()) {
+                    builder.buildWithVssStore(vssUrl, vssStoreId, lnurlAuthServerUrl, fixedHeaders)
+                } else {
+                    builder.buildWithVssStoreAndFixedHeaders(vssUrl, vssStoreId, fixedHeaders)
+                }
             }
+
+            buildNode().recoverCatching {
+                if (it !is BuildException.DangerousValue) throw it
+                // Handle `DangerousValue` with recovery flow
+                Logger.warn(
+                    "Build failed with DangerousValue. Retrying with `accept_stale_channel_monitors` for recovery.",
+                    it,
+                    context = TAG,
+                )
+                builder.setAcceptStaleChannelMonitors(true)
+                buildNode()
+                    .onFailure { recoveryError ->
+                        Logger.error(
+                            "Error in recovery attempt with `accept_stale_channel_monitors`.",
+                            recoveryError,
+                            context = TAG,
+                        )
+                    }
+                    .getOrThrow()
+            }.getOrThrow()
         } catch (e: BuildException) {
             throw LdkError(e)
         } finally {
@@ -226,6 +249,7 @@ class LightningService @Inject constructor(
                     lightningWalletSyncIntervalSecs = Env.walletSyncIntervalSecs,
                     feeRateCacheUpdateIntervalSecs = Env.walletSyncIntervalSecs,
                 ),
+                connectionTimeoutSecs = Env.walletSyncTimeoutSecs, // 10s
             ),
         )
     }

gradle/libs.versions.toml

@@ -58,7 +58,7 @@ ktor-client-core = { module = "io.ktor:ktor-client-core", version.ref = "ktor" }
 ktor-client-logging = { module = "io.ktor:ktor-client-logging", version.ref = "ktor" }
 ktor-client-okhttp = { module = "io.ktor:ktor-client-okhttp", version.ref = "ktor" }
 ktor-serialization-kotlinx-json = { module = "io.ktor:ktor-serialization-kotlinx-json", version.ref = "ktor" }
-ldk-node-android = { module = "com.synonym:ldk-node-android", version = "0.7.0-rc.32" }
+ldk-node-android = { module = "com.synonym:ldk-node-android", version = "0.7.0-rc.34" }
 lifecycle-process = { group = "androidx.lifecycle", name = "lifecycle-process", version.ref = "lifecycle" }
 lifecycle-runtime-compose = { module = "androidx.lifecycle:lifecycle-runtime-compose", version.ref = "lifecycle" }
 lifecycle-runtime-ktx = { module = "androidx.lifecycle:lifecycle-runtime-ktx", version.ref = "lifecycle" }