Add Cli command for OnchainSend

Author: G8XSU

Cargo.lock

@@ -7,3 +7,4 @@ edition = "2021"
 client = { path = "../client" }
 clap = { version = "4.0.5", default-features = false, features = ["derive", "std"] }
 tokio = { version = "1.38.0", default-features = false, features = ["rt-multi-thread", "macros"] }
+prost = { version = "0.11.6", default-features = false}

cli/Cargo.toml

@@ -1,6 +1,7 @@
 use clap::{Parser, Subcommand};
 use client::client::LdkNodeServerClient;
-use client::protos::OnchainReceiveRequest;
+use client::error::LdkNodeServerError;
+use client::protos::{OnchainReceiveRequest, OnchainSendRequest};
 
 #[derive(Parser, Debug)]
 #[command(version, about, long_about = None)]
@@ -15,6 +16,14 @@ struct Cli {
 #[derive(Subcommand, Debug)]
 enum Commands {
 	OnchainReceive,
+	OnchainSend {
+		#[arg(short, long)]
+		address: String,
+		#[arg(long)]
+		amount_sats: Option<u64>,
+		#[arg(long)]
+		send_all: Option<bool>,
+	},
 }
 
 #[tokio::main]
@@ -24,14 +33,23 @@ async fn main() {
 
 	match cli.command {
 		Commands::OnchainReceive => {
-			match client.onchain_receive(OnchainReceiveRequest {}).await {
-				Ok(response) => {
-					println!("New Bitcoin Address: {:?}", response);
-				},
-				Err(e) => {
-					eprintln!("Error in OnchainReceive: {:?}", e);
-				},
-			};
+			handle_response(client.onchain_receive(OnchainReceiveRequest {}).await);
+		},
+		Commands::OnchainSend { address, amount_sats, send_all } => {
+			handle_response(
+				client.onchain_send(OnchainSendRequest { address, amount_sats, send_all }).await,
+			);
 		},
 	}
 }
+
+fn handle_response<Rs: ::prost::Message>(response: Result<Rs, LdkNodeServerError>) {
+	match response {
+		Ok(response) => {
+			println!("{:?}", response);
+		},
+		Err(e) => {
+			eprintln!("Error executing command: {:?}", e);
+		},
+	};
+}