feat: tmp

crates/jstzd/tests/octez_client_test.rs

@@ -191,6 +191,18 @@ async fn activate_protocol() {
     ));
     assert!(response.contains("\"level\":1"));
     let _ = octez_node.kill().await;
+    // Wait for the process to shutdown entirely
+    let health_check_endpoint = format!("http://{}/health/ready", DEFAULT_RPC_ENDPOINT);
+    let node_destroyed = retry(10, 1000, || async {
+        let res = reqwest::get(&health_check_endpoint).await;
+        // Should get an error since the node should have been terminated
+        if let Err(e) = res {
+            return Ok(e.to_string().contains("Connection refused"));
+        }
+        Err(anyhow::anyhow!(""))
+    })
+    .await;
+    assert!(node_destroyed);
 }
 
 async fn spawn_octez_node() -> (octez_node::OctezNode, TempDir) {

crates/jstzd/tests/octez_node_test.rs

@@ -1,5 +1,6 @@
 use jstzd::task::{octez_node, Task};
 use serial_test::serial;
+mod utils;
 use utils::retry;
 
 #[tokio::test(flavor = "multi_thread")]