feat(e2e-tests): assert state sync after invite-join

calimero-network · Dec 23, 2024 · 9ccc401 · 9ccc401
1 parent bb54d55
commit 9ccc401
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 4 deletions.
diff --git a/e2e-tests/config/scenarios/kv-store/test.json b/e2e-tests/config/scenarios/kv-store/test.json
@@ -23,6 +23,14 @@
     },
     {
       "contextInviteJoin": null
+    },
+    {
+      "jsonRpcCall": {
+        "methodName": "get",
+        "argsJson": { "key": "foo" },
+        "expectedResultJson": "bar",
+        "target": "allMembers"
+      }
     }
   ]
 }
diff --git a/e2e-tests/src/meroctl.rs b/e2e-tests/src/meroctl.rs
@@ -151,8 +151,10 @@ impl Meroctl {
 
         root_args.extend(args);
 
+        let args_str = root_args.join(" ");
+
         self.output_writer
-            .write_string(format!("Command: '{:}' {:?}", &self.binary, root_args));
+            .write_string(format!("Command: '{:} {:?}'", &self.binary, args_str));
 
         let output = Command::new(&self.binary)
             .args(root_args)

diff --git a/e2e-tests/src/merod.rs b/e2e-tests/src/merod.rs
@@ -92,12 +92,13 @@ impl Merod {
 
         root_args.extend(args);
 
-        let log_file = self.log_dir.join(format!("{}.log", log_suffix));
-        let mut log_file = File::create(&log_file).await?;
+        let args_str = root_args.join(" ");
 
         self.output_writer
-            .write_string(format!("Command: '{:}' {:?}", &self.binary, root_args));
+            .write_string(format!("Command: '{:} {:?}'", &self.binary, args_str));
 
+        let log_file = self.log_dir.join(format!("{}.log", log_suffix));
+        let mut log_file = File::create(&log_file).await?;
         let mut child = Command::new(&self.binary)
             .args(root_args)
             .stdout(Stdio::piped())

diff --git a/e2e-tests/src/steps/context_invite_join.rs b/e2e-tests/src/steps/context_invite_join.rs
@@ -1,5 +1,8 @@
+use std::time::Duration;
+
 use eyre::{bail, Result as EyreResult};
 use serde::{Deserialize, Serialize};
+use tokio::time::sleep;
 
 use crate::driver::{Test, TestContext};
 
@@ -57,6 +60,8 @@ impl Test for InviteJoinContextStep {
                     .insert(invitee.clone(), invitee_public_key),
             );
 
+            sleep(Duration::from_secs(40)).await;
+
             ctx.output_writer
                 .write_string(format!("Report: Node '{}' joined the context", invitee));
         }