upleb.uk

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

summaryrefslogtreecommitdiff
path: root/tests/send.rs
diff options
context:
space:
mode:
authorDanConwayDev <DanConwayDev@protonmail.com>2024-02-14 13:47:11 +0000
committerDanConwayDev <DanConwayDev@protonmail.com>2024-02-14 13:47:11 +0000
commita1d67c50c8ebc5395b069e30b60d66e0c7de5a5a (patch)
tree0895e4cfab98e7c7bbf45ddbac2e7af2c51935e6 /tests/send.rs
parentfed60687b2438b6bd19ee8f5c854ddc53cad0c9b (diff)
feat: send to default relays, blast repo event
improve the distribution of events by sending to default relays in addition to user and repo relays. for better discoverability of repo events, this is also blasted. a temporary fix to blast everything was removed. the less reliable purplepages.es relay is moved to more_fallback_relays that currently isn't used
Diffstat (limited to 'tests/send.rs')
-rw-r--r--tests/send.rs14
1 files changed, 10 insertions, 4 deletions
diff --git a/tests/send.rs b/tests/send.rs
index a109918..b202d54 100644
--- a/tests/send.rs
+++ b/tests/send.rs
@@ -309,12 +309,12 @@ mod sends_cover_letter_and_2_patches_to_3_relays {
309 309
310 #[tokio::test] 310 #[tokio::test]
311 #[serial] 311 #[serial]
312 async fn pr_not_sent_to_fallback_relay() -> Result<()> { 312 async fn only_1_pr_kind_event_sent_to_fallback_relays() -> Result<()> {
313 let (r51, r52, _, _, _) = prep_run_create_pr(true).await?; 313 let (r51, r52, _, _, _) = prep_run_create_pr(true).await?;
314 for relay in [&r51, &r52] { 314 for relay in [&r51, &r52] {
315 assert_eq!( 315 assert_eq!(
316 relay.events.iter().filter(|e| is_cover_letter(e)).count(), 316 relay.events.iter().filter(|e| is_cover_letter(e)).count(),
317 0, 317 1,
318 ); 318 );
319 } 319 }
320 Ok(()) 320 Ok(())
@@ -323,8 +323,8 @@ mod sends_cover_letter_and_2_patches_to_3_relays {
323 #[tokio::test] 323 #[tokio::test]
324 #[serial] 324 #[serial]
325 async fn only_2_patch_kind_events_sent_to_each_relay() -> Result<()> { 325 async fn only_2_patch_kind_events_sent_to_each_relay() -> Result<()> {
326 let (_, _, r53, r55, r56) = prep_run_create_pr(true).await?; 326 let (r51, r52, r53, r55, r56) = prep_run_create_pr(true).await?;
327 for relay in [&r53, &r55, &r56] { 327 for relay in [&r51, &r52, &r53, &r55, &r56] {
328 assert_eq!(relay.events.iter().filter(|e| is_patch(e)).count(), 2,); 328 assert_eq!(relay.events.iter().filter(|e| is_patch(e)).count(), 2,);
329 } 329 }
330 Ok(()) 330 Ok(())
@@ -757,6 +757,8 @@ mod sends_cover_letter_and_2_patches_to_3_relays {
757 (" [my-relay] [repo-relay] ws://localhost:8055", true, ""), 757 (" [my-relay] [repo-relay] ws://localhost:8055", true, ""),
758 (" [my-relay] ws://localhost:8053", true, ""), 758 (" [my-relay] ws://localhost:8053", true, ""),
759 (" [repo-relay] ws://localhost:8056", true, ""), 759 (" [repo-relay] ws://localhost:8056", true, ""),
760 (" [default] ws://localhost:8051", true, ""),
761 (" [default] ws://localhost:8052", true, ""),
760 ], 762 ],
761 3, 763 3,
762 )?; 764 )?;
@@ -930,6 +932,8 @@ mod sends_cover_letter_and_2_patches_to_3_relays {
930 false, 932 false,
931 "error: Payment Required", 933 "error: Payment Required",
932 ), 934 ),
935 (" [default] ws://localhost:8051", true, ""),
936 (" [default] ws://localhost:8052", true, ""),
933 ], 937 ],
934 3, 938 3,
935 )?; 939 )?;
@@ -1016,6 +1020,8 @@ mod sends_2_patches_without_cover_letter {
1016 (" [my-relay] [repo-relay] ws://localhost:8055", true, ""), 1020 (" [my-relay] [repo-relay] ws://localhost:8055", true, ""),
1017 (" [my-relay] ws://localhost:8053", true, ""), 1021 (" [my-relay] ws://localhost:8053", true, ""),
1018 (" [repo-relay] ws://localhost:8056", true, ""), 1022 (" [repo-relay] ws://localhost:8056", true, ""),
1023 (" [default] ws://localhost:8051", true, ""),
1024 (" [default] ws://localhost:8052", true, ""),
1019 ], 1025 ],
1020 2, 1026 2,
1021 )?; 1027 )?;