diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2024-02-14 13:47:11 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2024-02-14 13:47:11 +0000 |
| commit | a1d67c50c8ebc5395b069e30b60d66e0c7de5a5a (patch) | |
| tree | 0895e4cfab98e7c7bbf45ddbac2e7af2c51935e6 /tests/send.rs | |
| parent | fed60687b2438b6bd19ee8f5c854ddc53cad0c9b (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.rs | 14 |
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 | )?; |