feat: kyoto

BDKSwiftExampleWallet.xcodeproj/project.pbxproj

@@ -54,6 +54,7 @@
 		AE4984832A1BBBD7009951E2 /* Preview Assets.xcassets in Resources */ = {isa = PBXBuildFile; fileRef = AE4984822A1BBBD7009951E2 /* Preview Assets.xcassets */; };
 		AE49848D2A1BBBD8009951E2 /* BDKSwiftExampleWalletTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = AE49848C2A1BBBD8009951E2 /* BDKSwiftExampleWalletTests.swift */; };
 		AE4984A62A1BBCB8009951E2 /* README.md in Resources */ = {isa = PBXBuildFile; fileRef = AE4984A52A1BBCB8009951E2 /* README.md */; };
+		AE4D97572E3AFF2500E88A38 /* CbfClient+Extensions.swift in Sources */ = {isa = PBXBuildFile; fileRef = AE4D97562E3AFF2500E88A38 /* CbfClient+Extensions.swift */; };
 		AE6715FA2A9A9220005C193F /* BDKSwiftExampleWalletPriceServiceTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = AE6715F92A9A9220005C193F /* BDKSwiftExampleWalletPriceServiceTests.swift */; };
 		AE6715FD2A9AC056005C193F /* PriceServiceError.swift in Sources */ = {isa = PBXBuildFile; fileRef = AE6715FC2A9AC056005C193F /* PriceServiceError.swift */; };
 		AE6715FF2A9AC066005C193F /* FeeServiceError.swift in Sources */ = {isa = PBXBuildFile; fileRef = AE6715FE2A9AC066005C193F /* FeeServiceError.swift */; };
@@ -163,6 +164,7 @@
 		AE4984882A1BBBD8009951E2 /* BDKSwiftExampleWalletTests.xctest */ = {isa = PBXFileReference; explicitFileType = wrapper.cfbundle; includeInIndex = 0; path = BDKSwiftExampleWalletTests.xctest; sourceTree = BUILT_PRODUCTS_DIR; };
 		AE49848C2A1BBBD8009951E2 /* BDKSwiftExampleWalletTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = BDKSwiftExampleWalletTests.swift; sourceTree = "<group>"; };
 		AE4984A52A1BBCB8009951E2 /* README.md */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = net.daringfireball.markdown; path = README.md; sourceTree = "<group>"; };
+		AE4D97562E3AFF2500E88A38 /* CbfClient+Extensions.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "CbfClient+Extensions.swift"; sourceTree = "<group>"; };
 		AE6474732CE559E000A270C6 /* BDKSwiftExampleWallet.entitlements */ = {isa = PBXFileReference; lastKnownFileType = text.plist.entitlements; path = BDKSwiftExampleWallet.entitlements; sourceTree = "<group>"; };
 		AE6715F92A9A9220005C193F /* BDKSwiftExampleWalletPriceServiceTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = BDKSwiftExampleWalletPriceServiceTests.swift; sourceTree = "<group>"; };
 		AE6715FC2A9AC056005C193F /* PriceServiceError.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = PriceServiceError.swift; sourceTree = "<group>"; };
@@ -572,6 +574,7 @@
 			isa = PBXGroup;
 			children = (
 				77EDA65A2E2A5B3800A5E3AD /* URL+Extensions.swift */,
+				AE4D97562E3AFF2500E88A38 /* CbfClient+Extensions.swift */,
 				AE97E74C2E315A8F000A407D /* AddressType+Extensions.swift */,
 				77F0FDC82DA9A93700B30E4F /* Persister+Extensions.swift */,
 				AEE6C74B2ABCB3E200442ADD /* Transaction+Extensions.swift */,
@@ -756,6 +759,7 @@
 				AE73239B2DF9C00F00D9BAE2 /* TxId+Extensions.swift in Sources */,
 				AE1390C72A7DB0AF0098127A /* KeyService.swift in Sources */,
 				AED4CC0A2A1D297600CE1831 /* BDKService.swift in Sources */,
