Merge pull request #6 from G8XSU/cli-base-setup

Author: G8XSU

Cargo.lock

@@ -4,3 +4,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+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,3 +1,143 @@
-fn main() {
-	println!("Hello, world!");
+use clap::{Parser, Subcommand};
+use client::client::LdkNodeServerClient;
+use client::error::LdkNodeServerError;
+use client::protos::{
+	Bolt11ReceiveRequest, Bolt11SendRequest, Bolt12ReceiveRequest, Bolt12SendRequest,
+	OnchainReceiveRequest, OnchainSendRequest, OpenChannelRequest,
+};
+
+#[derive(Parser, Debug)]
+#[command(version, about, long_about = None)]
+struct Cli {
+	#[arg(short, long, default_value = "localhost:3000")]
+	base_url: String,
+
+	#[command(subcommand)]
+	command: Commands,
+}
+
+#[derive(Subcommand, Debug)]
+enum Commands {
+	OnchainReceive,
+	OnchainSend {
+		#[arg(short, long)]
+		address: String,
+		#[arg(long)]
+		amount_sats: Option<u64>,
+		#[arg(long)]
+		send_all: Option<bool>,
+	},
+	Bolt11Receive {
+		#[arg(short, long)]
+		description: String,
+		#[arg(short, long)]
+		expiry_secs: u32,
+		#[arg(long)]
+		amount_msat: Option<u64>,
+	},
+	Bolt11Send {
+		#[arg(short, long)]
+		invoice: String,
+		#[arg(long)]
+		amount_msat: Option<u64>,
+	},
+	Bolt12Receive {
+		#[arg(short, long)]
+		description: String,
+		#[arg(long)]
+		amount_msat: Option<u64>,
+	},
+	Bolt12Send {
+		#[arg(short, long)]
+		offer: String,
+		#[arg(long)]
+		amount_msat: Option<u64>,
+		#[arg(short, long)]
+		quantity: Option<u64>,
+		#[arg(short, long)]
+		payer_note: Option<String>,
+	},
+	OpenChannel {
+		#[arg(short, long)]
+		node_pubkey: String,
+		#[arg(short, long)]
+		address: String,
+		#[arg(long)]
+		channel_amount_sats: u64,
+		#[arg(long)]
+		push_to_counterparty_msat: Option<u64>,
+		#[arg(long)]
+		announce_channel: bool,
+	},
+}
+
+#[tokio::main]
+async fn main() {
+	let cli = Cli::parse();
+	let client = LdkNodeServerClient::new(cli.base_url);
+
+	match cli.command {
+		Commands::OnchainReceive => {
+			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,
+			);
+		},
+		Commands::Bolt11Receive { description, expiry_secs, amount_msat } => {
+			handle_response(
+				client
+					.bolt11_receive(Bolt11ReceiveRequest { description, expiry_secs, amount_msat })
+					.await,
+			);
+		},
+		Commands::Bolt11Send { invoice, amount_msat } => {
+			handle_response(client.bolt11_send(Bolt11SendRequest { invoice, amount_msat }).await);
+		},
+		Commands::Bolt12Receive { description, amount_msat } => {
+			handle_response(
+				client.bolt12_receive(Bolt12ReceiveRequest { description, amount_msat }).await,
+			);
+		},
+		Commands::Bolt12Send { offer, amount_msat, quantity, payer_note } => {
+			handle_response(
+				client
+					.bolt12_send(Bolt12SendRequest { offer, amount_msat, quantity, payer_note })
+					.await,
+			);
+		},
+		Commands::OpenChannel {
+			node_pubkey,
+			address,
+			channel_amount_sats,
+			push_to_counterparty_msat,
+			announce_channel,
+		} => {
+			handle_response(
+				client
+					.open_channel(OpenChannelRequest {
+						node_pubkey,
+						address,
+						channel_amount_sats,
+						push_to_counterparty_msat,
+						channel_config: None,
+						announce_channel,
+					})
+					.await,
+			);
+		},
+	}
+}
+
+fn handle_response<Rs: ::prost::Message>(response: Result<Rs, LdkNodeServerError>) {
+	match response {
+		Ok(response) => {
+			println!("{:?}", response);
+		},
+		Err(e) => {
+			eprintln!("Error executing command: {:?}", e);
+			std::process::exit(1); // Exit with status code 1 on error.
+		},
+	};
 }

cli/src/main.rs

@@ -4,3 +4,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+protos = { path = "../protos" }
+reqwest = { version = "0.11.13", default-features = false, features = ["rustls-tls"] }
+tokio = { version = "1.38.0", default-features = false }
+prost = { version = "0.11.6", default-features = false, features = ["std", "prost-derive"] }