upleb.uk

Public git repos — served from a NIP-34 GRASP relay at git.upleb.uk

summaryrefslogtreecommitdiff
path: root/src/lib/client.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/lib/client.rs')
-rw-r--r--src/lib/client.rs40
1 files changed, 20 insertions, 20 deletions
diff --git a/src/lib/client.rs b/src/lib/client.rs
index 2bdea42..6f28cff 100644
--- a/src/lib/client.rs
+++ b/src/lib/client.rs
@@ -60,11 +60,11 @@ use crate::{
60#[allow(clippy::struct_field_names)] 60#[allow(clippy::struct_field_names)]
61pub struct Client { 61pub struct Client {
62 client: nostr_sdk::Client, 62 client: nostr_sdk::Client,
63 fallback_relays: Vec<String>, 63 relay_default_set: Vec<String>,
64 more_fallback_relays: Vec<String>, 64 more_fallback_relays: Vec<String>,
65 blaster_relays: Vec<String>, 65 blaster_relays: Vec<String>,
66 fallback_signer_relays: Vec<String>, 66 fallback_signer_relays: Vec<String>,
67 fallback_grasp_servers: Vec<String>, 67 grasp_default_set: Vec<String>,
68 relays_not_to_retry: Arc<RwLock<HashMap<RelayUrl, String>>>, 68 relays_not_to_retry: Arc<RwLock<HashMap<RelayUrl, String>>>,
69} 69}
70 70
@@ -98,11 +98,11 @@ pub trait Connect {
98 async fn set_signer(&mut self, signer: Arc<dyn NostrSigner>); 98 async fn set_signer(&mut self, signer: Arc<dyn NostrSigner>);
99 async fn connect(&self, relay_url: &RelayUrl) -> Result<()>; 99 async fn connect(&self, relay_url: &RelayUrl) -> Result<()>;
100 async fn disconnect(&self) -> Result<()>; 100 async fn disconnect(&self) -> Result<()>;
101 fn get_fallback_relays(&self) -> &Vec<String>; 101 fn get_relay_default_set(&self) -> &Vec<String>;
102 fn get_more_fallback_relays(&self) -> &Vec<String>; 102 fn get_more_fallback_relays(&self) -> &Vec<String>;
103 fn get_blaster_relays(&self) -> &Vec<String>; 103 fn get_blaster_relays(&self) -> &Vec<String>;
104 fn get_fallback_signer_relays(&self) -> &Vec<String>; 104 fn get_fallback_signer_relays(&self) -> &Vec<String>;
105 fn get_fallback_grasp_servers(&self) -> &Vec<String>; 105 fn get_grasp_default_set(&self) -> &Vec<String>;
106 async fn send_event_to<'a>( 106 async fn send_event_to<'a>(
107 &self, 107 &self,
108 git_repo_path: Option<&'a Path>, 108 git_repo_path: Option<&'a Path>,
@@ -152,11 +152,11 @@ impl Connect for Client {
152 .opts(Options::new().relay_limits(RelayLimits::disable())) 152 .opts(Options::new().relay_limits(RelayLimits::disable()))
153 .build() 153 .build()
154 }, 154 },
155 fallback_relays: opts.fallback_relays, 155 relay_default_set: opts.relay_default_set,
156 more_fallback_relays: opts.more_fallback_relays, 156 more_fallback_relays: opts.more_fallback_relays,
157 blaster_relays: opts.blaster_relays, 157 blaster_relays: opts.blaster_relays,
158 fallback_signer_relays: opts.fallback_signer_relays, 158 fallback_signer_relays: opts.fallback_signer_relays,
159 fallback_grasp_servers: opts.fallback_grasp_servers, 159 grasp_default_set: opts.grasp_default_set,
160 relays_not_to_retry: Arc::new(RwLock::new(HashMap::new())), 160 relays_not_to_retry: Arc::new(RwLock::new(HashMap::new())),
161 } 161 }
162 } 162 }
@@ -195,8 +195,8 @@ impl Connect for Client {
195 Ok(()) 195 Ok(())
196 } 196 }
197 197
198 fn get_fallback_relays(&self) -> &Vec<String> { 198 fn get_relay_default_set(&self) -> &Vec<String> {
199 &self.fallback_relays 199 &self.relay_default_set
200 } 200 }
201 201
202 fn get_more_fallback_relays(&self) -> &Vec<String> { 202 fn get_more_fallback_relays(&self) -> &Vec<String> {
@@ -211,8 +211,8 @@ impl Connect for Client {
211 &self.fallback_signer_relays 211 &self.fallback_signer_relays
212 } 212 }
213 213
214 fn get_fallback_grasp_servers(&self) -> &Vec<String> { 214 fn get_grasp_default_set(&self) -> &Vec<String> {
215 &self.fallback_grasp_servers 215 &self.grasp_default_set
216 } 216 }
217 217
218 async fn send_event_to<'a>( 218 async fn send_event_to<'a>(
@@ -345,8 +345,8 @@ impl Connect for Client {
345 trusted_maintainer_coordinate: Option<&'a Nip19Coordinate>, 345 trusted_maintainer_coordinate: Option<&'a Nip19Coordinate>,
346 user_profiles: &HashSet<PublicKey>, 346 user_profiles: &HashSet<PublicKey>,
347 ) -> Result<(Vec<Result<FetchReport>>, MultiProgress)> { 347 ) -> Result<(Vec<Result<FetchReport>>, MultiProgress)> {
348 let fallback_relays = &self 348 let relay_default_set = &self
349 .fallback_relays 349 .relay_default_set
350 .iter() 350 .iter()
351 .filter_map(|r| RelayUrl::parse(r).ok()) 351 .filter_map(|r| RelayUrl::parse(r).ok())
352 .collect::<HashSet<RelayUrl>>(); 352 .collect::<HashSet<RelayUrl>>();
@@ -355,7 +355,7 @@ impl Connect for Client {
355 git_repo_path, 355 git_repo_path,
356 trusted_maintainer_coordinate, 356 trusted_maintainer_coordinate,
357 user_profiles, 357 user_profiles,
358 fallback_relays.clone(), 358 relay_default_set.clone(),
359 ) 359 )
360 .await?; 360 .await?;
361 361
@@ -695,18 +695,18 @@ async fn get_events_of(
695 695
696pub struct Params { 696pub struct Params {
697 pub keys: Option<nostr::Keys>, 697 pub keys: Option<nostr::Keys>,
698 pub fallback_relays: Vec<String>, 698 pub relay_default_set: Vec<String>,
699 pub more_fallback_relays: Vec<String>, 699 pub more_fallback_relays: Vec<String>,
700 pub blaster_relays: Vec<String>, 700 pub blaster_relays: Vec<String>,
701 pub fallback_signer_relays: Vec<String>, 701 pub fallback_signer_relays: Vec<String>,
702 pub fallback_grasp_servers: Vec<String>, 702 pub grasp_default_set: Vec<String>,
703} 703}
704 704
705impl Default for Params { 705impl Default for Params {
706 fn default() -> Self { 706 fn default() -> Self {
707 Params { 707 Params {
708 keys: None, 708 keys: None,
709 fallback_relays: if std::env::var("NGITTEST").is_ok() { 709 relay_default_set: if std::env::var("NGITTEST").is_ok() {
710 vec![ 710 vec![
711 "ws://localhost:8051".to_string(), 711 "ws://localhost:8051".to_string(),
712 "ws://localhost:8052".to_string(), 712 "ws://localhost:8052".to_string(),
@@ -742,7 +742,7 @@ impl Default for Params {
742 } else { 742 } else {
743 vec!["wss://relay.nsec.app".to_string()] 743 vec!["wss://relay.nsec.app".to_string()]
744 }, 744 },
745 fallback_grasp_servers: if std::env::var("NGITTEST").is_ok() { 745 grasp_default_set: if std::env::var("NGITTEST").is_ok() {
746 vec![] 746 vec![]
747 } else { 747 } else {
748 vec!["relay.ngit.dev".to_string(), "gitnostr.com".to_string()] 748 vec!["relay.ngit.dev".to_string(), "gitnostr.com".to_string()]
@@ -765,7 +765,7 @@ impl Params {
765 .collect(); 765 .collect();
766 // elsewhere it is assumed this isn't empty 766 // elsewhere it is assumed this isn't empty
767 if !new_default_relays.is_empty() { 767 if !new_default_relays.is_empty() {
768 params.fallback_relays = new_default_relays; 768 params.relay_default_set = new_default_relays;
769 } 769 }
770 } 770 }
771 if let Ok(Some(relay_blasters)) = 771 if let Ok(Some(relay_blasters)) =
@@ -794,7 +794,7 @@ impl Params {
794 .filter_map(|url| normalize_grasp_server_url(url).ok()) // Attempt to parse and filter out errors 794 .filter_map(|url| normalize_grasp_server_url(url).ok()) // Attempt to parse and filter out errors
795 .collect(); 795 .collect();
796 if !new_default_grasp_servers.is_empty() { 796 if !new_default_grasp_servers.is_empty() {
797 params.fallback_grasp_servers = new_default_grasp_servers; 797 params.grasp_default_set = new_default_grasp_servers;
798 } 798 }
799 } 799 }
800 } 800 }
@@ -1995,7 +1995,7 @@ pub async fn send_events(
1995 silent: bool, 1995 silent: bool,
1996) -> Result<()> { 1996) -> Result<()> {
1997 let fallback = [ 1997 let fallback = [
1998 client.get_fallback_relays().clone(), 1998 client.get_relay_default_set().clone(),
1999 if events.iter().any(|e| e.kind.eq(&Kind::GitRepoAnnouncement)) { 1999 if events.iter().any(|e| e.kind.eq(&Kind::GitRepoAnnouncement)) {
2000 client.get_blaster_relays().clone() 2000 client.get_blaster_relays().clone()
2001 } else { 2001 } else {