From 93c8743dc75528982d281ecd3348278845a802ca Mon Sep 17 00:00:00 2001
From: Awiteb <a@4rs.nl>
Date: Tue, 6 May 2025 12:15:12 +0000
Subject: [PATCH] chore: Add the relays for read and write

Signed-off-by: Awiteb <a@4rs.nl>
---
 src/cli/repo/announce.rs |  4 +++-
 src/cli/repo/view.rs     |  2 +-
 src/nostr_utils/mod.rs   | 18 +++++++-----------
 3 files changed, 11 insertions(+), 13 deletions(-)

diff --git a/src/cli/repo/announce.rs b/src/cli/repo/announce.rs
index 51b3d6d..fdf808e 100644
--- a/src/cli/repo/announce.rs
+++ b/src/cli/repo/announce.rs
@@ -72,6 +72,8 @@ impl CommandRunner for AnnounceArgs {
 
         let mut write_relays = options.relays.clone();
         let mut maintainers = vec![user_pubk];
+        write_relays.sort_unstable();
+        write_relays.dedup();
         maintainers.extend(self.maintainers);
 
         if let Some(event) = relays_list.clone() {
@@ -99,7 +101,7 @@ impl CommandRunner for AnnounceArgs {
 
 
         let result = client
-            .send_event_to(event, relays_list.as_ref(), write_relays)
+            .send_event_to(event, relays_list.as_ref(), &write_relays)
             .await?;
 
         for relay in &result.success {
diff --git a/src/cli/repo/view.rs b/src/cli/repo/view.rs
index b9db20d..24c2836 100644
--- a/src/cli/repo/view.rs
+++ b/src/cli/repo/view.rs
@@ -37,7 +37,7 @@ impl CommandRunner for ViewArgs {
     async fn run(self, options: CliOptions) -> N34Result<()> {
         let client = NostrClient::init(&options).await;
         if !self.naddr.relays.is_empty() {
-            client.add_read_relays(&self.naddr.relays).await;
+            client.add_relays(&self.naddr.relays).await;
         }
 
         let repo = client.fetch_repo(&self.naddr).await?;
diff --git a/src/nostr_utils/mod.rs b/src/nostr_utils/mod.rs
index 25fb521..93a2ae9 100644
--- a/src/nostr_utils/mod.rs
+++ b/src/nostr_utils/mod.rs
@@ -65,15 +65,15 @@ impl NostrClient {
                 .build(),
         );
 
-        client.add_read_relays(&options.relays).await;
+        client.add_relays(&options.relays).await;
         client
     }
 
-    /// Add read relays and connect to them
-    pub async fn add_read_relays(&self, relays: &[RelayUrl]) {
+    /// Add relays and connect to them
+    pub async fn add_relays(&self, relays: &[RelayUrl]) {
         for relay in relays {
             self.client
-                .add_read_relay(relay)
+                .add_relay(relay)
                 .await
                 .expect("It's a valid relay url");
             if let Err(err) = self.client.try_connect_relay(relay, CLIENT_TIMEOUT).await {
@@ -87,16 +87,12 @@ impl NostrClient {
         &self,
         event: UnsignedEvent,
         relays_list: Option<&Event>,
-        mut relays: Vec<RelayUrl>,
+        relays: &[RelayUrl],
     ) -> N34Result<Output<EventId>> {
-        relays.sort_unstable();
-        relays.dedup();
-        for relay in &relays {
-            let _ = self.client.add_write_relay(relay).await;
-        }
+        self.add_relays(relays).await;
 
         if let Some(event) = relays_list {
-            let _ = self.client.send_event_to(&relays, event).await;
+            let _ = self.client.send_event_to(relays, event).await;
         }
         self.client
             .send_event_to(relays, &event.sign(&self.client.signer().await?).await?)