test(p2p): run scenarios in sequence

... when running with `cargo test ...`

Author: akoptelov

node/testing/src/lib.rs

@@ -1,4 +1,7 @@
 mod exit_with_error;
+
+use std::sync::Arc;
+
 pub use exit_with_error::exit_with_error;
 
 pub mod cluster;
@@ -13,6 +16,7 @@ pub mod ocaml;
 
 mod server;
 pub use server::server;
+use tokio::sync::{Mutex, MutexGuard};
 
 pub fn setup() -> tokio::runtime::Runtime {
     // openmina_node_native::tracing::initialize(openmina_node_native::tracing::Level::DEBUG);
@@ -41,3 +45,22 @@ pub fn setup_without_rt() {
     };
     *INIT;
 }
+
+lazy_static::lazy_static! {
+    static ref GATE: Arc<Mutex<()>> = Arc::new(Mutex::new(()));
+}
+
+pub struct TestGate(MutexGuard<'static, ()>);
+
+impl TestGate {
+    async fn there_can_be_only_one() -> Self {
+        Self(GATE.lock().await)
+    }
+    pub fn release(self) {
+
+    }
+}
+
+pub async fn wait_for_other_tests() -> TestGate {
+    TestGate::there_can_be_only_one().await
+}

node/testing/tests/common.rs

@@ -16,9 +16,13 @@ macro_rules! scenario_test {
             use openmina_node_testing::{
                 cluster::{Cluster, ClusterConfig},
                 scenarios::ClusterRunner,
+                setup_without_rt, wait_for_other_tests,
             };
             use std::io::Write;
 
+            setup_without_rt();
+            let w = wait_for_other_tests().await;
+
             if let Some(summary) = std::env::var_os("GITHUB_STEP_SUMMARY") {
                 let _ = std::fs::File::options()
                     .append(true)
@@ -40,9 +44,9 @@ macro_rules! scenario_test {
                     if let Some((file, line)) = panic_info.location().map(|l| (l.file(), l.line()))
                     {
                         if let Some(message) = panic_info.payload().downcast_ref::<&str>() {
-                            eprintln!("\n::error file={file},line={line}::{message}");
+                            println!("\n::error file={file},line={line}::{message}");
                         } else {
-                            eprintln!("\n::error file={file},line={line}::panic without a message");
+                            println!("\n::error file={file},line={line}::panic without a message");
                         }
                     }
                     prev_panic_hook(panic_info);
@@ -61,6 +65,7 @@ macro_rules! scenario_test {
                     .open(&summary)
                     .and_then(|mut f| writeln!(f, "**PASSED** :white_check_mark:"));
             }
+            w.release();
         }
     };
 }