chore: more temp logging because not getting peer info today

Author: reez

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

@@ -11,6 +11,7 @@ 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 heartbeatTasks: [ObjectIdentifier: Task<Void, Never>] = [:]
     private static var lastInfoAt: [ObjectIdentifier: Date] = [:]
     private static let monitoringTasksQueue = DispatchQueue(label: "cbf.monitoring.tasks")
@@ -132,6 +133,36 @@ extension CbfClient {
         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 DEBUG
+                    print("[Kyoto][warning] \(String(describing: warning))")
+                    #endif
+                    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
+        }
     }
 
     func stopBackgroundMonitoring() {
@@ -140,15 +171,18 @@ extension CbfClient {
             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() }
             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 (_, hb) in Self.heartbeatTasks { hb.cancel() }
             Self.monitoringTasks.removeAll()
+            Self.warningTasks.removeAll()
             Self.heartbeatTasks.removeAll()
             Self.lastInfoAt.removeAll()
         }