From 57321aa9136293b24757a6695a5c92087af539ab Mon Sep 17 00:00:00 2001 From: DanConwayDev Date: Wed, 1 Nov 2023 00:00:00 +0000 Subject: feat(prs-create) send to repo relays fetch repository reference events to identify repository relays send pr events to repository relays alongside user relays --- tests/prs_create.rs | 52 ++++++++++++++++++++++++++++++++++++++++++++++++---- 1 file changed, 48 insertions(+), 4 deletions(-) (limited to 'tests/prs_create.rs') diff --git a/tests/prs_create.rs b/tests/prs_create.rs index 3a28016..3b8aa31 100644 --- a/tests/prs_create.rs +++ b/tests/prs_create.rs @@ -218,7 +218,18 @@ mod sends_pr_and_2_patches_to_3_relays { ), Relay::new(8052, None, None), Relay::new(8053, None, None), - Relay::new(8055, None, None), + Relay::new( + 8055, + None, + Some(&|relay, client_id, subscription_id, _| -> Result<()> { + relay.respond_events( + client_id, + &subscription_id, + &vec![generate_repo_ref_event()], + )?; + Ok(()) + }), + ), Relay::new(8056, None, None), ); @@ -521,7 +532,18 @@ mod sends_pr_and_2_patches_to_3_relays { ), Relay::new(8052, None, None), Relay::new(8053, None, None), - Relay::new(8055, None, None), + Relay::new( + 8055, + None, + Some(&|relay, client_id, subscription_id, _| -> Result<()> { + relay.respond_events( + client_id, + &subscription_id, + &vec![generate_repo_ref_event()], + )?; + Ok(()) + }), + ), Relay::new(8056, None, None), ); @@ -592,7 +614,18 @@ mod sends_pr_and_2_patches_to_3_relays { ), Relay::new(8052, None, None), Relay::new(8053, None, None), - Relay::new(8055, None, None), + Relay::new( + 8055, + None, + Some(&|relay, client_id, subscription_id, _| -> Result<()> { + relay.respond_events( + client_id, + &subscription_id, + &vec![generate_repo_ref_event()], + )?; + Ok(()) + }), + ), Relay::new( 8056, Some(&|relay, client_id, event| -> Result<()> { @@ -660,7 +693,18 @@ mod sends_pr_and_2_patches_to_3_relays { ), Relay::new(8052, None, None), Relay::new(8053, None, None), - Relay::new(8055, None, None), + Relay::new( + 8055, + None, + Some(&|relay, client_id, subscription_id, _| -> Result<()> { + relay.respond_events( + client_id, + &subscription_id, + &vec![generate_repo_ref_event()], + )?; + Ok(()) + }), + ), Relay::new( 8056, Some(&|relay, client_id, event| -> Result<()> { -- cgit v1.2.3