Merge pull request #25 from synonymdev/migrate-old-ldk

ovitrif · web-flow · commit 612ad053cf08 · 2025-12-23T13:53:43.000+01:00
Add channel data migration from external LDK implementations
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,4 @@
-# 0.7.0-rc.1 (Synonym Fork)
+# 0.7.0-rc.2 (Synonym Fork)
 
 ## Synonym Fork Additions
 - Added reactive event system for wallet monitoring without polling:
@@ -51,6 +51,10 @@
   from external wallets). Default is `false` for safety, as spending unconfirmed external funds
   carries risk of double-spending. This affects all balance reporting including `list_balances()`
   and `BalanceChanged` events.
+- Added `ChannelDataMigration` struct and `Builder::set_channel_data_migration()` method to migrate
+  channel data from external LDK implementations (e.g., react-native-ldk). The channel manager and
+  monitor data is written to the configured storage during build, before channel monitors are read.
+  Storage keys for monitors are derived from the funding outpoint.
 
 # 0.7.0 - Dec. 3, 2025
 This seventh minor release introduces numerous new features, bug fixes, and API improvements. In particular, it adds support for channel Splicing, Async Payments, as well as sourcing chain data from a Bitcoin Core REST backend.
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ldk-node"
-version = "0.7.0-rc.1"
+version = "0.7.0-rc.2"
 authors = ["Elias Rohrer <dev@tnull.de>"]
 homepage = "https://lightningdevkit.org/"
 license = "MIT OR Apache-2.0"
diff --git a/Package.swift b/Package.swift
@@ -3,8 +3,8 @@
 
 import PackageDescription
 
