Add update channel config cli command

This was hooked up on the backend but not in the cli

Author: benthecarman

ldk-server-cli/src/main.rs

@@ -8,10 +8,10 @@ use ldk_server_client::ldk_server_protos::api::{
 	Bolt11ReceiveRequest, Bolt11SendRequest, Bolt12ReceiveRequest, Bolt12SendRequest,
 	CloseChannelRequest, ForceCloseChannelRequest, GetBalancesRequest, GetNodeInfoRequest,
 	ListChannelsRequest, ListPaymentsRequest, OnchainReceiveRequest, OnchainSendRequest,
-	OpenChannelRequest,
+	OpenChannelRequest, UpdateChannelConfigRequest,
 };
 use ldk_server_client::ldk_server_protos::types::{
-	bolt11_invoice_description, Bolt11InvoiceDescription, PageToken, Payment,
+	bolt11_invoice_description, Bolt11InvoiceDescription, ChannelConfig, PageToken, Payment,
 };
 use std::fmt::Debug;
 
@@ -110,6 +110,27 @@ enum Commands {
 		)]
 		number_of_payments: Option<u64>,
 	},
+	UpdateChannelConfig {
+		#[arg(short, long)]
+		user_channel_id: String,
+		#[arg(short, long)]
+		counterparty_node_id: String,
+		#[arg(
+			long,
+			help = "Amount (in millionths of a satoshi) charged per satoshi for payments forwarded outbound over the channel. This can be updated by using update-channel-config."
+		)]
+		forwarding_fee_proportional_millionths: Option<u32>,
+		#[arg(
+			long,
+			help = "Amount (in milli-satoshi) charged for payments forwarded outbound over the channel, in excess of forwarding_fee_proportional_millionths. This can be updated by using update-channel-config."
+		)]
+		forwarding_fee_base_msat: Option<u32>,
+		#[arg(
+			long,
+			help = "The difference in the CLTV value between incoming HTLCs and an outbound HTLC forwarded over the channel."
+		)]
+		cltv_expiry_delta: Option<u32>,
+	},
 }
 
 #[tokio::main]
@@ -233,6 +254,32 @@ async fn main() {
 		Commands::ListPayments { number_of_payments } => {
 			handle_response_result(list_n_payments(client, number_of_payments).await);
 		},
+		Commands::UpdateChannelConfig {
+			user_channel_id,
+			counterparty_node_id,
+			forwarding_fee_proportional_millionths,
+			forwarding_fee_base_msat,
+			cltv_expiry_delta,
+		} => {
+			let channel_config = ChannelConfig {
+				forwarding_fee_proportional_millionths,
+				forwarding_fee_base_msat,
+				cltv_expiry_delta,
+				force_close_avoidance_max_fee_satoshis: None,
+				accept_underpaying_htlcs: None,
+				max_dust_htlc_exposure: None,
+			};
+
+			handle_response_result(
+				client
+					.update_channel_config(UpdateChannelConfigRequest {
+						user_channel_id,
+						counterparty_node_id,
+						channel_config: Some(channel_config),
+					})
+					.await,
+			);
+		},
 	}
 }
 

ldk-server-client/src/client.rs

@@ -11,13 +11,14 @@ use ldk_server_protos::api::{
 	GetBalancesRequest, GetBalancesResponse, GetNodeInfoRequest, GetNodeInfoResponse,
 	ListChannelsRequest, ListChannelsResponse, ListPaymentsRequest, ListPaymentsResponse,
 	OnchainReceiveRequest, OnchainReceiveResponse, OnchainSendRequest, OnchainSendResponse,
-	OpenChannelRequest, OpenChannelResponse,
+	OpenChannelRequest, OpenChannelResponse, UpdateChannelConfigRequest,
+	UpdateChannelConfigResponse,
 };
 use ldk_server_protos::endpoints::{
 	BOLT11_RECEIVE_PATH, BOLT11_SEND_PATH, BOLT12_RECEIVE_PATH, BOLT12_SEND_PATH,
 	CLOSE_CHANNEL_PATH, FORCE_CLOSE_CHANNEL_PATH, GET_BALANCES_PATH, GET_NODE_INFO_PATH,
 	LIST_CHANNELS_PATH, LIST_PAYMENTS_PATH, ONCHAIN_RECEIVE_PATH, ONCHAIN_SEND_PATH,
-	OPEN_CHANNEL_PATH,
+	OPEN_CHANNEL_PATH, UPDATE_CHANNEL_CONFIG_PATH,
 };
 use ldk_server_protos::error::{ErrorCode, ErrorResponse};
 use reqwest::header::CONTENT_TYPE;
@@ -155,6 +156,15 @@ impl LdkServerClient {
 		self.post_request(&request, &url).await
 	}
 
+	/// Updates the config for a previously opened channel.
+	/// For API contract/usage, refer to docs for [`UpdateChannelConfigRequest`] and [`UpdateChannelConfigResponse`].
+	pub async fn update_channel_config(
+		&self, request: UpdateChannelConfigRequest,
+	) -> Result<UpdateChannelConfigResponse, LdkServerError> {
+		let url = format!("http://{}/{UPDATE_CHANNEL_CONFIG_PATH}", self.base_url);
+		self.post_request(&request, &url).await
+	}
+
 	async fn post_request<Rq: Message, Rs: Message + Default>(
 		&self, request: &Rq, url: &str,
 	) -> Result<Rs, LdkServerError> {