Add Impl for CloseChannel Api

Author: G8XSU

server/src/api/close_channel.rs

@@ -0,0 +1,26 @@
+use ldk_node::bitcoin::secp256k1::PublicKey;
+use ldk_node::{Node, UserChannelId};
+use protos::{CloseChannelRequest, CloseChannelResponse};
+use std::str::FromStr;
+use std::sync::Arc;
+
+pub(crate) const CLOSE_CHANNEL_PATH: &str = "CloseChannel";
+
+pub(crate) fn handle_close_channel_request(
+	node: Arc<Node>, request: CloseChannelRequest,
+) -> Result<CloseChannelResponse, ldk_node::NodeError> {
+	//TODO: Should this be string?
+	let mut user_channel_id_bytes = [0u8; 16];
+	user_channel_id_bytes.copy_from_slice(&request.user_channel_id);
+	let user_channel_id = UserChannelId(u128::from_be_bytes(user_channel_id_bytes));
+	let counterparty_node_id = PublicKey::from_str(&request.counterparty_node_id)
+		.map_err(|_| ldk_node::NodeError::InvalidPublicKey)?;
+
+	match request.force_close {
+		Some(true) => node.force_close_channel(&user_channel_id, counterparty_node_id)?,
+		_ => node.close_channel(&user_channel_id, counterparty_node_id)?,
+	};
+
+	let response = CloseChannelResponse {};
+	Ok(response)
+}

server/src/api/mod.rs

@@ -2,6 +2,7 @@ pub(crate) mod bolt11_receive;
 pub(crate) mod bolt11_send;
 pub(crate) mod bolt12_receive;
 pub(crate) mod bolt12_send;
+pub(crate) mod close_channel;
 pub(crate) mod onchain_receive;
 pub(crate) mod onchain_send;
 pub(crate) mod open_channel;

server/src/service.rs

@@ -11,20 +11,22 @@ use std::future::Future;
 use std::pin::Pin;
 use std::sync::Arc;
 
-use crate::api::onchain_receive::handle_onchain_receive_request;
-use crate::api::onchain_receive::ONCHAIN_RECEIVE_PATH;
-use crate::api::onchain_send::handle_onchain_send_request;
-use crate::api::onchain_send::ONCHAIN_SEND_PATH;
 use crate::api::bolt11_receive::handle_bolt11_receive_request;
 use crate::api::bolt11_receive::BOLT11_RECEIVE_PATH;
-use crate::api::open_channel::handle_open_channel;
-use crate::api::open_channel::OPEN_CHANNEL_PATH;
 use crate::api::bolt11_send::handle_bolt11_send_request;
 use crate::api::bolt11_send::BOLT11_SEND_PATH;
 use crate::api::bolt12_receive::handle_bolt12_receive_request;
 use crate::api::bolt12_receive::BOLT12_RECEIVE_PATH;
 use crate::api::bolt12_send::handle_bolt12_send_request;
 use crate::api::bolt12_send::BOLT12_SEND_PATH;
+use crate::api::close_channel::handle_close_channel_request;
+use crate::api::close_channel::CLOSE_CHANNEL_PATH;
+use crate::api::onchain_receive::handle_onchain_receive_request;
+use crate::api::onchain_receive::ONCHAIN_RECEIVE_PATH;
+use crate::api::onchain_send::handle_onchain_send_request;
+use crate::api::onchain_send::ONCHAIN_SEND_PATH;
+use crate::api::open_channel::handle_open_channel;
+use crate::api::open_channel::OPEN_CHANNEL_PATH;
 
 #[derive(Clone)]
 pub struct NodeService {
@@ -58,6 +60,7 @@ impl Service<Request<Incoming>> for NodeService {
 			},
 			BOLT12_SEND_PATH => Box::pin(handle_request(node, req, handle_bolt12_send_request)),
 			OPEN_CHANNEL_PATH => Box::pin(handle_request(node, req, handle_open_channel)),
+			CLOSE_CHANNEL_PATH => Box::pin(handle_request(node, req, handle_close_channel_request)),
 			path => {
 				let error = format!("Unknown request: {}", path).into_bytes();
 				Box::pin(async {