diff options
| -rw-r--r-- | src/bin/ngit/sub_commands/init.rs | 6 | ||||
| -rw-r--r-- | src/lib/client.rs | 40 | ||||
| -rw-r--r-- | src/lib/login/fresh.rs | 4 |
3 files changed, 25 insertions, 25 deletions
diff --git a/src/bin/ngit/sub_commands/init.rs b/src/bin/ngit/sub_commands/init.rs index 52e43e9..eaaf83d 100644 --- a/src/bin/ngit/sub_commands/init.rs +++ b/src/bin/ngit/sub_commands/init.rs | |||
| @@ -229,7 +229,7 @@ pub async fn launch(cli_args: &Cli, args: &SubCommandArgs) -> Result<()> { | |||
| 229 | .map(std::string::ToString::to_string) | 229 | .map(std::string::ToString::to_string) |
| 230 | .collect::<Vec<String>>() | 230 | .collect::<Vec<String>>() |
| 231 | } else { | 231 | } else { |
| 232 | client.get_fallback_relays().clone() | 232 | client.get_relay_default_set().clone() |
| 233 | } | 233 | } |
| 234 | } else { | 234 | } else { |
| 235 | args.relays.clone() | 235 | args.relays.clone() |
| @@ -252,7 +252,7 @@ pub async fn launch(cli_args: &Cli, args: &SubCommandArgs) -> Result<()> { | |||
| 252 | args.blossoms.clone() | 252 | args.blossoms.clone() |
| 253 | }; | 253 | }; |
| 254 | 254 | ||
| 255 | let fallback_grasp_servers = client.get_fallback_grasp_servers(); | 255 | let fallback_grasp_servers = client.get_grasp_default_set(); |
| 256 | 256 | ||
| 257 | let selected_grasp_servers = if has_server_and_relay_flags { | 257 | let selected_grasp_servers = if has_server_and_relay_flags { |
| 258 | // ignore so a script running `ngit init` can contiue without prompts | 258 | // ignore so a script running `ngit init` can contiue without prompts |
| @@ -456,7 +456,7 @@ pub async fn launch(cli_args: &Cli, args: &SubCommandArgs) -> Result<()> { | |||
| 456 | let mut selections: Vec<bool> = vec![true; options.len()]; | 456 | let mut selections: Vec<bool> = vec![true; options.len()]; |
| 457 | 457 | ||
| 458 | // add fallback relays as options | 458 | // add fallback relays as options |
| 459 | for relay in client.get_fallback_relays().clone() { | 459 | for relay in client.get_relay_default_set().clone() { |
| 460 | if !options.iter().any(|r| r.contains(&relay)) | 460 | if !options.iter().any(|r| r.contains(&relay)) |
| 461 | && !formatted_selected_grasp_servers | 461 | && !formatted_selected_grasp_servers |
| 462 | .iter() | 462 | .iter() |
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 { |
diff --git a/src/lib/login/fresh.rs b/src/lib/login/fresh.rs index a169177..358045a 100644 --- a/src/lib/login/fresh.rs +++ b/src/lib/login/fresh.rs | |||
| @@ -728,7 +728,7 @@ async fn signup( | |||
| 728 | EventBuilder::metadata(&Metadata::new().name(name)).sign_with_keys(&keys)?; | 728 | EventBuilder::metadata(&Metadata::new().name(name)).sign_with_keys(&keys)?; |
| 729 | let relay_list = EventBuilder::relay_list( | 729 | let relay_list = EventBuilder::relay_list( |
| 730 | client | 730 | client |
| 731 | .get_fallback_relays() | 731 | .get_relay_default_set() |
| 732 | .iter() | 732 | .iter() |
| 733 | .map(|s| (RelayUrl::parse(s).unwrap(), None)), | 733 | .map(|s| (RelayUrl::parse(s).unwrap(), None)), |
| 734 | ) | 734 | ) |
| @@ -738,7 +738,7 @@ async fn signup( | |||
| 738 | client, | 738 | client, |
| 739 | None, | 739 | None, |
| 740 | vec![profile, relay_list], | 740 | vec![profile, relay_list], |
| 741 | client.get_fallback_relays().clone(), | 741 | client.get_relay_default_set().clone(), |
| 742 | vec![], | 742 | vec![], |
| 743 | true, | 743 | true, |
| 744 | false, | 744 | false, |