simulator: Persist beacon logs

.github/workflows/test-suite.yml

@@ -295,8 +295,15 @@ jobs:
       with:
           channel: stable
           cache-target: release
+    - name: Create log dir
+      run: mkdir ${{ runner.temp }}/basic_simulator_logs
     - name: Run a basic beacon chain sim that starts from Bellatrix
-      run: cargo run --release --bin simulator basic-sim
+      run: cargo run --release --bin simulator basic-sim --log-dir ${{ runner.temp }}/basic_simulator_logs
+    - name: Upload logs
+      uses: actions/upload-artifact@v4
+      with:
+        name: basic_simulator_logs
+        path: ${{ runner.temp }}/basic_simulator_logs
   fallback-simulator-ubuntu:
     name: fallback-simulator-ubuntu
     needs: [check-labels]
@@ -309,8 +316,15 @@ jobs:
       with:
           channel: stable
           cache-target: release
+    - name: Create log dir
+      run: mkdir ${{ runner.temp }}/fallback_simulator_logs
     - name: Run a beacon chain sim which tests VC fallback behaviour
-      run: cargo run --release --bin simulator fallback-sim
+      run: cargo run --release --bin simulator fallback-sim --log-dir ${{ runner.temp }}/fallback_simulator_logs
+    - name: Upload logs
+      uses: actions/upload-artifact@v4
+      with:
+        name: fallback_simulator_logs
+        path: ${{ runner.temp }}/fallback_simulator_logs
   execution-engine-integration-ubuntu:
     name: execution-engine-integration-ubuntu
     needs: [check-labels]

testing/simulator/src/basic_sim.rs

@@ -11,6 +11,7 @@ use node_test_rig::{
 };
 use rayon::prelude::*;
 use std::cmp::max;
+use std::path::PathBuf;
 use std::sync::Arc;
 use std::time::Duration;
 
