use std::env;
use std::str::FromStr;
use nostr::nips::nip47::{
HoldInvoiceAcceptedNotification, NostrWalletConnectUri, NotificationType, PaymentNotification,
};
use nwc::prelude::*;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let log_level = env::var("RUST_LOG")
.unwrap_or_else(|_| "info,nwc=debug,nostr_relay_pool=debug".to_string());
tracing_subscriber::fmt()
.with_env_filter(log_level)
.with_target(true)
.with_line_number(true)
.init();
let uri_str = env::args()
.nth(1)
.or_else(|| env::var("NWC_URI").ok())
.ok_or("Please provide NWC URI as argument or set NWC_URI environment variable")?;
let uri =
NostrWalletConnectUri::from_str(&uri_str).map_err(|e| format!("Invalid NWC URI: {}", e))?;
println!("📡 Relay: {:?}", uri.relays);
println!("🔑 Wallet pubkey: {}", uri.public_key);
println!("🔗 Connecting to wallet service...");
let nwc = NostrWalletConnect::new(uri);
nwc.subscribe_to_notifications().await?;
println!("✅ NWC client started and listening for notifications...");
println!("📱 Wallet notifications will appear here in real-time");
println!("💡 Try making or receiving payments with your wallet");
println!("🛑 Press Ctrl+C to stop");
let mut notifications = nwc.notifications();
let shutdown = tokio::signal::ctrl_c();
tokio::pin!(shutdown);
tokio::select! {
_ = shutdown => {
println!("\n👋 Shutting down...");
}
_ = async move {
while let Some(result) = notifications.next().await {
let Ok(notification) = result else {
eprintln!("Error: {}", result.unwrap_err());
continue;
};
match notification.notification_type {
NotificationType::PaymentReceived => {
if let Ok(payment) = notification.to_pay_notification() {
println!("🟢 Payment Received!");
print_payment_details(&payment);
}
}
NotificationType::PaymentSent => {
if let Ok(payment) = notification.to_pay_notification() {
println!("🔴 Payment Sent!");
print_payment_details(&payment);
}
}
NotificationType::HoldInvoiceAccepted => {
if let Ok(hold_accepted) = notification.to_holdinvoice_accepted_notification() {
println!("🟡 Hold Invoice Accepted!");
print_holdinvoice_details(&hold_accepted);
}
}
}
}
} => {
println!("Notifications stream terminated");
}
}
nwc.unsubscribe_from_notifications().await?;
nwc.shutdown().await;
Ok(())
}
fn print_payment_details(payment: &PaymentNotification) {
println!(" 💰 Amount: {} msat", payment.amount);
if let Some(description) = &payment.description {
println!(" 📝 Description: {}", description);
}
println!(" 🔗 Payment Hash: {}", payment.payment_hash);
println!(" 📅 Settled At: {}", payment.settled_at);
if payment.fees_paid > 0 {
println!(" 💸 Fees: {} msat", payment.fees_paid);
}
println!();
}
fn print_holdinvoice_details(hold_accepted: &HoldInvoiceAcceptedNotification) {
println!(" 💰 Amount: {} msat", hold_accepted.amount);
if let Some(description) = &hold_accepted.description {
println!(" 📝 Description: {}", description);
}
println!(" 🔗 Payment Hash: {}", hold_accepted.payment_hash);
println!(
" 📅 Settle until blockheight: {}",
hold_accepted.settle_deadline
);
println!();
}