fix: gets peer message when manual open channel fails

lib/android/src/main/java/com/reactnativeldk/LdkModule.kt

@@ -17,6 +17,8 @@ import org.ldk.structs.Result_Bolt11InvoiceParseOrSemanticErrorZ.Result_Bolt11In
 import org.ldk.structs.Result_Bolt11InvoiceSignOrCreationErrorZ.Result_Bolt11InvoiceSignOrCreationErrorZ_OK
 import org.ldk.structs.Result_C2Tuple_ThirtyTwoBytesChannelMonitorZDecodeErrorZ.Result_C2Tuple_ThirtyTwoBytesChannelMonitorZDecodeErrorZ_OK
 import org.ldk.structs.Result_C3Tuple_ThirtyTwoBytesRecipientOnionFieldsRouteParametersZNoneZ.Result_C3Tuple_ThirtyTwoBytesRecipientOnionFieldsRouteParametersZNoneZ_OK
+import org.ldk.structs.Result_ChannelIdAPIErrorZ.Result_ChannelIdAPIErrorZ_OK
+import org.ldk.structs.Result_NoneAPIErrorZ.Result_NoneAPIErrorZ_OK
 import org.ldk.structs.Result_NoneRetryableSendFailureZ.Result_NoneRetryableSendFailureZ_Err
 import org.ldk.structs.Result_PublicKeyNoneZ.Result_PublicKeyNoneZ_OK
 import org.ldk.structs.Result_StrSecp256k1ErrorZ.Result_StrSecp256k1ErrorZ_OK
@@ -772,6 +774,8 @@ class LdkModule(reactContext: ReactApplicationContext) : ReactContextBaseJavaMod
         channelManager ?: return handleReject(promise, LdkErrors.init_channel_manager)
         keysManager ?: return handleReject(promise, LdkErrors.init_keys_manager)
 
+        println("Creating channel with counterPartyNodeId: $counterPartyNodeId, channelValueSats: $channelValueSats, pushSats: $pushSats")
+
         val theirNetworkKey = counterPartyNodeId.hexa()
         val channelValueSatoshis = channelValueSats.toLong()
         val pushMsat = pushSats.toLong() * 1000
@@ -790,11 +794,39 @@ class LdkModule(reactContext: ReactApplicationContext) : ReactContextBaseJavaMod
             UserConfig.with_default()
         )
 
-        if (!res.is_ok) {
-            return handleReject(promise, LdkErrors.start_create_channel_fail)
+        if (res.is_ok) {
+            return promise.resolve((res as Result_ChannelIdAPIErrorZ_OK).res._a.hexEncodedString())
+        }
+
+        if ((res as Result_ChannelIdAPIErrorZ.Result_ChannelIdAPIErrorZ_Err).err is APIError.APIMisuseError) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error((res.err as APIError.APIMisuseError).err))
+        }
+
+        if (res.err is APIError.ChannelUnavailable) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error((res.err as APIError.ChannelUnavailable).err))
+        }
+
+        if (res.err is APIError.FeeRateTooHigh) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error((res.err as APIError.FeeRateTooHigh).err))
+        }
+
+        if (res.err is APIError.InvalidRoute) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error((res.err as APIError.InvalidRoute).err))
+        }
+
+        if (res.err is APIError.IncompatibleShutdownScript) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error("IncompatibleShutdownScript"))
+        }
+
+        if (res.err is APIError.MonitorUpdateInProgress) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error("MonitorUpdateInProgress"))
+        }
+
+        if (res.err is APIError.ChannelUnavailable) {
+            return handleReject(promise, LdkErrors.start_create_channel_fail, Error((res.err as APIError.ChannelUnavailable).err))
         }
 
-        handleResolve(promise, LdkCallbackResponses.start_create_channel_fail)
+        return handleReject(promise, LdkErrors.start_create_channel_fail)
     }
 
     @ReactMethod

lib/android/src/main/java/com/reactnativeldk/classes/LdkChannelManagerPersister.kt

@@ -162,6 +162,14 @@ class LdkChannelManagerPersister: ChannelManagerConstructor.EventHandler {
             }
             body.putString("reason", reasonString)
 
+            if (channelClosed.reason is ClosureReason.CounterpartyForceClosed) {
+                (channelClosed.reason as ClosureReason.CounterpartyForceClosed).peer_msg?.let {
+                    body.putString("peer_message", it.to_str())
+                }
+            }
+
+            println("Channel closed: ${channelClosed.channel_id._a.hexEncodedString()}")
+
             return LdkEventEmitter.send(EventTypes.channel_manager_channel_closed, body)
         }
 

