nwc: Add Monitor to NostrWalletConnectOptions

Author: unldenis

crates/nwc/CHANGELOG.md

@@ -28,6 +28,7 @@
 ### Added
 
 - Add notification support for real-time payment updates (https://github.com/rust-nostr/nostr/pull/953)
+- Add Monitor to NostrWalletConnectOptions (https://github.com/rust-nostr/nostr/pull/989)
 
 ## v0.42.0 - 2025/05/20
 

crates/nwc/examples/nwc.rs

@@ -20,7 +20,18 @@ async fn main() -> Result<()> {
     // Parse URI and compose NWC client
     let uri: NostrWalletConnectURI =
         NostrWalletConnectURI::from_str(&nwc_uri_string).expect("Failed to parse NWC URI");
-    let nwc: NWC = NWC::new(uri);
+
+    // Create monitor and subscribe to it
+    let monitor = Monitor::new(100);
+    let mut monitor_sub = monitor.subscribe();
+    tokio::spawn(async move {
+        while let Ok(notification) = monitor_sub.recv().await {
+            println!("Notification: {notification:?}");
+        }
+    });
+
+    // Create NWC client with monitor
+    let nwc: NWC = NWC::with_opts(uri, NostrWalletConnectOptions::default().monitor(monitor));
 
     // Get balance
     let balance = nwc.get_balance().await?;

crates/nwc/src/lib.rs

@@ -53,9 +53,14 @@ impl NWC {
 
     /// New `NWC` client with custom [`NostrWalletConnectOptions`].
     pub fn with_opts(uri: NostrWalletConnectURI, opts: NostrWalletConnectOptions) -> Self {
+        let pool = match opts.monitor.as_ref() {
+            Some(monitor) => RelayPool::builder().monitor(monitor.clone()).build(),
+            None => RelayPool::default(),
+        };
+
         Self {
             uri,
-            pool: RelayPool::default(),
+            pool,
             opts,
             bootstrapped: Arc::new(AtomicBool::new(false)),
             notifications_subscribed: Arc::new(AtomicBool::new(false)),

crates/nwc/src/options.rs

@@ -6,6 +6,7 @@
 
 use std::time::Duration;
 
+use nostr_relay_pool::monitor::Monitor;
 use nostr_relay_pool::{ConnectionMode, RelayOptions};
 
 /// Default timeout
@@ -16,13 +17,15 @@ pub const DEFAULT_TIMEOUT: Duration = Duration::from_secs(60);
 pub struct NostrWalletConnectOptions {
     pub(super) relay: RelayOptions,
     pub(super) timeout: Duration,
+    pub(super) monitor: Option<Monitor>,
 }
 
 impl Default for NostrWalletConnectOptions {
     fn default() -> Self {
         Self {
             relay: RelayOptions::default(),
             timeout: DEFAULT_TIMEOUT,
+            monitor: None,
         }
     }
 }
@@ -48,4 +51,11 @@ impl NostrWalletConnectOptions {
         self.timeout = timeout;
         self
     }
+
+    /// Set Relay Pool monitor
+    #[inline]
+    pub fn monitor(mut self, monitor: Monitor) -> Self {
+        self.monitor = Some(monitor);
+        self
+    }
 }