feat: Add ldk debug dev settings screen

Author: ovitrif

app/src/main/java/to/bitkit/data/backup/VssBackupClient.kt

@@ -1,7 +1,10 @@
 package to.bitkit.data.backup
 
+import com.synonym.vssclient.KeyVersion
 import com.synonym.vssclient.VssItem
+import com.synonym.vssclient.vssDelete
 import com.synonym.vssclient.vssGet
+import com.synonym.vssclient.vssListKeys
 import com.synonym.vssclient.vssNewClient
 import com.synonym.vssclient.vssNewClientWithLnurlAuth
 import com.synonym.vssclient.vssStore
@@ -106,6 +109,52 @@ class VssBackupClient @Inject constructor(
         }
     }
 
+    suspend fun listKeys(prefix: String? = null): Result<List<KeyVersion>> = withContext(ioDispatcher) {
+        isSetup.await()
+        Logger.verbose("VSS 'listKeys' call with prefix: '$prefix'", context = TAG)
+        runCatching {
+            vssListKeys(prefix = prefix)
+        }.onSuccess {
+            Logger.verbose("VSS 'listKeys' success - found ${it.size} key(s)", context = TAG)
+        }.onFailure { e ->
+            Logger.verbose("VSS 'listKeys' error", e = e, context = TAG)
+        }
+    }
+
+    suspend fun deleteObject(key: String): Result<Boolean> = withContext(ioDispatcher) {
+        isSetup.await()
+        Logger.verbose("VSS 'deleteObject' call for '$key'", context = TAG)
+        runCatching {
+            vssDelete(key = key)
+        }.onSuccess { wasDeleted ->
+            if (wasDeleted) {
+                Logger.verbose("VSS 'deleteObject' success for '$key' - key was deleted", context = TAG)
+            } else {
+                Logger.verbose("VSS 'deleteObject' success for '$key' - key did not exist", context = TAG)
+            }
+        }.onFailure { e ->
+            Logger.verbose("VSS 'deleteObject' error for '$key'", e = e, context = TAG)
+        }
+    }
+
+    suspend fun deleteAllKeys(): Result<Int> = withContext(ioDispatcher) {
+        isSetup.await()
+        Logger.verbose("VSS 'deleteAllKeys' call", context = TAG)
+        runCatching {
+            val keys = vssListKeys(prefix = null)
+            var deletedCount = 0
+            for (keyVersion in keys) {
+                val wasDeleted = vssDelete(key = keyVersion.key)
+                if (wasDeleted) deletedCount++
+            }
+            deletedCount
+        }.onSuccess {
+            Logger.verbose("VSS 'deleteAllKeys' success - deleted $it key(s)", context = TAG)
+        }.onFailure { e ->
+            Logger.verbose("VSS 'deleteAllKeys' error", e = e, context = TAG)
+        }
+    }
+
     companion object Companion {
         private const val TAG = "VssBackupClient"
     }

app/src/main/java/to/bitkit/ext/PeerDetails.kt

@@ -1,5 +1,6 @@
 package to.bitkit.ext
 
+import com.synonym.bitkitcore.ILspNode
 import org.lightningdevkit.ldknode.PeerDetails
 
 val PeerDetails.host get() = address.substringBefore(":")
@@ -35,3 +36,15 @@ fun PeerDetails.Companion.from(nodeId: String, host: String, port: String) = Pee
     isConnected = false,
     isPersisted = false,
 )
+
+fun ILspNode.toPeerDetails(): PeerDetails? {
+    val address = connectionStrings.firstOrNull() ?: return null
+    return PeerDetails(
+        nodeId = pubkey,
+        address = address,
+        isConnected = false,
+        isPersisted = false,
+    )
+}
+
+fun List<ILspNode>.toPeerDetailsList(): List<PeerDetails> = mapNotNull { it.toPeerDetails() }

app/src/main/java/to/bitkit/repositories/LightningRepo.kt

@@ -46,6 +46,7 @@ import to.bitkit.di.BgDispatcher
 import to.bitkit.env.Env
 import to.bitkit.ext.getSatsPerVByteFor
 import to.bitkit.ext.nowTimestamp
+import to.bitkit.ext.toPeerDetailsList
 import to.bitkit.models.CoinSelectionPreference
 import to.bitkit.models.NodeLifecycleState
 import to.bitkit.models.OpenChannelResult
@@ -170,14 +171,25 @@ class LightningRepo @Inject constructor(
         customRgsServerUrl: String? = null,
     ) = withContext(bgDispatcher) {
         return@withContext try {
-            lightningService.setup(walletIndex, customServerUrl, customRgsServerUrl)
+            val trustedPeers = getTrustedPeersFromBlocktank()
+            lightningService.setup(walletIndex, customServerUrl, customRgsServerUrl, trustedPeers)
             Result.success(Unit)
         } catch (e: Throwable) {
             Logger.error("Node setup error", e, context = TAG)
             Result.failure(e)
         }
     }
 
+    private suspend fun getTrustedPeersFromBlocktank(): List<PeerDetails>? = runCatching {
+        val info = coreService.blocktank.info(refresh = false)
+            ?: coreService.blocktank.info(refresh = true)
+        info?.nodes?.toPeerDetailsList()?.also {
+            Logger.info("Loaded ${it.size} trusted peers from blocktank", context = TAG)
+        }
+    }.onFailure {
+        Logger.warn("Failed to get trusted peers from blocktank", e = it, context = TAG)
+    }.getOrNull()
+
     @Suppress("LongMethod", "LongParameterList")
     suspend fun start(
         walletIndex: Int = 0,
@@ -989,6 +1001,29 @@ class LightningRepo @Inject constructor(
                 }
         }
 
+    // region debug
+    fun getNetworkGraphInfo() = lightningService.getNetworkGraphInfo()
+
+    suspend fun exportNetworkGraphToFile(outputDir: String): Result<java.io.File> =
+        executeWhenNodeRunning("exportNetworkGraphToFile") {
+            lightningService.exportNetworkGraphToFile(outputDir)
+        }
+
+    suspend fun restartNode(): Result<Unit> = withContext(bgDispatcher) {
+        Logger.info("Restarting LDK node", context = TAG)
+        stop().onFailure {
+            Logger.error("Failed to stop node during restart", it, context = TAG)
+            return@withContext Result.failure(it)
+        }
+        start(shouldRetry = false).onFailure {
+            Logger.error("Failed to start node during restart", it, context = TAG)
+            return@withContext Result.failure(it)
+        }
+        Logger.info("LDK node restarted successfully", context = TAG)
+        Result.success(Unit)
+    }
+    // endregion
+
     companion object {
         private const val TAG = "LightningRepo"
         private const val CHANNEL_ID_PREVIEW_LENGTH = 10