feat: support RN app migration

Bitkit/AppScene.swift

@@ -23,6 +23,7 @@ struct AppScene: View {
     @StateObject private var tagManager = TagManager()
     @StateObject private var transferTracking: TransferTrackingManager
     @StateObject private var channelDetails = ChannelDetailsViewModel.shared
+    @StateObject private var migrations = MigrationsService.shared
 
     @State private var hideSplash = false
     @State private var removeSplash = false
@@ -72,6 +73,9 @@ struct AppScene: View {
             .onChange(of: wallet.walletExists, perform: handleWalletExistsChange)
             .onChange(of: wallet.nodeLifecycleState, perform: handleNodeLifecycleChange)
             .onChange(of: scenePhase, perform: handleScenePhaseChange)
+            .onChange(of: migrations.isShowingMigrationLoading) { isLoading in
+                if !isLoading { widgets.loadSavedWidgets() }
+            }
             .environmentObject(app)
             .environmentObject(navigation)
             .environmentObject(network)
@@ -111,7 +115,9 @@ struct AppScene: View {
     @ViewBuilder
     private var mainContent: some View {
         ZStack {
-            if showRecoveryScreen {
+            if migrations.isShowingMigrationLoading {
+                migrationLoadingContent
+            } else if showRecoveryScreen {
                 RecoveryRouter()
                     .accentColor(.white)
             } else if hasCriticalUpdate {
@@ -127,6 +133,32 @@ struct AppScene: View {
         }
     }
 
+    @ViewBuilder
+    private var migrationLoadingContent: some View {
+        VStack(spacing: 24) {
+            Spacer()
+
+            ProgressView()
+                .scaleEffect(1.5)
+                .tint(.white)
+
+            VStack(spacing: 8) {
+                Text("Updating Wallet")
+                    .font(.system(size: 24, weight: .semibold))
+                    .foregroundColor(.white)
+
+                Text("Please wait while we update the app...")
+                    .font(.system(size: 16))
+                    .foregroundColor(.white.opacity(0.7))
+                    .multilineTextAlignment(.center)
+            }
+
+            Spacer()
+        }
+        .frame(maxWidth: .infinity, maxHeight: .infinity)
+        .background(Color.black)
+    }
+
     @ViewBuilder
     private var walletContent: some View {
         if wallet.walletExists == true {
@@ -247,6 +279,7 @@ struct AppScene: View {
     @Sendable
     private func setupTask() async {
         do {
+            await checkAndPerformRNMigration()
             try wallet.setWalletExistsState()
 
             // Setup TimedSheetManager with all timed sheets
@@ -262,6 +295,43 @@ struct AppScene: View {
         }
     }
 
+    private func checkAndPerformRNMigration() async {
+        let migrations = MigrationsService.shared
+
+        guard !migrations.isMigrationChecked else {
+            Logger.debug("RN migration already checked, skipping", context: "AppScene")
+            return
+        }
+
+        guard !migrations.hasNativeWalletData() else {
+            Logger.info("Native wallet data exists, skipping RN migration", context: "AppScene")
+            migrations.markMigrationChecked()
+            return
+        }
+
+        guard migrations.hasRNWalletData() else {
+            Logger.info("No RN wallet data found, skipping migration", context: "AppScene")
+            migrations.markMigrationChecked()
+            return
+        }
+
+        await MainActor.run { migrations.isShowingMigrationLoading = true }
+        Logger.info("RN wallet data found, starting migration...", context: "AppScene")
+
+        do {
+            try await migrations.migrateFromReactNative()
+        } catch {
+            Logger.error("RN migration failed: \(error)", context: "AppScene")
+            migrations.markMigrationChecked()
+            await MainActor.run { migrations.isShowingMigrationLoading = false }
+            app.toast(
+                type: .error,
+                title: "Migration Failed",
+                description: "Please restore your wallet manually using your recovery phrase"
+            )
+        }
+    }
+
     private func handleNodeLifecycleChange(_ state: NodeLifecycleState) {
         if state == .initializing {
             walletIsInitializing = true

Bitkit/Services/CoreService.swift

@@ -54,7 +54,7 @@
                 }
             }
             await MainActor.run {
                 self.cachedTxIdsInBoostTxIds = txIds
             }
         } catch {
             Logger.error("Failed to refresh boostTxIds cache: \(error)", context: "ActivityService")
@@ -109,7 +109,7 @@
 
     func isActivitySeen(id: String) async -> Bool {
         do {
             if let activity = try await getActivityById(activityId: id) {
                 switch activity {
                 case let .onchain(onchain):
                     return onchain.seenAt != nil
@@ -154,6 +154,42 @@
         }
     }
 
+    func markAllUnseenActivitiesAsSeen() async {
+        let timestamp = UInt64(Date().timeIntervalSince1970)
+
+        do {
+            let activities = try await get()
+            var didMarkAny = false
+
+            for activity in activities {
+                let id: String
+                let isSeen: Bool
+
+                switch activity {
+                case let .onchain(onchain):
+                    id = onchain.id
+                    isSeen = onchain.seenAt != nil
+                case let .lightning(lightning):
+                    id = lightning.id
+                    isSeen = lightning.seenAt != nil
+                }
+
+                if !isSeen {
+                    try await ServiceQueue.background(.core) {
+                        try BitkitCore.markActivityAsSeen(activityId: id, seenAt: timestamp)
+                    }
+                    didMarkAny = true
+                }
+            }
+
+            if didMarkAny {
+                activitiesChangedSubject.send()
+            }
+        } catch {
+            Logger.error("Failed to mark all activities as seen: \(error)", context: "ActivityService")
+        }
+    }
+
     // MARK: - Transaction Status Checks
 
     func wasTransactionReplaced(txid: String) async -> Bool {
@@ -582,7 +618,7 @@
     }
 
     private func processLightningPayment(_ payment: PaymentDetails) async throws {
         guard case let .bolt11(hash, preimage, secret, description, bolt11) = payment.kind else { return }
 
         // Skip pending inbound payments - just means they created an invoice
         guard !(payment.status == .pending && payment.direction == .inbound) else { return }
@@ -635,7 +671,7 @@
 
             for payment in payments {
                 do {
                     let state: BitkitCore.PaymentState = switch payment.status {
                     case .failed:
                         .failed
                     case .pending:
@@ -671,7 +707,7 @@
                             latestCaughtError = error
                         }
                     }
                 } catch {
                     Logger.error("Error syncing LDK payment: \(error)", context: "CoreService")
                     latestCaughtError = error
                 }
@@ -705,7 +741,7 @@
     /// Check if a transaction spends a closed channel's funding UTXO
     private func findClosedChannelForTransaction(txid: String, transactionDetails: BitkitCore.TransactionDetails? = nil) async -> String? {
         do {
             let closedChannels = try await getAllClosedChannels(sortDirection: .desc)
             guard !closedChannels.isEmpty else { return nil }
 
             let details = if let provided = transactionDetails { provided } else { await fetchTransactionDetails(txid: txid) }

Bitkit/Services/LightningService.swift

@@ -22,7 +22,12 @@
 
     private init() {}
 
-    func setup(walletIndex: Int, electrumServerUrl: String? = nil, rgsServerUrl: String? = nil) async throws {
+    func setup(
+        walletIndex: Int,
+        electrumServerUrl: String? = nil,
+        rgsServerUrl: String? = nil,
+        channelMigration: ChannelDataMigration? = nil
+    ) async throws {
         Logger.debug("Checking lightning process lock...")
         try StateLocker.lock(.lightning, wait: 30) // Wait 30 seconds to lock because maybe extension is still running
 
@@ -80,7 +85,11 @@
         Logger.debug("Building ldk-node with vssUrl: '\(vssUrl)'")
         Logger.debug("Building ldk-node with lnurlAuthServerUrl: '\(lnurlAuthServerUrl)'")
 
-        // Set entropy from mnemonic on builder
+        if let channelMigration {
+            builder.setChannelDataMigration(migration: channelMigration)
+            Logger.info("Applied channel migration: \(channelMigration.channelMonitors.count) monitors", context: "Migration")
+        }
+
         builder.setEntropyBip39Mnemonic(mnemonic: mnemonic, passphrase: passphrase)
 
         try await ServiceQueue.background(.ldk) {
@@ -488,7 +497,7 @@
     }
 
     func closeChannel(_ channel: ChannelDetails, force: Bool = false, forceCloseReason: String? = nil) async throws {
         guard let node else {
             throw AppError(serviceError: .nodeNotStarted)
         }
 
@@ -706,7 +715,7 @@
                 onEvent?(event)
 
                 switch event {
                 case let .paymentSuccessful(paymentId, paymentHash, paymentPreimage, feePaidMsat):
                     Logger.info("✅ Payment successful: paymentId: \(paymentId ?? "?") paymentHash: \(paymentHash) feePaidMsat: \(feePaidMsat ?? 0)")
                     Task {
                         let hash = paymentId ?? paymentHash
@@ -731,7 +740,7 @@
                             Logger.warn("No paymentId or paymentHash available for failed payment", context: "LightningService")
                         }
                     }
                 case let .paymentReceived(paymentId, paymentHash, amountMsat, feePaidMsat):
                     Logger.info("🤑 Payment received: paymentId: \(paymentId ?? "?") paymentHash: \(paymentHash) amountMsat: \(amountMsat)")
                     Task {
                         let hash = paymentId ?? paymentHash
@@ -741,7 +750,7 @@
                             Logger.error("Failed to handle payment received for \(hash): \(error)", context: "LightningService")
                         }
                     }
                 case let .paymentClaimable(paymentId, paymentHash, claimableAmountMsat, claimDeadline, customRecords):
                     Logger.info(
                         "🫰 Payment claimable: paymentId: \(paymentId) paymentHash: \(paymentHash) claimableAmountMsat: \(claimableAmountMsat)"
                     )
@@ -770,7 +779,7 @@
 
                     if let channel {
                         await registerClosedChannel(channel: channel, reason: reasonString)
                         await MainActor.run {
                             channelCache.removeValue(forKey: channelIdString)
                         }
                     } else {
@@ -793,7 +802,7 @@
                             Logger.error("Failed to handle transaction received for \(txid): \(error)", context: "LightningService")
                         }
                     }
                 case let .onchainTransactionConfirmed(txid, blockHash, blockHeight, confirmationTime, details):
                     Logger.info("✅ Onchain transaction confirmed: txid=\(txid) blockHeight=\(blockHeight) amountSats=\(details.amountSats)")
                     Task {
                         do {
@@ -847,7 +856,7 @@
 
                 // MARK: Balance Events
 
                 case let .balanceChanged(oldSpendableOnchain, newSpendableOnchain, oldTotalOnchain, newTotalOnchain, oldLightning, newLightning):
                     Logger
                         .info("💰 Balance changed: onchain=\(oldSpendableOnchain)->\(newSpendableOnchain) lightning=\(oldLightning)->\(newLightning)")