lib/ios/Classes/LdkChannelManagerPersister.swift

@@ -9,7 +9,7 @@ import Foundation
 import LightningDevKit
 
 class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
-    //Custom function to manage any unlikely missing info from the event object
+    // Custom function to manage any unlikely missing info from the event object
     func handleEventError(_ event: Event) {
         LdkEventEmitter.shared.send(
             withEvent: .native_log,
@@ -25,14 +25,14 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
             guard let fundingGeneration = event.getValueAsFundingGenerationReady() else {
                 return handleEventError(event)
             }
-            
+
             LdkEventEmitter.shared.send(
                 withEvent: .channel_manager_funding_generation_ready,
                 body: [
                     "temp_channel_id": Data(fundingGeneration.getTemporaryChannelId().getA() ?? []).hexEncodedString(),
                     "output_script": Data(fundingGeneration.getOutputScript()).hexEncodedString(),
                     "user_channel_id": Data(fundingGeneration.getUserChannelId()).hexEncodedString(),
-                    "value_satoshis": fundingGeneration.getChannelValueSatoshis(),
+                    "value_satoshis": fundingGeneration.getChannelValueSatoshis()
                 ]
             )
             return
@@ -60,7 +60,7 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 body: body
             )
 
-            //Save to disk for TX history
+            // Save to disk for TX history
             persistPaymentClaimed(body)
             return
         case .PaymentSent:
@@ -82,11 +82,11 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 body: body
             )
 
-            //Save to disk for tx history
+            // Save to disk for tx history
             persistPaymentSent(body)
             return
         case .OpenChannelRequest:
-            //Use if we ever manually accept inbound channels. Setting in initConfig.
+            // Use if we ever manually accept inbound channels. Setting in initConfig.
             guard let openChannelRequest = event.getValueAsOpenChannelRequest() else {
                 return handleEventError(event)
             }
@@ -100,7 +100,7 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                     "requires_zero_conf": openChannelRequest.getChannelType().requiresZeroConf(),
                     "supports_zero_conf": openChannelRequest.getChannelType().supportsZeroConf(),
                     "requires_anchors_zero_fee_htlc_tx": openChannelRequest.getChannelType().requiresAnchorsZeroFeeHtlcTx()
-                ] as [String : Any]
+                ] as [String: Any]
             )
             return
         case .PaymentPathSuccessful:
@@ -116,8 +116,8 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 body: [
                     "payment_id": paymentId,
                     "payment_hash": paymentHash,
-                    "path_hops": paymentPathSuccessful.getPath().getHops().map { $0.asJson },
-                ] as [String : Any]
+                    "path_hops": paymentPathSuccessful.getPath().getHops().map { $0.asJson }
+                ] as [String: Any]
             )
             return
         case .PaymentPathFailed:
@@ -136,15 +136,15 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                     "payment_failed_permanently": paymentPathFailed.getPaymentFailedPermanently(),
                     "short_channel_id": String(paymentPathFailed.getShortChannelId() ?? 0),
                     "path_hops": paymentPathFailed.getPath().getHops().map { $0.asJson }
-                ] as [String : Any]
+                ] as [String: Any]
             )
 
             persistPaymentSent(
                 [
                     "payment_id": paymentId,
                     "payment_hash": paymentHash,
                     "unix_timestamp": Int(Date().timeIntervalSince1970),
-                    "state":  paymentPathFailed.getPaymentFailedPermanently() ? "failed" : "pending"
+                    "state": paymentPathFailed.getPaymentFailedPermanently() ? "failed" : "pending"
                 ]
             )
             return
@@ -160,23 +160,23 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 withEvent: .channel_manager_payment_failed,
                 body: [
                     "payment_id": paymentId,
-                    "payment_hash": paymentHash,
+                    "payment_hash": paymentHash
                 ]
             )
 
-            //MARK: Mark as failed
+            // MARK: Mark as failed
 
             persistPaymentSent(
                 [
                     "payment_id": paymentId,
                     "payment_hash": paymentHash,
                     "unix_timestamp": Int(Date().timeIntervalSince1970),
-                    "state":  "failed"
+                    "state": "failed"
                 ]
             )
             return
         case .PaymentForwarded:
-            //Unused on mobile
+            // Unused on mobile
             return
         case .PendingHTLCsForwardable:
             guard let pendingHtlcsForwardable = event.getValueAsPendingHtlcsForwardable() else {
@@ -186,7 +186,7 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
             LdkEventEmitter.shared.send(
                 withEvent: .channel_manager_pending_htlcs_forwardable,
                 body: [
-                    "time_forwardable": pendingHtlcsForwardable.getTimeForwardable(),
+                    "time_forwardable": pendingHtlcsForwardable.getTimeForwardable()
                 ]
             )
             return
@@ -198,7 +198,7 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
             LdkEventEmitter.shared.send(
                 withEvent: .channel_manager_spendable_outputs,
                 body: [
-                    "outputsSerialized": spendableOutputs.getOutputs().map { Data($0.write()).hexEncodedString() },
+                    "outputsSerialized": spendableOutputs.getOutputs().map { Data($0.write()).hexEncodedString() }
                 ]
             )
             return
@@ -208,13 +208,16 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
             }
 
             let reasonString: String
+            var peerMessage: String? = nil
+
             switch channelClosed.getReason().getValueType() {
             case .CommitmentTxConfirmed:
                 reasonString = "CommitmentTxConfirmed"
             case .CounterpartyCoopClosedUnfundedChannel:
                 reasonString = "CounterpartyCoopClosedUnfundedChannel"
             case .CounterpartyForceClosed:
                 reasonString = "CounterpartyForceClosed"
+                peerMessage = channelClosed.getReason().getValueAsCounterpartyForceClosed()?.getPeerMsg().getA()
             case .DisconnectedPeer:
                 reasonString = "DisconnectedPeer"
             case .FundingBatchClosure:
@@ -244,17 +247,18 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 body: [
                     "user_channel_id": Data(channelClosed.getUserChannelId()).hexEncodedString(),
                     "channel_id": Data(channelClosed.getChannelId().getA() ?? []).hexEncodedString(),
-                    "reason": reasonString
+                    "reason": reasonString,
+                    "peer_message": peerMessage
                 ]
             )
-            
+
             return
         case .DiscardFunding:
             guard let discardFunding = event.getValueAsDiscardFunding() else {
                 return handleEventError(event)
             }
 
-            //Wallet should probably "lock" the UTXOs spent in funding transactions until the funding transaction either confirms, or this event is generated.
+            // Wallet should probably "lock" the UTXOs spent in funding transactions until the funding transaction either confirms, or this event is generated.
             LdkEventEmitter.shared.send(
                 withEvent: .channel_manager_discard_funding,
                 body: [
@@ -287,7 +291,7 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 body: body
             )
 
-            //Save to disk for TX history
+            // Save to disk for TX history
             persistPaymentClaimed(body)
             return
         case .ChannelReady:
@@ -300,7 +304,7 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
             guard let bumpTransaction = event.getValueAsBumpTransaction() else {
                 return handleEventError(event)
             }
-            
+
             LdkEventEmitter.shared.send(withEvent: .native_log, body: "BumpTransaction request")
 
             if let channelClose = bumpTransaction.getValueAsChannelClose() {
@@ -309,11 +313,11 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                     "commitment_tx_fee": channelClose.getCommitmentTxFeeSatoshis(),
                     "pending_htlcs_count": channelClose.getPendingHtlcs().count
                 ]
-                
+
                 LdkEventEmitter.shared.send(withEvent: .lsp_log, body: body)
                 return
             }
-            
+
             LdkEventEmitter.shared.send(withEvent: .native_log, body: "BumpTransaction event not handled")
             return
         case .ProbeFailed:
@@ -413,23 +417,23 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 }
             }
 
-            //Replace entry if payment hash exists (Confirmed payment replacing pending)
+            // Replace entry if payment hash exists (Confirmed payment replacing pending)
             var paymentReplaced = false
             for (index, existingPayment) in payments.enumerated() {
                 if let existingPaymentHash = existingPayment["payment_hash"] as? String, let newPaymentHash = payment["payment_hash"] as? String {
                     if existingPaymentHash == newPaymentHash {
-                        //Don't replace a successful payment. If a 2nd wallet tries to pay an invoice the first successful one should not be overwritten.
+                        // Don't replace a successful payment. If a 2nd wallet tries to pay an invoice the first successful one should not be overwritten.
                         if existingPayment["state"] as? String == "successful" {
                             return
                         }
-                        
-                        payments[index] = mergeObj(payments[index], payment) //Merges update into orginal entry
+
+                        payments[index] = mergeObj(payments[index], payment) // Merges update into orginal entry
                         paymentReplaced = true
                     }
                 }
             }
 