+				AE4D97572E3AFF2500E88A38 /* CbfClient+Extensions.swift in Sources */,
 				AED4CC102A1D522100CE1831 /* WalletView.swift in Sources */,
 				AE7F67092A7451AA00CED561 /* Price.swift in Sources */,
 				AE184EFC2BFE52C800374362 /* Amount+Extensions.swift in Sources */,

BDKSwiftExampleWallet/Extensions/BDK+Extensions/CbfClient+Extensions.swift

@@ -0,0 +1,190 @@
+//
+//  CbfClient+Extensions.swift
+//  BDKSwiftExampleWallet
+//
+//  Created by Matthew Ramsden on 7/30/25.
+//
+
+import BitcoinDevKit
+import Foundation
+
+extension CbfClient {
+    // Track monitoring tasks per client for clean cancellation
+    private static var monitoringTasks: [ObjectIdentifier: Task<Void, Never>] = [:]
+    private static var warningTasks: [ObjectIdentifier: Task<Void, Never>] = [:]
+    private static var logTasks: [ObjectIdentifier: Task<Void, Never>] = [:]
+    private static var heartbeatTasks: [ObjectIdentifier: Task<Void, Never>] = [:]
+    private static var lastInfoAt: [ObjectIdentifier: Date] = [:]
+    private static let monitoringTasksQueue = DispatchQueue(label: "cbf.monitoring.tasks")
+
+    static func createComponents(wallet: Wallet) -> (client: CbfClient, node: CbfNode) {
+        do {
+
+            let components = try CbfBuilder()
+                .logLevel(logLevel: .debug)
+                .scanType(scanType: .sync)
+                .dataDir(dataDir: Constants.Config.Kyoto.dbPath)
+                .peers(peers: Constants.Networks.Signet.Regular.kyotoPeers)
+                .build(wallet: wallet)
+
+            components.node.run()
+
+            components.client.startBackgroundMonitoring()
+
+            return (client: components.client, node: components.node)
+        } catch {
+            fatalError("Failed to create CBF components: \(error)")
+        }
+    }
+
+    func startBackgroundMonitoring() {
+        let id = ObjectIdentifier(self)
+
+        let task = Task { [self] in
+            var hasEstablishedConnection = false
+            while true {
+                if Task.isCancelled { break }
+                do {
+                    let info = try await self.nextInfo()
+                    CbfClient.monitoringTasksQueue.sync { Self.lastInfoAt[id] = Date() }
+                    switch info {
+                    case let .progress(progress):
+                        await MainActor.run {
+                            NotificationCenter.default.post(
+                                name: NSNotification.Name("KyotoProgressUpdate"),
+                                object: nil,
+                                userInfo: ["progress": progress]
+                            )
+                        }
+                    case let .newChainHeight(height):
+                        await MainActor.run {
+                            NotificationCenter.default.post(
+                                name: NSNotification.Name("KyotoChainHeightUpdate"),
+                                object: nil,
+                                userInfo: ["height": height]
+                            )
+                            if !hasEstablishedConnection {
+                                hasEstablishedConnection = true
+                                NotificationCenter.default.post(
+                                    name: NSNotification.Name("KyotoConnectionUpdate"),
+                                    object: nil,
+                                    userInfo: ["connected": true]
+                                )
+                            }
+                        }
+                    case .connectionsMet, .successfulHandshake:
+                        await MainActor.run {
+                            if !hasEstablishedConnection {
+                                hasEstablishedConnection = true
+                                NotificationCenter.default.post(
+                                    name: NSNotification.Name("KyotoConnectionUpdate"),
+                                    object: nil,
+                                    userInfo: ["connected": true]
+                                )
+                            }
+                        }
+                    default:
+                        break
+                    }
+                } catch is CancellationError {
+                    break
+                } catch {
+                    // ignore
+                }
+            }
+        }
+
+        Self.monitoringTasksQueue.sync {
+            Self.monitoringTasks[id] = task
+            Self.lastInfoAt[id] = Date()
+        }
+
+        // Heartbeat task to signal idleness while awaiting Info events
+        let heartbeat = Task {
+            while true {
+                if Task.isCancelled { break }
+                try? await Task.sleep(nanoseconds: 5_000_000_000)
+                if Task.isCancelled { break }
+                var idleFor: TimeInterval = 0
+                CbfClient.monitoringTasksQueue.sync {
+                    if let last = Self.lastInfoAt[id] { idleFor = Date().timeIntervalSince(last) }
+                }
+            }
+        }
+
+        Self.monitoringTasksQueue.sync {
+            Self.heartbeatTasks[id] = heartbeat
+        }
+
+        // Minimal warnings listener for visibility while syncing
+        let warnings = Task { [self] in
+            while true {
+                if Task.isCancelled { break }
+                do {
+                    let warning = try await self.nextWarning()
+                    if case .needConnections = warning {
+                        await MainActor.run {
+                            NotificationCenter.default.post(
+                                name: NSNotification.Name("KyotoConnectionUpdate"),
+                                object: nil,
+                                userInfo: ["connected": false]
+                            )
+                        }
+                    }
+                } catch is CancellationError {
+                    break
+                } catch {
+                    // ignore
+                }
+            }
+        }
+
+        Self.monitoringTasksQueue.sync {
+            Self.warningTasks[id] = warnings
+        }
+
+        // Log listener for detailed debugging
+        let logs = Task { [self] in
+            while true {
+                if Task.isCancelled { break }
+                do {
+                    let log = try await self.nextLog()
+                } catch is CancellationError {
+                    break
+                } catch {
+                    // ignore
+                }
+            }
+        }
+
+        Self.monitoringTasksQueue.sync {
+            Self.logTasks[id] = logs
+        }
+    }
+
+    func stopBackgroundMonitoring() {
+        let id = ObjectIdentifier(self)
+        Self.monitoringTasksQueue.sync {
+            guard let task = Self.monitoringTasks.removeValue(forKey: id) else { return }
+            task.cancel()
+            if let hb = Self.heartbeatTasks.removeValue(forKey: id) { hb.cancel() }
+            if let wt = Self.warningTasks.removeValue(forKey: id) { wt.cancel() }
+            if let lt = Self.logTasks.removeValue(forKey: id) { lt.cancel() }
+            Self.lastInfoAt.removeValue(forKey: id)
+        }
+    }
+
+    static func cancelAllMonitoring() {
+        Self.monitoringTasksQueue.sync {
+            for (_, task) in Self.monitoringTasks { task.cancel() }
+            for (_, wt) in Self.warningTasks { wt.cancel() }
+            for (_, lt) in Self.logTasks { lt.cancel() }
+            for (_, hb) in Self.heartbeatTasks { hb.cancel() }
+            Self.monitoringTasks.removeAll()
+            Self.warningTasks.removeAll()
+            Self.logTasks.removeAll()
+            Self.heartbeatTasks.removeAll()
+            Self.lastInfoAt.removeAll()
+        }
+    }
+}

BDKSwiftExampleWallet/Resources/Localizable.xcstrings

@@ -146,6 +146,9 @@
           }
         }
       }
+    },
+    "%" : {
+
     },
     "%@ • %@" : {
       "localizations" : {
@@ -210,6 +213,9 @@
           }
         }
       }
+    },
+    "%lld" : {
+
     },
     "%lld Output%@" : {
       "localizations" : {
@@ -467,6 +473,9 @@
           }
         }
       }
+    },
+    "Block %u" : {
+
     },
     "Build Transaction Error" : {
       "localizations" : {
@@ -483,6 +492,9 @@
           }
         }
       }
+    },
+    "Client" : {
+
     },
     "Coldcard Verify Address" : {
 
@@ -623,6 +635,9 @@
           }
         }
       }
+    },
+    "Esplora" : {
+
     },
     "Esplora Server" : {
       "localizations" : {
@@ -733,6 +748,9 @@
           }
         }
       }
+    },
+    "Kyoto" : {
+
     },
     "Navigation Title" : {
       "extractionState" : "stale",
@@ -1049,6 +1067,9 @@
           }
         }
       }
+    },
+    "Select Client Type" : {
+
     },
     "Select Fee" : {
       "localizations" : {