feat: Add Kyoto example

Author: ItoroD

bdk-jvm/examples/build.gradle.kts

@@ -15,6 +15,7 @@ repositories {
 dependencies {
     implementation(project(":lib"))
     testImplementation(kotlin("test"))
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.8.1")
 }
 
 tasks.test {
@@ -48,5 +49,12 @@ tasks.register<JavaExec>("MultisigTransaction") {
     classpath = sourceSets["main"].runtimeClasspath
 }
 
+tasks.register<JavaExec>("Kyoto") {
+    group = "application"
+    description = "Runs the main function in the Kyoto example"
+    mainClass.set("org.bitcoindevkit.KyotoKt")
+    classpath = sourceSets["main"].runtimeClasspath
+}
+
 
 

bdk-jvm/examples/src/main/kotlin/Kyoto.kt

@@ -0,0 +1,64 @@
+package org.bitcoindevkit
+
+import kotlinx.coroutines.cancelAndJoin
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import java.nio.file.Files
+import java.nio.file.Paths
+
+fun main() {
+    // Regtest environment must have Compact block filter enabled to run this
+    // Setup your environment according to the https://github.com/thunderbiscuit/podman-regtest-infinity-pro documentation.
+
+    // Add your regtest IP address
+    val ip: IpAddress = IpAddress.fromIpv4(127u, 0u, 0u, 1u)
+    val peer: Peer = Peer(ip, 18444u, false)
+    val peers: List<Peer> = listOf(peer)
+    val currentPath = Paths.get(".").toAbsolutePath().normalize()
+    val persistenceFilePath = Files.createTempDirectory(currentPath, "tempDirPrefix_")
+
+    val wallet = getNewWallet(ActiveWalletScriptType.P2WPKH, Network.REGTEST)
+    val address = wallet.revealNextAddress(KeychainKind.EXTERNAL)
+
+    // Fund this address. Send coins from your regtest to this address
+    println("Receiving address. Send funds to this address: ${address.address}")
+
+    // Wait 70 seconds for funds to arrive before syncing
+    println("Waiting 70 seconds for funds to arrive here ${address.address} before kyoto (compact block filter syncing) ...")
+    Thread.sleep(70000)
+
+    // Create CBF node and client
+    runBlocking {
+        val lightClient = CbfBuilder()
+            .peers(peers)
+            .connections(1u)
+            .scanType(ScanType.New)
+            .dataDir(persistenceFilePath.toString())
+            .build(wallet)
+        val client = lightClient.client
+        val node = lightClient.node
+        val logJob = launch {
+            while (true) {
+                val log = client.nextLog()
+                println(log)
+            }
+        }
+        //Start CBF node
+        node.run()
+        println("Node running")
+
+        //Update wallet
+        val update: Update = client.update()
+        wallet.applyUpdate(update)
+        println("Wallet balance: ${wallet.balance().total.toSat()}")
+
+        if(wallet.balance().total.toSat() > 0uL) {
+            println("Wallet is synced and ready for use!")
+            println("Test completed successfully")
+        }else{
+            println("Wallet balance is 0. Try sending funds to ${address.address} and try again.")
+        }
+        logJob.cancelAndJoin()
+        client.shutdown()
+    }
+}