feat: add docker container log streaming (#314)

* add docker container log streaming

* add tokio feature

* log level management

Author: frisitano

.github/workflows/test.yaml

@@ -98,5 +98,5 @@ jobs:
             --success-output never \
             --verbose
         env:
-          RUST_LOG: debug
+          RUST_LOG: trace
           RUST_BACKTRACE: full

tests/Cargo.toml

@@ -13,7 +13,7 @@ alloy-network = { workspace = true }
 alloy-provider = { workspace = true, features = ["reqwest", "ws"] }
 alloy-rpc-types-eth = { workspace = true }
 scroll-alloy-network = { workspace = true }
-tokio = { workspace = true, features = ["rt", "time"] }
+tokio = { workspace = true, features = ["rt", "time", "process"] }
 eyre = { workspace = true }
 getrandom = { workspace = true }
 tracing = { workspace = true }

tests/docker-compose.test.yml

@@ -1,7 +1,6 @@
 services:
   l1-node:
     image: ghcr.io/foundry-rs/foundry:latest
-    container_name: l1-node
     entrypoint: [ "bash", "/launch_l1.bash" ]
     ports:
       - "8544:8545"
@@ -18,7 +17,6 @@ services:
     build:
       context: ../
       dockerfile: Dockerfile.test
-    container_name: rollup-node-sequencer
     entrypoint: ["bash", "/launch_rollup_node_sequencer.bash"]
     environment:
       - RUST_LOG=info
@@ -37,7 +35,6 @@ services:
     build:
       context: ../
       dockerfile: Dockerfile.test
-    container_name: rollup-node-follower
     entrypoint: ["bash", "/launch_rollup_node_follower.bash"]
     environment:
       - RUST_LOG=info
@@ -55,7 +52,6 @@ services:
   l2geth-sequencer:
     image: scrolltech/l2geth:scroll-v5.9.4
     platform: linux/amd64
-    container_name: l2geth-sequencer
     entrypoint: ["bash", "/launch_l2geth.bash"]
     ports:
       - "8547:8545"    # JSON-RPC
@@ -71,7 +67,6 @@ services:
   l2geth-follower:
     image: scrolltech/l2geth:scroll-v5.9.4
     platform: linux/amd64
-    container_name: l2geth-follower
     entrypoint: ["bash", "/launch_l2geth.bash"]
     ports:
       - "8548:8545"    # JSON-RPC

tests/src/docker_compose.rs

@@ -5,6 +5,10 @@ use std::{
     process::Command,
     time::{Duration, SystemTime, UNIX_EPOCH},
 };
+use tokio::{
+    io::{AsyncBufReadExt, BufReader},
+    process::Command as TokioCommand,
+};
 
 /// A wrapper that combines a provider with its human-readable name for testing
 pub struct NamedProvider {
@@ -53,6 +57,9 @@ impl DockerComposeEnv {
         // Start the environment
         let env = Self::start_environment(&compose_file, &project_name)?;
 
+        // Start streaming logs in the background
+        let _ = Self::stream_container_logs(&compose_file, &project_name).await;
+
         // Wait for all services to be ready
         tracing::info!("⏳ Waiting for services to be ready...");
         Self::wait_for_l2_node_ready(RN_SEQUENCER_RPC_URL, 30).await?;
@@ -208,6 +215,45 @@ impl DockerComposeEnv {
         );
     }
 
+    /// Stream logs from all containers in the background to the `docker-compose` target aat trace
+    /// level.
+    async fn stream_container_logs(compose_file: &str, project_name: &str) -> eyre::Result<()> {
+        let mut child = TokioCommand::new("docker")
+            .args([
+                "compose",
+                "-f",
+                compose_file,
+                "-p",
+                project_name,
+                "logs",
+                "-f",         // follow mode
+                "--no-color", // avoid ANSI mess
+            ])
+            .stdout(std::process::Stdio::piped())
+            .stderr(std::process::Stdio::piped())
+            .spawn()?;
+
+        if let Some(stdout) = child.stdout.take() {
+            let mut reader = BufReader::new(stdout).lines();
+            tokio::spawn(async move {
+                while let Ok(Some(line)) = reader.next_line().await {
+                    tracing::trace!(target: "docker-compose", "{}", line);
+                }
+            });
+        }
+
+        if let Some(stderr) = child.stderr.take() {
+            let mut reader = BufReader::new(stderr).lines();
+            tokio::spawn(async move {
+                while let Ok(Some(line)) = reader.next_line().await {
+                    tracing::trace!(target: "docker-compose", "{}", line);
+                }
+            });
+        }
+
+        Ok(())
+    }
+
     /// Show logs for all containers
     fn show_all_container_logs(compose_file: &str, project_name: &str) {
         tracing::info!("🔍 Getting all container logs...");