From d7ec799d3565adc0503dd2f5c42c3953cbdd1fb9 Mon Sep 17 00:00:00 2001
From: DanConwayDev <DanConwayDev@protonmail.com>
Date: Wed, 1 Nov 2023 00:00:00 +0000
Subject: build(test) fix running tests together

use a patched websocket server that releases port after x connections
enabling its use in many tests included in the same test run
---
 tests/prs_create.rs | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

(limited to 'tests')

diff --git a/tests/prs_create.rs b/tests/prs_create.rs
index 564ef16..42f83b4 100644
--- a/tests/prs_create.rs
+++ b/tests/prs_create.rs
@@ -204,6 +204,9 @@ mod sends_pr_and_2_patches_to_3_relays {
         let cli_tester_handle = std::thread::spawn(move || -> Result<()> {
             let mut p = cli_tester_create_pr(&git_repo);
             p.expect_end_eventually()?;
+            for p in [51, 52, 53] {
+                relay::shutdown_relay(8000 + p)?;
+            }
             Ok(())
         });
 
@@ -419,7 +422,6 @@ mod sends_pr_and_2_patches_to_3_relays {
             Ok(())
         }
     }
-
     mod cli_ouput {
         use super::*;
 
@@ -446,6 +448,9 @@ mod sends_pr_and_2_patches_to_3_relays {
                     3,
                 )?;
                 p.expect_end_with_whitespace()?;
+                for p in [51, 52, 53] {
+                    relay::shutdown_relay(8000 + p)?;
+                }
                 Ok(())
             });
 
@@ -493,6 +498,9 @@ mod sends_pr_and_2_patches_to_3_relays {
                 let cli_tester_handle = std::thread::spawn(move || -> Result<()> {
                     let mut p = cli_tester_create_pr(&git_repo);
                     p.expect_end_eventually()?;
+                    for p in [51, 52, 53] {
+                        relay::shutdown_relay(8000 + p)?;
+                    }
                     Ok(())
                 });
 
@@ -554,6 +562,10 @@ mod sends_pr_and_2_patches_to_3_relays {
                         3,
                     )?;
                     p.expect_end_with_whitespace()?;
+                    for p in [51, 52, 53] {
+                        relay::shutdown_relay(8000 + p)?;
+                    }
+
                     Ok(())
                 });
 
-- 
cgit v1.2.3