-            //No existing payment found, append as new payment
+            // No existing payment found, append as new payment
             if !paymentReplaced {
                 payments.append(payment)
             }
@@ -472,18 +476,18 @@ class LdkChannelManagerPersister: Persister, ExtendedChannelManagerPersister {
                 }
             }
 
-            //Replace entry if payment hash exists (Confirmed payment replacing pending)
+            // Replace entry if payment hash exists (Confirmed payment replacing pending)
             var paymentReplaced = false
             for (index, existingPayment) in payments.enumerated() {
                 if let existingPaymentId = existingPayment["payment_id"] as? String, let newPaymentId = payment["payment_id"] as? String {
                     if existingPaymentId == newPaymentId {
-                        payments[index] = mergeObj(payments[index], payment) //Merges update into orginal entry
+                        payments[index] = mergeObj(payments[index], payment) // Merges update into orginal entry
                         paymentReplaced = true
                     }
                 }
             }
 
-            //No existing payment found, append as new payment
+            // No existing payment found, append as new payment
             if !paymentReplaced {
                 payments.append(payment)
             }

lib/ios/Ldk.swift

@@ -937,6 +937,25 @@ class Ldk: NSObject {
             return resolve(Data(res.getValue()?.getA() ?? []).hexEncodedString())
         }
 
+        if let error = res.getError() {
+            switch error.getValueType() {
+            case .APIMisuseError:
+                return handleReject(reject, .start_create_channel_fail, nil, error.getValueAsApiMisuseError()?.getErr())
+            case .ChannelUnavailable:
+                return handleReject(reject, .start_create_channel_fail, nil, error.getValueAsChannelUnavailable()?.getErr())
+            case .FeeRateTooHigh:
+                return handleReject(reject, .start_create_channel_fail, nil, error.getValueAsFeeRateTooHigh()?.getErr())
+            case .InvalidRoute:
+                return handleReject(reject, .start_create_channel_fail, nil, error.getValueAsInvalidRoute()?.getErr())
+            case .IncompatibleShutdownScript:
+                return handleReject(reject, .start_create_channel_fail, nil, "IncompatibleShutdownScript")
+            case .MonitorUpdateInProgress:
+                return handleReject(reject, .start_create_channel_fail, nil, "MonitorUpdateInProgress")
+            @unknown default:
+                handleReject(reject, .start_create_channel_fail, "Unhandled error")
+            }
+        }
+
         handleReject(reject, .start_create_channel_fail)
     }
 

lib/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@synonymdev/react-native-ldk",
   "title": "React Native LDK",
-  "version": "0.0.151",
+  "version": "0.0.152",
   "description": "React Native wrapper for LDK",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

lib/src/lightning-manager.ts

@@ -55,7 +55,7 @@
 	TCreatePaymentReq,
 	TBackupServerDetails,
 	IAddress,
 	TLspLogPayload,
 	TLspLogEvent,
 	TChannelMonitor,
 	TCreateChannelReq,
@@ -2183,7 +2183,7 @@
 	}
 
 	private onChannelManagerPendingHtlcsForwardable(
 		res: TChannelManagerPendingHtlcsForwardable,
 	): void {
 		ldk.processPendingHtlcForwards().catch(console.error);
 	}
@@ -2446,10 +2446,10 @@
 			return err(res.error);
 		}
 
 		return new Promise((resolve, reject) => {
 			// Channel funding ready event should be instant but if it fails and we don't get the event, we should reject.
 			const timeout = setTimeout(() => {
-				reject(err(new Error('Event not triggered within 5 seconds')));
+				resolve(err(new Error('Event not triggered within 5 seconds')));
 			}, 5000);
 
 			// Listen for the event for the channel funding details
@@ -2465,8 +2465,14 @@
 				EEventTypes.channel_manager_channel_closed,
 				(eventRes: TChannelManagerChannelClosed) => {
 					if (eventRes.channel_id === res.value) {
+
 						clearTimeout(timeout);
-						reject(err('Channel closed before funding'));
+						if (eventRes.peer_message) {
+							resolve(err(eventRes.peer_message));
+							return;
+						}
+
+						resolve(err(`Channel open failed: ${eventRes.reason}`));
 					}
 				},
 			);

lib/src/utils/types.ts

@@ -134,6 +134,7 @@ export type TChannelManagerChannelClosed = {
 	user_channel_id: string;
 	channel_id: string;
 	reason: string;
+	peer_message?: string;
 };
 
 export type TChannelManagerDiscardFunding = {