add force close channel in the cli

Author: moisesPompilio

ldk-server-cli/src/main.rs

@@ -6,8 +6,9 @@ use ldk_server_client::error::LdkServerErrorCode::{
 };
 use ldk_server_client::ldk_server_protos::api::{
 	Bolt11ReceiveRequest, Bolt11SendRequest, Bolt12ReceiveRequest, Bolt12SendRequest,
-	CloseChannelRequest, GetBalancesRequest, GetNodeInfoRequest, ListChannelsRequest,
-	ListPaymentsRequest, OnchainReceiveRequest, OnchainSendRequest, OpenChannelRequest,
+	CloseChannelRequest, ForceCloseChannelRequest, GetBalancesRequest, GetNodeInfoRequest,
+	ListChannelsRequest, ListPaymentsRequest, OnchainReceiveRequest, OnchainSendRequest,
+	OpenChannelRequest,
 };
 use ldk_server_client::ldk_server_protos::types::{
 	bolt11_invoice_description, Bolt11InvoiceDescription, PageToken, Payment,
@@ -81,7 +82,14 @@ enum Commands {
 		#[arg(short, long)]
 		counterparty_node_id: String,
 	},
-	
+	ForceCloseChannel {
+		#[arg(short, long)]
+		user_channel_id: String,
+		#[arg(short, long)]
+		counterparty_node_id: String,
+		#[arg(long)]
+		force_close_reason: Option<String>,
+	},
 	OpenChannel {
 		#[arg(short, long)]
 		node_pubkey: String,
@@ -184,6 +192,21 @@ async fn main() {
 					.await,
 			);
 		},
+		Commands::ForceCloseChannel {
+			user_channel_id,
+			counterparty_node_id,
+			force_close_reason,
+		} => {
+			handle_response_result(
+				client
+					.force_close_channel(ForceCloseChannelRequest {
+						user_channel_id,
+						counterparty_node_id,
+						force_close_reason,
+					})
+					.await,
+			);
+		},
 		Commands::OpenChannel {
 			node_pubkey,
 			address,

ldk-server-client/src/client.rs

@@ -7,10 +7,11 @@ use crate::error::LdkServerErrorCode::{
 use ldk_server_protos::api::{
 	Bolt11ReceiveRequest, Bolt11ReceiveResponse, Bolt11SendRequest, Bolt11SendResponse,
 	Bolt12ReceiveRequest, Bolt12ReceiveResponse, Bolt12SendRequest, Bolt12SendResponse,
-	CloseChannelRequest, CloseChannelResponse, GetBalancesRequest, GetBalancesResponse,
-	GetNodeInfoRequest, GetNodeInfoResponse, ListChannelsRequest, ListChannelsResponse,
-	ListPaymentsRequest, ListPaymentsResponse, OnchainReceiveRequest, OnchainReceiveResponse,
-	OnchainSendRequest, OnchainSendResponse, OpenChannelRequest, OpenChannelResponse,
+	CloseChannelRequest, CloseChannelResponse, ForceCloseChannelRequest, ForceCloseChannelResponse,
+	GetBalancesRequest, GetBalancesResponse, GetNodeInfoRequest, GetNodeInfoResponse,
+	ListChannelsRequest, ListChannelsResponse, ListPaymentsRequest, ListPaymentsResponse,
+	OnchainReceiveRequest, OnchainReceiveResponse, OnchainSendRequest, OnchainSendResponse,
+	OpenChannelRequest, OpenChannelResponse,
 };
 use ldk_server_protos::error::{ErrorCode, ErrorResponse};
 use reqwest::header::CONTENT_TYPE;
@@ -28,6 +29,7 @@ const BOLT12_RECEIVE_PATH: &str = "Bolt12Receive";
 const BOLT12_SEND_PATH: &str = "Bolt12Send";
 const OPEN_CHANNEL_PATH: &str = "OpenChannel";
 const CLOSE_CHANNEL_PATH: &str = "CloseChannel";
+const FORCE_CLOSE_CHANNEL_PATH: &str = "ForceCloseChannel";
 const LIST_CHANNELS_PATH: &str = "ListChannels";
 const LIST_PAYMENTS_PATH: &str = "ListPayments";
 
@@ -134,6 +136,15 @@ impl LdkServerClient {
 		self.post_request(&request, &url).await
 	}
 
+	/// Force closes the channel specified by given request.
+	/// For API contract/usage, refer to docs for [`ForceCloseChannelRequest`] and [`ForceCloseChannelResponse`].
+	pub async fn force_close_channel(
+		&self, request: ForceCloseChannelRequest,
+	) -> Result<ForceCloseChannelResponse, LdkServerError> {
+		let url = format!("http://{}/{FORCE_CLOSE_CHANNEL_PATH}", self.base_url);
+		self.post_request(&request, &url).await
+	}
+
 	/// Retrieves list of known channels.
 	/// For API contract/usage, refer to docs for [`ListChannelsRequest`] and [`ListChannelsResponse`].
 	pub async fn list_channels(