feat: support RN app migration

Author: ben-kaufman

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

@@ -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/AppScene.swift

@@ -154,6 +154,42 @@ class ActivityService {
         }
     }
 
+    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 {

Bitkit/Services/CoreService.swift

@@ -22,7 +22,12 @@ class LightningService {
 
     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 @@ class LightningService {
         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) {