wip

Author: jpraynaud

mithril-test-lab/mithril-end-to-end/src/devnet/runner.rs

@@ -124,9 +124,14 @@ impl Devnet {
             bootstrap_args.cardano_hard_fork_latest_era_at_epoch.to_string(),
         );
 
+        // TODO: temporary implementation
+        let dmq_node_binary =
+            PathBuf::from(r"/home/jp/Works/Cardano/Mithril/ouroboros-network/result/bin");
+        bootstrap_command.env("DMQ_NODE_BINARY", &dmq_node_binary);
+
         bootstrap_command
             .current_dir(&bootstrap_args.devnet_scripts_dir)
-            .stdout(Stdio::null())
+            //.stdout(Stdio::null())
             .kill_on_drop(true);
 
         info!("Bootstrapping the Devnet"; "script" => &bootstrap_script_path.display());
@@ -230,20 +235,43 @@ impl Devnet {
         let mut run_command = Command::new(&run_script_path);
         run_command.current_dir(&self.artifacts_dir).kill_on_drop(true);
 
-        info!("Starting the Devnet"; "script" => &run_script_path.display());
+        info!("Starting the Cardano devnet"; "script" => &run_script_path.display());
+
+        let status = run_command
+            .spawn()
+            .with_context(|| "Failed to start the Cardano devnet")?
+            .wait()
+            .await
+            .with_context(|| "Error while starting the Cardano devnet")?;
+        match status.code() {
+            Some(0) => Ok(()),
+            Some(code) => Err(anyhow!(RetryableDevnetError(format!(
+                "Run Cardano devnet exited with status code: {code}"
+            )))),
+            None => Err(anyhow!("Run Cardano devnet terminated by signal")),
+        }
+    }
+
+    pub async fn run_dmq(&self) -> StdResult<()> {
+        let run_script = "start-dmq.sh";
+        let run_script_path = self.artifacts_dir.join(run_script);
+        let mut run_command = Command::new(&run_script_path);
+        run_command.current_dir(&self.artifacts_dir).kill_on_drop(true);
+
+        info!("Starting the DMQ devnet"; "script" => &run_script_path.display());
 
         let status = run_command
             .spawn()
-            .with_context(|| "Failed to start the devnet")?
+            .with_context(|| "Failed to start the DMQ devnet")?
             .wait()
             .await
-            .with_context(|| "Error while starting the devnet")?;
+            .with_context(|| "Error while starting the DMQ devnet")?;
         match status.code() {
             Some(0) => Ok(()),
             Some(code) => Err(anyhow!(RetryableDevnetError(format!(
-                "Run devnet exited with status code: {code}"
+                "Run DMQ devnet exited with status code: {code}"
             )))),
-            None => Err(anyhow!("Run devnet terminated by signal")),
+            None => Err(anyhow!("Run DMQ devnet terminated by signal")),
         }
     }