fix: revert Swift-side filtering + bump ldk-node to v0.7.0-rc.33 which includes the migration-aware write protection

Author: jvsena42

Bitkit.xcodeproj/project.pbxproj

@@ -928,7 +928,7 @@
 			repositoryURL = "https://github.com/synonymdev/ldk-node";
 			requirement = {
 				kind = revision;
-				revision = c5698d00066e0e50f33696afc562d71023da2373;
+				revision = 1531af727811f03ec0542aec3befb5a26198b192;
 			};
 		};
 		96DEA0382DE8BBA1009932BF /* XCRemoteSwiftPackageReference "bitkit-core" */ = {

Bitkit.xcodeproj/project.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -311,9 +311,6 @@ enum RNKeychainKey {
 struct PendingChannelMigration: Codable {
     let channelManager: Data
     let channelMonitors: [Data]
-    /// Parallel array of channel monitor IDs in "{txid}_{output_index}" format.
-    /// Used to filter out monitors that already exist locally before applying migration.
-    let channelMonitorIds: [String]
 }
 
 /// Peer entry from backup peers.json: [{"pubKey":"...","address":"...","port":9735}, ...]
@@ -682,7 +679,6 @@ extension MigrationsService {
 
         let managerData = try Data(contentsOf: managerPath)
         var monitors: [Data] = []
-        var monitorIds: [String] = []
 
         let channelsPath = accountPath.appendingPathComponent("channels")
         let monitorsPath = accountPath.appendingPathComponent("monitors")
@@ -693,14 +689,12 @@ extension MigrationsService {
             for file in monitorFiles where file.hasSuffix(".bin") {
                 let monitorData = try Data(contentsOf: monitorDir.appendingPathComponent(file))
                 monitors.append(monitorData)
-                monitorIds.append(file.replacingOccurrences(of: ".bin", with: ""))
             }
         }
 
         pendingChannelMigration = PendingChannelMigration(
             channelManager: managerData,
-            channelMonitors: monitors,
-            channelMonitorIds: monitorIds
+            channelMonitors: monitors
         )
         Logger.info("Prepared \(monitors.count) channel monitors for migration", context: "Migration")
     }
@@ -2138,12 +2132,7 @@ extension MigrationsService {
                 )
             }
 
-            let successfulResults = monitorResults.compactMap { id, data -> (String, Data)? in
-                guard let data else { return nil }
-                return (id, data)
-            }
-            let monitorIds = successfulResults.map(\.0)
-            let monitors = successfulResults.map(\.1)
+            let monitors = monitorResults.compactMap(\.1)
 
             if monitors.count < expectedCount {
                 Logger.warn(
@@ -2155,8 +2144,7 @@ extension MigrationsService {
             if !monitors.isEmpty {
                 pendingChannelMigration = PendingChannelMigration(
                     channelManager: managerData,
-                    channelMonitors: monitors,
-                    channelMonitorIds: monitorIds
+                    channelMonitors: monitors
                 )
                 Logger.info("Prepared \(monitors.count)/\(expectedCount) channel monitors for migration", context: "Migration")
             }

Bitkit/Services/MigrationsService.swift

@@ -282,8 +282,7 @@ class WalletViewModel: ObservableObject {
                     "Found \(migration.channelMonitors.count) monitors on RN backup for pre-startup recovery",
                     context: "WalletViewModel"
                 )
-                let filtered = filterMigrationMonitors(migration, walletIndex: walletIndex)
-                return (filtered, allRetrieved)
+                return (migration, allRetrieved)
             } else {
                 Logger.info("No channel monitors found on RN backup", context: "WalletViewModel")
                 return (nil, allRetrieved)
@@ -294,56 +293,6 @@ class WalletViewModel: ObservableObject {
         }
     }
 
-    /// Filters out migration monitors for channels that already have local monitors.
-    /// Prevents old RN monitors from overwriting newer local ones during orphaned channel recovery.
-    private func filterMigrationMonitors(_ migration: PendingChannelMigration, walletIndex: Int) -> PendingChannelMigration? {
-        let monitorsDir = Env.ldkStorage(walletIndex: walletIndex)
-            .appendingPathComponent("channel_monitors")
-            .appendingPathComponent("0")
-
-        guard FileManager.default.fileExists(atPath: monitorsDir.path) else {
-            Logger.debug("No local monitors directory, keeping all migration monitors", context: "WalletViewModel")
-            return migration
-        }
-
-        let localFiles = (try? FileManager.default.contentsOfDirectory(atPath: monitorsDir.path)) ?? []
-        guard !localFiles.isEmpty else {
-            Logger.debug("No local monitor files, keeping all migration monitors", context: "WalletViewModel")
-            return migration
-        }
-
-        let localMonitorIds = Set(localFiles)
-        var filteredMonitors: [Data] = []
-        var filteredIds: [String] = []
-
-        for (index, monitorId) in migration.channelMonitorIds.enumerated() {
-            if localMonitorIds.contains(monitorId) {
-                Logger.info("Skipping migration monitor \(monitorId) — already exists locally", context: "WalletViewModel")
-            } else {
-                filteredMonitors.append(migration.channelMonitors[index])
-                filteredIds.append(monitorId)
-            }
-        }
-
-        if filteredMonitors.isEmpty {
-            Logger.info(
-                "All \(migration.channelMonitors.count) migration monitors already exist locally, skipping migration",
-                context: "WalletViewModel"
-            )
-            return nil
-        }
-
-        Logger.info(
-            "Filtered migration monitors: \(filteredMonitors.count) kept, \(migration.channelMonitors.count - filteredMonitors.count) skipped (already local)",
-            context: "WalletViewModel"
-        )
-        return PendingChannelMigration(
-            channelManager: migration.channelManager,
-            channelMonitors: filteredMonitors,
-            channelMonitorIds: filteredIds
-        )
-    }
-
     private func fetchTrustedPeersFromBlocktank() async -> [LnPeer]? {
         switch Self.peerSimulation {
         case .apiFailure: