From c121c4675fbb97e9f091b7e420d520afdb73fafc Mon Sep 17 00:00:00 2001
From: Tommy Volk <tvolk131@gmail.com>
Date: Sun, 13 Oct 2024 16:40:12 +0200
Subject: [PATCH] refactor: NostrModule::get_state() takes self as arg

---
 src/nostr.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/nostr.rs b/src/nostr.rs
index d30a20f..638c963 100644
--- a/src/nostr.rs
+++ b/src/nostr.rs
@@ -46,7 +46,7 @@ impl NostrModule {
     pub fn subscription(&self) -> Subscription<NostrState> {
         const POLL_DURATION: Duration = Duration::from_millis(200);
 
-        let client = self.client.clone();
+        let self_clone = self.clone();
 
         Subscription::run_with_id(
             std::any::TypeId::of::<NostrState>(),
@@ -57,7 +57,7 @@ impl NostrModule {
             async_stream::stream! {
                 let mut last_state = NostrState::default();
                 loop {
-                    let new_state = Self::get_state(&client).await;
+                    let new_state = self_clone.get_state().await;
                     if new_state != last_state {
                         yield new_state.clone();
                         last_state = new_state;
@@ -72,10 +72,10 @@ impl NostrModule {
     /// Fetches the current state of the Nostr SDK client.
     /// Note: This is async because it's grabbing read locks
     /// on the relay `RwLock`s. No network requests are made.
-    async fn get_state(client: &nostr_sdk::Client) -> NostrState {
+    async fn get_state(&self) -> NostrState {
         let mut relay_connections = BTreeMap::new();
 
-        for (url, relay) in client.relays().await {
+        for (url, relay) in self.client.relays().await {
             relay_connections.insert(url.clone(), relay.status().await);
         }