diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-07-23 14:02:09 +0100 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-07-23 14:02:09 +0100 |
| commit | 055316ba3e50ffc3efb9be5f60afda669d74e548 (patch) | |
| tree | 20e34c6831dcf12866aa3a6d092d3e107ebec735 /src/lib/client.rs | |
| parent | dd5300b301292c3944aad4dcdecf4802307c7ea2 (diff) | |
refactor: Rename fallback relays and grasp servers
Rename `params.fallback_relays` and `client.fallback_relays` to
`relay_default_set`. Rename `params.fallback_grasp_servers` to
`grasp_default_set`. This includes updating associated getters and
usages across the codebase.
Diffstat (limited to 'src/lib/client.rs')
| -rw-r--r-- | src/lib/client.rs | 40 |
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)] |
| 61 | pub struct Client { | 61 | pub 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 | ||
| 696 | pub struct Params { | 696 | pub 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 | ||
| 705 | impl Default for Params { | 705 | impl 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 { |