Merge pull request #718 from input-output-hk/testing-scenario-managin…

…g-test-flow

capture the standard error output from the running nodes

jormungandr-scenario-tests/Cargo.toml

@@ -8,7 +8,7 @@ edition = "2018"
 
 [dependencies]
 slog = "2"
-bawawa = "0.1.4"
+bawawa = "0.1.5"
 bytes = "0.4"
 error-chain = "0.12"
 tokio = "0.1"

jormungandr-scenario-tests/src/node.rs

@@ -209,6 +209,7 @@ impl Node {
             &config_file.display().to_string(),
             "--secret",
             &config_secret.display().to_string(),
+            "--log-level=warn",
         ]);
 
         match block0 {
@@ -239,6 +240,18 @@ impl Node {
         Ok(node)
     }
 
+    pub fn capture_logs(&mut self) -> impl Future<Item = (), Error = ()> {
+        let stderr = self.process.stderr().take().unwrap();
+
+        let stderr = tokio::codec::FramedRead::new(stderr, tokio::codec::LinesCodec::new());
+
+        let progress_bar = self.progress_bar.clone();
+
+        stderr
+            .for_each(move |line| future::ok(progress_bar.log_info(&line)))
+            .map_err(|err| unimplemented!("{}", err))
+    }
+
     fn progress_bar_start(&self) {
         self.progress_bar.set_style(
             indicatif::ProgressStyle::default_spinner()

jormungandr-scenario-tests/src/scenario/controller.rs

@@ -148,7 +148,7 @@ impl Controller {
         let pb = ProgressBar::new_spinner();
         let pb = self.progress_bar.add(pb);
 
-        let node = Node::spawn(
+        let mut node = Node::spawn(
             &self.context,
             pb,
             node_alias,
@@ -158,6 +158,7 @@ impl Controller {
         )?;
         let controller = node.controller();
 
+        self.runtime.executor().spawn(node.capture_logs());
         self.runtime.executor().spawn(node);
 
         Ok(controller)