pool: remove RelayPoolNotification::Stop

* Remove all `start` and `stop` methods
* Fix shutdown notification sent to external channel on `Relay::terminate` method call

Signed-off-by: Yuki Kishimoto <[email protected]>

CHANGELOG.md

@@ -48,10 +48,14 @@
 ### Fixed
 
 * nostr: fix NIP-47 `list_transactions` response deserialization ([Yuki Kishimoto] and [lnbc1QWFyb24])
+* pool: fix shutdown notification sent to external channel on `Relay::terminate` method call ([Yuki Kishimoto])
 * js: fix "RuntimeError: memory access out of bounds" WASM error ([Yuki Kishimoto])
 
 ### Removed
 
+* pool: remove `RelayPoolNotification::Stop` ([Yuki Kishimoto])
+* Remove all `start` and `stop` methods ([Yuki Kishimoto])
+
 ## [v0.32.0]
 
 ### Summary

bindings/nostr-sdk-ffi/src/client/mod.rs

@@ -134,14 +134,6 @@ impl Client {
             .await
     }
 
-    pub async fn start(&self) {
-        self.inner.start().await
-    }
-
-    pub async fn stop(&self) -> Result<()> {
-        Ok(self.inner.stop().await?)
-    }
-
     pub async fn shutdown(&self) -> Result<()> {
         Ok(self.inner.clone().shutdown().await?)
     }

bindings/nostr-sdk-ffi/src/pool/mod.rs

@@ -45,21 +45,6 @@ impl RelayPool {
         }
     }
 
-    /// Start
-    ///
-    /// Internally call `connect` without wait for connection.
-    #[inline]
-    pub async fn start(&self) {
-        self.inner.start().await
-    }
-
-    /// Stop
-    ///
-    /// Call `connect` to re-start relays connections
-    pub async fn stop(&self) -> Result<()> {
-        Ok(self.inner.stop().await?)
-    }
-
     /// Completely shutdown pool
     pub async fn shutdown(&self) -> Result<()> {
         Ok(self.inner.clone().shutdown().await?)

bindings/nostr-sdk-ffi/src/relay/mod.rs

@@ -154,11 +154,6 @@ impl Relay {
         self.inner.connect(connection_timeout).await
     }
 
-    /// Disconnect from relay and set status to 'Stopped'
-    pub async fn stop(&self) -> Result<()> {
-        Ok(self.inner.stop().await?)
-    }
-
     /// Disconnect from relay and set status to 'Terminated'
     pub async fn terminate(&self) -> Result<()> {
         Ok(self.inner.terminate().await?)

bindings/nostr-sdk-js/src/pool/mod.rs

@@ -47,22 +47,6 @@ impl JsRelayPool {
         }
     }
 
-    /// Start
-    ///
-    /// Internally call `connect` without wait for connection.
-    #[wasm_bindgen]
-    pub async fn start(&self) {
-        self.inner.start().await
-    }
-
-    /// Stop
-    ///
-    /// Call `connect` or `start` to re-start relays connections
-    #[wasm_bindgen]
-    pub async fn stop(&self) -> Result<()> {
-        self.inner.stop().await.map_err(into_err)
-    }
-
     /// Completely shutdown pool
     #[wasm_bindgen]
     pub async fn shutdown(&self) -> Result<()> {

bindings/nostr-sdk-js/src/relay/mod.rs

@@ -133,11 +133,6 @@ impl JsRelay {
         self.inner.connect(connection_timeout.map(|d| *d)).await
     }
 
-    /// Disconnect from relay and set status to 'Stopped'
-    pub async fn stop(&self) -> Result<()> {
-        self.inner.stop().await.map_err(into_err)
-    }
-
     /// Disconnect from relay and set status to 'Terminated'
     pub async fn terminate(&self) -> Result<()> {
         self.inner.terminate().await.map_err(into_err)

crates/nostr-relay-pool/src/pool/internal.rs

@@ -65,17 +65,6 @@ impl InternalRelayPool {
         }
     }
 
-    pub async fn stop(&self) -> Result<(), Error> {
-        let relays = self.relays().await;
-        for relay in relays.values() {
-            relay.stop().await?;
-        }
-        if let Err(e) = self.notification_sender.send(RelayPoolNotification::Stop) {
-            tracing::error!("Impossible to send STOP notification: {e}");
-        }
-        Ok(())
-    }
-
     pub async fn shutdown(&self) -> Result<(), Error> {
         // Disconnect all relays
         self.disconnect().await?;

crates/nostr-relay-pool/src/pool/mod.rs

@@ -56,8 +56,6 @@ pub enum RelayPoolNotification {
         /// Relay Status
         status: RelayStatus,
     },
-    /// Stop
-    Stop,
     /// Shutdown
     Shutdown,
 }
@@ -101,22 +99,6 @@ impl RelayPool {
         }
     }
 
-    /// Start
-    ///
-    /// Internally call `connect` without wait for connection.
-    #[inline]
-    pub async fn start(&self) {
-        self.inner.connect(None).await
-    }
-
-    /// Stop
-    ///
-    /// Call `connect` to re-start relays connections
-    #[inline]
-    pub async fn stop(&self) -> Result<(), Error> {
-        self.inner.stop().await
-    }
-
     /// Completely shutdown pool
     #[inline]
     pub async fn shutdown(self) -> Result<(), Error> {
@@ -516,12 +498,11 @@ impl RelayPool {
     {
         let mut notifications = self.notifications();
         while let Ok(notification) = notifications.recv().await {
-            let stop: bool = RelayPoolNotification::Stop == notification;
             let shutdown: bool = RelayPoolNotification::Shutdown == notification;
             let exit: bool = func(notification)
                 .await
                 .map_err(|e| Error::Handler(e.to_string()))?;
-            if exit || stop || shutdown {
+            if exit || shutdown {
                 break;
             }
         }