-let tag = "v0.7.0-rc.1"
-let checksum = "2e44a30a302b3d1a934e7e212c691161b0cb6f4d367593b9e555d53d401830d3"
+let tag = "v0.7.0-rc.2"
+let checksum = "02b7edc2f3fcf2b8a1c914bd1f03e8a3bf2aca2281a2314d0d03cb7547ecd11a"
 let url = "https://github.com/synonymdev/ldk-node/releases/download/\(tag)/LDKNodeFFI.xcframework.zip"
 
 let package = Package(
diff --git a/bindings/kotlin/ldk-node-android/gradle.properties b/bindings/kotlin/ldk-node-android/gradle.properties
@@ -2,4 +2,4 @@ org.gradle.jvmargs=-Xmx1536m
 android.useAndroidX=true
 android.enableJetifier=true
 kotlin.code.style=official
-libraryVersion=0.7.0-rc.1
+libraryVersion=0.7.0-rc.2
diff --git a/bindings/kotlin/ldk-node-android/lib/src/main/jniLibs/arm64-v8a/libldk_node.so b/bindings/kotlin/ldk-node-android/lib/src/main/jniLibs/arm64-v8a/libldk_node.so
diff --git a/bindings/kotlin/ldk-node-android/lib/src/main/jniLibs/armeabi-v7a/libldk_node.so b/bindings/kotlin/ldk-node-android/lib/src/main/jniLibs/armeabi-v7a/libldk_node.so
diff --git a/bindings/kotlin/ldk-node-android/lib/src/main/jniLibs/x86_64/libldk_node.so b/bindings/kotlin/ldk-node-android/lib/src/main/jniLibs/x86_64/libldk_node.so
diff --git a/bindings/kotlin/ldk-node-android/lib/src/main/kotlin/org/lightningdevkit/ldknode/ldk_node.android.kt b/bindings/kotlin/ldk-node-android/lib/src/main/kotlin/org/lightningdevkit/ldknode/ldk_node.android.kt
@@ -1485,6 +1485,8 @@ internal typealias UniffiVTableCallbackInterfaceVssHeaderProviderUniffiByValue =
 
 
 
+
+
 
 
 
@@ -1979,6 +1981,11 @@ internal interface UniffiLib : Library {
         `config`: RustBufferByValue,
         uniffiCallStatus: UniffiRustCallStatus,
     ): Unit
+    fun uniffi_ldk_node_fn_method_builder_set_channel_data_migration(
+        `ptr`: Pointer?,
+        `migration`: RustBufferByValue,
+        uniffiCallStatus: UniffiRustCallStatus,
+    ): Unit
     fun uniffi_ldk_node_fn_method_builder_set_custom_logger(
         `ptr`: Pointer?,
         `logWriter`: Pointer?,
@@ -3015,6 +3022,8 @@ internal interface UniffiLib : Library {
     ): Short
     fun uniffi_ldk_node_checksum_method_builder_set_chain_source_esplora(
     ): Short
+    fun uniffi_ldk_node_checksum_method_builder_set_channel_data_migration(
+    ): Short
     fun uniffi_ldk_node_checksum_method_builder_set_custom_logger(
     ): Short
     fun uniffi_ldk_node_checksum_method_builder_set_entropy_bip39_mnemonic(
@@ -3478,6 +3487,9 @@ private fun uniffiCheckApiChecksums(lib: UniffiLib) {
     if (lib.uniffi_ldk_node_checksum_method_builder_set_chain_source_esplora() != 1781.toShort()) {
         throw RuntimeException("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     }
+    if (lib.uniffi_ldk_node_checksum_method_builder_set_channel_data_migration() != 58453.toShort()) {
+        throw RuntimeException("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
+    }
     if (lib.uniffi_ldk_node_checksum_method_builder_set_custom_logger() != 51232.toShort()) {
         throw RuntimeException("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     }
@@ -5668,6 +5680,18 @@ open class Builder: Disposable, BuilderInterface {
         }
     }
 
+    override fun `setChannelDataMigration`(`migration`: ChannelDataMigration) {
+        callWithPointer {
+            uniffiRustCall { uniffiRustCallStatus ->
+                UniffiLib.INSTANCE.uniffi_ldk_node_fn_method_builder_set_channel_data_migration(
+                    it,
+                    FfiConverterTypeChannelDataMigration.lower(`migration`),
+                    uniffiRustCallStatus,
+                )
+            }
+        }
+    }
+
     override fun `setCustomLogger`(`logWriter`: LogWriter) {
         callWithPointer {
             uniffiRustCall { uniffiRustCallStatus ->
@@ -8781,6 +8805,28 @@ object FfiConverterTypeChannelConfig: FfiConverterRustBuffer<ChannelConfig> {
 
 
 
+object FfiConverterTypeChannelDataMigration: FfiConverterRustBuffer<ChannelDataMigration> {
+    override fun read(buf: ByteBuffer): ChannelDataMigration {
+        return ChannelDataMigration(
+            FfiConverterOptionalSequenceUByte.read(buf),
+            FfiConverterSequenceSequenceUByte.read(buf),
+        )
+    }
+
+    override fun allocationSize(value: ChannelDataMigration) = (
+            FfiConverterOptionalSequenceUByte.allocationSize(value.`channelManager`) +
+            FfiConverterSequenceSequenceUByte.allocationSize(value.`channelMonitors`)
+    )
+
+    override fun write(value: ChannelDataMigration, buf: ByteBuffer) {
+        FfiConverterOptionalSequenceUByte.write(value.`channelManager`, buf)
+        FfiConverterSequenceSequenceUByte.write(value.`channelMonitors`, buf)
+    }
+}
+
+
+
+
 object FfiConverterTypeChannelDetails: FfiConverterRustBuffer<ChannelDetails> {
     override fun read(buf: ByteBuffer): ChannelDetails {
         return ChannelDetails(
diff --git a/bindings/kotlin/ldk-node-android/lib/src/main/kotlin/org/lightningdevkit/ldknode/ldk_node.common.kt b/bindings/kotlin/ldk-node-android/lib/src/main/kotlin/org/lightningdevkit/ldknode/ldk_node.common.kt
@@ -313,6 +313,8 @@ interface BuilderInterface {
     
     fun `setChainSourceEsplora`(`serverUrl`: kotlin.String, `config`: EsploraSyncConfig?)
     
+    fun `setChannelDataMigration`(`migration`: ChannelDataMigration)
+    
     fun `setCustomLogger`(`logWriter`: LogWriter)
     
     fun `setEntropyBip39Mnemonic`(`mnemonic`: Mnemonic, `passphrase`: kotlin.String?)
@@ -712,6 +714,16 @@ data class ChannelConfig (
 
 
 
+@kotlinx.serialization.Serializable
+data class ChannelDataMigration (
+    val `channelManager`: List<kotlin.UByte>?, 
+    val `channelMonitors`: List<List<kotlin.UByte>>
+) {
+    companion object
+}
+
+
+
 @kotlinx.serialization.Serializable
 data class ChannelDetails (
     val `channelId`: ChannelId, 
diff --git a/bindings/kotlin/ldk-node-jvm/gradle.properties b/bindings/kotlin/ldk-node-jvm/gradle.properties
@@ -1,3 +1,3 @@
 org.gradle.jvmargs=-Xmx1536m
 kotlin.code.style=official
-libraryVersion=0.7.0-rc.1
+libraryVersion=0.7.0-rc.2
diff --git a/bindings/ldk_node.udl b/bindings/ldk_node.udl
@@ -77,6 +77,11 @@ interface LogWriter {
 	void log(LogRecord record);
 };
 
+dictionary ChannelDataMigration {
+	sequence<u8>? channel_manager;
+	sequence<sequence<u8>> channel_monitors;
+};
+
 interface Builder {
 	constructor();
 	[Name=from_config]
@@ -85,6 +90,7 @@ interface Builder {
 	[Throws=BuildError]
 	void set_entropy_seed_bytes(sequence<u8> seed_bytes);
 	void set_entropy_bip39_mnemonic(Mnemonic mnemonic, string? passphrase);
+	void set_channel_data_migration(ChannelDataMigration migration);
 	void set_chain_source_esplora(string server_url, EsploraSyncConfig? config);
 	void set_chain_source_electrum(string server_url, ElectrumSyncConfig? config);
 	void set_chain_source_bitcoind_rpc(string rpc_host, u16 rpc_port, string rpc_user, string rpc_password);
diff --git a/bindings/python/pyproject.toml b/bindings/python/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "ldk_node"
-version = "0.7.0-rc.1"
+version = "0.7.0-rc.2"
 authors = [
   { name="Elias Rohrer", email="dev@tnull.de" },
 ]
diff --git a/bindings/python/src/ldk_node/ldk_node.py b/bindings/python/src/ldk_node/ldk_node.py
@@ -609,6 +609,8 @@ def _uniffi_check_api_checksums(lib):
         raise InternalError("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     if lib.uniffi_ldk_node_checksum_method_builder_set_chain_source_esplora() != 1781:
         raise InternalError("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
+    if lib.uniffi_ldk_node_checksum_method_builder_set_channel_data_migration() != 58453:
+        raise InternalError("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     if lib.uniffi_ldk_node_checksum_method_builder_set_custom_logger() != 51232:
         raise InternalError("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     if lib.uniffi_ldk_node_checksum_method_builder_set_entropy_bip39_mnemonic() != 827:
@@ -1500,6 +1502,12 @@ class _UniffiVTableCallbackInterfaceVssHeaderProvider(ctypes.Structure):
     ctypes.POINTER(_UniffiRustCallStatus),
 )
 _UniffiLib.uniffi_ldk_node_fn_method_builder_set_chain_source_esplora.restype = None
+_UniffiLib.uniffi_ldk_node_fn_method_builder_set_channel_data_migration.argtypes = (
+    ctypes.c_void_p,
+    _UniffiRustBuffer,
+    ctypes.POINTER(_UniffiRustCallStatus),
+)
+_UniffiLib.uniffi_ldk_node_fn_method_builder_set_channel_data_migration.restype = None
 _UniffiLib.uniffi_ldk_node_fn_method_builder_set_custom_logger.argtypes = (
     ctypes.c_void_p,
     ctypes.c_void_p,
@@ -2807,6 +2815,9 @@ class _UniffiVTableCallbackInterfaceVssHeaderProvider(ctypes.Structure):
 _UniffiLib.uniffi_ldk_node_checksum_method_builder_set_chain_source_esplora.argtypes = (
 )
 _UniffiLib.uniffi_ldk_node_checksum_method_builder_set_chain_source_esplora.restype = ctypes.c_uint16
+_UniffiLib.uniffi_ldk_node_checksum_method_builder_set_channel_data_migration.argtypes = (
+)
+_UniffiLib.uniffi_ldk_node_checksum_method_builder_set_channel_data_migration.restype = ctypes.c_uint16
 _UniffiLib.uniffi_ldk_node_checksum_method_builder_set_custom_logger.argtypes = (
 )
 _UniffiLib.uniffi_ldk_node_checksum_method_builder_set_custom_logger.restype = ctypes.c_uint16
@@ -4474,6 +4485,8 @@ def set_chain_source_electrum(self, server_url: "str",config: "typing.Optional[E
         raise NotImplementedError
     def set_chain_source_esplora(self, server_url: "str",config: "typing.Optional[EsploraSyncConfig]"):
         raise NotImplementedError
+    def set_channel_data_migration(self, migration: "ChannelDataMigration"):
+        raise NotImplementedError
     def set_custom_logger(self, log_writer: "LogWriter"):
         raise NotImplementedError
     def set_entropy_bip39_mnemonic(self, mnemonic: "Mnemonic",passphrase: "typing.Optional[str]"):
@@ -4710,6 +4723,17 @@ def set_chain_source_esplora(self, server_url: "str",config: "typing.Optional[Es
 
 
 
+    def set_channel_data_migration(self, migration: "ChannelDataMigration") -> None:
+        _UniffiConverterTypeChannelDataMigration.check_lower(migration)
+        
+        _uniffi_rust_call(_UniffiLib.uniffi_ldk_node_fn_method_builder_set_channel_data_migration,self._uniffi_clone_pointer(),
+        _UniffiConverterTypeChannelDataMigration.lower(migration))
+
+
+
+
+
+
     def set_custom_logger(self, log_writer: "LogWriter") -> None:
         _UniffiConverterTypeLogWriter.check_lower(log_writer)
         
@@ -7238,6 +7262,42 @@ def write(value, buf):
         _UniffiConverterBool.write(value.accept_underpaying_htlcs, buf)
 
 
+class ChannelDataMigration:
+    channel_manager: "typing.Optional[typing.List[int]]"
+    channel_monitors: "typing.List[typing.List[int]]"
+    def __init__(self, *, channel_manager: "typing.Optional[typing.List[int]]", channel_monitors: "typing.List[typing.List[int]]"):
+        self.channel_manager = channel_manager
+        self.channel_monitors = channel_monitors
+
+    def __str__(self):
+        return "ChannelDataMigration(channel_manager={}, channel_monitors={})".format(self.channel_manager, self.channel_monitors)
+
+    def __eq__(self, other):
+        if self.channel_manager != other.channel_manager:
+            return False
+        if self.channel_monitors != other.channel_monitors:
+            return False
+        return True
+
+class _UniffiConverterTypeChannelDataMigration(_UniffiConverterRustBuffer):
+    @staticmethod
+    def read(buf):
+        return ChannelDataMigration(
+            channel_manager=_UniffiConverterOptionalSequenceUInt8.read(buf),
+            channel_monitors=_UniffiConverterSequenceSequenceUInt8.read(buf),
+        )
+
+    @staticmethod
+    def check_lower(value):
+        _UniffiConverterOptionalSequenceUInt8.check_lower(value.channel_manager)
+        _UniffiConverterSequenceSequenceUInt8.check_lower(value.channel_monitors)
+
+    @staticmethod
+    def write(value, buf):
+        _UniffiConverterOptionalSequenceUInt8.write(value.channel_manager, buf)
+        _UniffiConverterSequenceSequenceUInt8.write(value.channel_monitors, buf)
+
+
 class ChannelDetails:
     channel_id: "ChannelId"
     counterparty_node_id: "PublicKey"
@@ -15848,6 +15908,7 @@ def generate_entropy_mnemonic(word_count: "typing.Optional[WordCount]") -> "Mnem
     "BalanceDetails",
     "BestBlock",
     "ChannelConfig",
+    "ChannelDataMigration",
     "ChannelDetails",
     "ChannelInfo",
     "ChannelUpdateInfo",
diff --git a/bindings/swift/Sources/LDKNode/LDKNode.swift b/bindings/swift/Sources/LDKNode/LDKNode.swift
@@ -1574,6 +1574,8 @@ public protocol BuilderProtocol: AnyObject {
 
     func setChainSourceEsplora(serverUrl: String, config: EsploraSyncConfig?)
 
+    func setChannelDataMigration(migration: ChannelDataMigration)
+
     func setCustomLogger(logWriter: LogWriter)
 
     func setEntropyBip39Mnemonic(mnemonic: Mnemonic, passphrase: String?)
@@ -1755,6 +1757,12 @@ open class Builder:
     }
     }
 
+    open func setChannelDataMigration(migration: ChannelDataMigration) { try! rustCall {
+        uniffi_ldk_node_fn_method_builder_set_channel_data_migration(self.uniffiClonePointer(),
+                                                                     FfiConverterTypeChannelDataMigration.lower(migration), $0)
+    }
+    }
+
     open func setCustomLogger(logWriter: LogWriter) { try! rustCall {
         uniffi_ldk_node_fn_method_builder_set_custom_logger(self.uniffiClonePointer(),
                                                             FfiConverterTypeLogWriter.lower(logWriter), $0)
@@ -4316,6 +4324,67 @@ public func FfiConverterTypeChannelConfig_lower(_ value: ChannelConfig) -> RustB
     return FfiConverterTypeChannelConfig.lower(value)
 }
 
+public struct ChannelDataMigration {
+    public var channelManager: [UInt8]?
+    public var channelMonitors: [[UInt8]]
+
+    // Default memberwise initializers are never public by default, so we
+    // declare one manually.
+    public init(channelManager: [UInt8]?, channelMonitors: [[UInt8]]) {
+        self.channelManager = channelManager
+        self.channelMonitors = channelMonitors
+    }
+}
+
+extension ChannelDataMigration: Equatable, Hashable {
+    public static func == (lhs: ChannelDataMigration, rhs: ChannelDataMigration) -> Bool {
+        if lhs.channelManager != rhs.channelManager {
+            return false
+        }
+        if lhs.channelMonitors != rhs.channelMonitors {
+            return false
+        }
+        return true
+    }
+
+    public func hash(into hasher: inout Hasher) {
+        hasher.combine(channelManager)
+        hasher.combine(channelMonitors)
+    }
+}
+
+#if swift(>=5.8)
+    @_documentation(visibility: private)
+#endif
+public struct FfiConverterTypeChannelDataMigration: FfiConverterRustBuffer {
+    public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> ChannelDataMigration {
+        return
+            try ChannelDataMigration(
+                channelManager: FfiConverterOptionSequenceUInt8.read(from: &buf),
+                channelMonitors: FfiConverterSequenceSequenceUInt8.read(from: &buf)
+            )
+    }
+
+    public static func write(_ value: ChannelDataMigration, into buf: inout [UInt8]) {
+        FfiConverterOptionSequenceUInt8.write(value.channelManager, into: &buf)
+        FfiConverterSequenceSequenceUInt8.write(value.channelMonitors, into: &buf)
+    }
+}
+
+#if swift(>=5.8)
+    @_documentation(visibility: private)
+#endif
+public func FfiConverterTypeChannelDataMigration_lift(_ buf: RustBuffer) throws -> ChannelDataMigration {
+    return try FfiConverterTypeChannelDataMigration.lift(buf)
+}
+
+#if swift(>=5.8)
+    @_documentation(visibility: private)
+#endif
+public func FfiConverterTypeChannelDataMigration_lower(_ value: ChannelDataMigration) -> RustBuffer {
+    return FfiConverterTypeChannelDataMigration.lower(value)
+}
+
 public struct ChannelDetails {
     public var channelId: ChannelId
     public var counterpartyNodeId: PublicKey
@@ -11856,6 +11925,9 @@ private var initializationResult: InitializationResult = {
     if uniffi_ldk_node_checksum_method_builder_set_chain_source_esplora() != 1781 {
         return InitializationResult.apiChecksumMismatch
     }
+    if uniffi_ldk_node_checksum_method_builder_set_channel_data_migration() != 58453 {
+        return InitializationResult.apiChecksumMismatch
+    }
     if uniffi_ldk_node_checksum_method_builder_set_custom_logger() != 51232 {
         return InitializationResult.apiChecksumMismatch
     }
diff --git a/src/builder.rs b/src/builder.rs
diff --git a/src/lib.rs b/src/lib.rs
