feat(prs-create) send to repo relays

fetch repository reference events to identify repository relays

send pr events to repository relays alongside user relays

2 files changed, 48 insertions, 6 deletions

diff --git a/tests/claim.rs b/tests/claim.rs
index 914b12e..61be68b 100644
--- a/tests/claim.rs
+++ b/tests/claim.rs
@@ -17,8 +17,6 @@ mod sends_repoistory_to_relays {
 
     use super::*;
 
-    static REPOSITORY_KIND: u64 = 30017;
-
     fn prep_git_repo() -> Result<GitTestRepo> {
         let test_repo = GitTestRepo::default();
         test_repo.populate()?;
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<()> {