@@ -63,13 +64,15 @@ pub fn run_basic_sim(matches: &ArgMatches) -> Result<(), String> {
         .expect("missing debug-level");
 
     let continue_after_checks = matches.get_flag("continue-after-checks");
+    let log_dir = matches.get_one::<String>("log-dir").map(PathBuf::from);
 
     println!("Basic Simulator:");
     println!(" nodes: {}", node_count);
     println!(" proposer-nodes: {}", proposer_nodes);
     println!(" validators-per-node: {}", validators_per_node);
     println!(" speed-up-factor: {}", speed_up_factor);
     println!(" continue-after-checks: {}", continue_after_checks);
+    println!(" log-dir: {:?}", log_dir);
 
     // Generate the directories and keystores required for the validator clients.
     let validator_files = (0..node_count)
@@ -91,21 +94,21 @@ pub fn run_basic_sim(matches: &ArgMatches) -> Result<(), String> {
         env_builder,
         logger_config,
         stdout_logging_layer,
-        _file_logging_layer,
+        file_logging_layer,
         _sse_logging_layer_opt,
         _libp2p_discv5_layer,
     ) = tracing_common::construct_logger(
         LoggerConfig {
-            path: None,
+            path: log_dir,
             debug_level: tracing_common::parse_level(&log_level.clone()),
             logfile_debug_level: tracing_common::parse_level(&log_level.clone()),
             log_format: None,
             logfile_format: None,
             log_color: true,
-            logfile_color: true,
+            logfile_color: false,
             disable_log_timestamp: false,
-            max_log_size: 0,
-            max_log_number: 0,
+            max_log_size: 200,
+            max_log_number: 5,
             compression: false,
             is_restricted: true,
             sse_logging: false,
@@ -115,8 +118,19 @@ pub fn run_basic_sim(matches: &ArgMatches) -> Result<(), String> {
         EnvironmentBuilder::minimal(),
     );
 
+    let mut logging_layers = vec![stdout_logging_layer
+        .with_filter(logger_config.debug_level)
+        .boxed()];
+    if let Some(file_logging_layer) = file_logging_layer {
+        logging_layers.push(
+            file_logging_layer
+                .with_filter(logger_config.logfile_debug_level)
+                .boxed(),
+        );
+    }
+
     if let Err(e) = tracing_subscriber::registry()
-        .with(stdout_logging_layer.with_filter(logger_config.debug_level))
+        .with(logging_layers)
         .try_init()
     {
         eprintln!("Failed to initialize dependency logging: {e}");

testing/simulator/src/cli.rs

@@ -61,6 +61,12 @@ pub fn cli_app() -> Command {
                         .long("continue_after_checks")
                         .action(ArgAction::SetTrue)
                         .help("Continue after checks (default false)"),
+                )
+                .arg(
+                    Arg::new("log-dir")
+                        .long("log-dir")
+                        .action(ArgAction::Set)
+                        .help("Set a path for logs of beacon nodes that run in this simulation."),
                 ),
         )
         .subcommand(
@@ -120,6 +126,12 @@ pub fn cli_app() -> Command {
                         .long("continue_after_checks")
                         .action(ArgAction::SetTrue)
                         .help("Continue after checks (default false)"),
+                )
+                .arg(
+                    Arg::new("log-dir")
+                        .long("log-dir")
+                        .action(ArgAction::Set)
+                        .help("Set a path for logs of beacon nodes that run in this simulation."),
                 ),
         )
 }

testing/simulator/src/fallback_sim.rs

@@ -11,6 +11,7 @@ use node_test_rig::{
 };
 use rayon::prelude::*;
 use std::cmp::max;
+use std::path::PathBuf;
 use std::sync::Arc;
 use std::time::Duration;
 use tokio::time::sleep;
@@ -69,12 +70,15 @@ pub fn run_fallback_sim(matches: &ArgMatches) -> Result<(), String> {
 
     let continue_after_checks = matches.get_flag("continue-after-checks");
 
+    let log_dir = matches.get_one::<String>("log-dir").map(PathBuf::from);
+
     println!("Fallback Simulator:");
     println!(" vc-count: {}", vc_count);
     println!(" validators-per-vc: {}", validators_per_vc);
     println!(" bns-per-vc: {}", bns_per_vc);
     println!(" speed-up-factor: {}", speed_up_factor);
     println!(" continue-after-checks: {}", continue_after_checks);
+    println!(" log-dir: {:?}", log_dir);
 
     // Generate the directories and keystores required for the validator clients.
     let validator_files = (0..vc_count)
@@ -95,21 +99,21 @@ pub fn run_fallback_sim(matches: &ArgMatches) -> Result<(), String> {
         env_builder,
         logger_config,
         stdout_logging_layer,
-        _file_logging_layer,
+        file_logging_layer,
         _sse_logging_layer_opt,
         _libp2p_discv5_layer,
     ) = tracing_common::construct_logger(
         LoggerConfig {
-            path: None,
+            path: log_dir,
             debug_level: tracing_common::parse_level(&log_level.clone()),
             logfile_debug_level: tracing_common::parse_level(&log_level.clone()),
             log_format: None,
             logfile_format: None,
             log_color: true,
             logfile_color: false,
             disable_log_timestamp: false,
-            max_log_size: 0,
-            max_log_number: 0,
+            max_log_size: 200,
+            max_log_number: 5,
             compression: false,
             is_restricted: true,
             sse_logging: false,
@@ -119,8 +123,19 @@ pub fn run_fallback_sim(matches: &ArgMatches) -> Result<(), String> {
         EnvironmentBuilder::minimal(),
     );
 
+    let mut logging_layers = vec![stdout_logging_layer
+        .with_filter(logger_config.debug_level)
+        .boxed()];
+    if let Some(file_logging_layer) = file_logging_layer {
+        logging_layers.push(
+            file_logging_layer
+                .with_filter(logger_config.logfile_debug_level)
+                .boxed(),
+        );
+    }
+
     if let Err(e) = tracing_subscriber::registry()
-        .with(stdout_logging_layer.with_filter(logger_config.debug_level))
+        .with(logging_layers)
         .try_init()
     {
         eprintln!("Failed to initialize dependency logging: {e}");