feat(l1): ethrex_replay add tooling for periodic replay runs

Cargo.toml

@@ -31,6 +31,7 @@ members = [
   "tooling/load_test",
   "tooling/loc",
   "tooling/archive_sync",
+  "tooling/replayer",
   "crates/common/config",
 ]
 resolver = "2"

cmd/ethrex_replay/Cargo.toml

@@ -30,6 +30,7 @@ eyre.workspace = true
 tokio = { version = "1.21", default-features = false, features = ["full"] }
 clap.workspace = true
 charming = { version = "0.4.0", features = ["ssr"] }
+futures.workspace = true
 
 jemallocator = { version = "0.5.4", optional = true }
 

cmd/ethrex_replay/src/cli.rs

@@ -15,7 +15,6 @@ use crate::{bench::run_and_measure, fetcher::get_batchdata};
 use ethrex_config::networks::Network;
 
 pub const VERSION_STRING: &str = env!("CARGO_PKG_VERSION");
-pub const BINARY_NAME: &str = env!("CARGO_BIN_NAME");
 
 #[cfg(feature = "sp1")]
 const BACKEND: Backend = Backend::SP1;
@@ -25,14 +24,14 @@ const BACKEND: Backend = Backend::RISC0;
 const BACKEND: Backend = Backend::Exec;
 
 #[derive(Parser)]
-#[command(name=BINARY_NAME, author, version=VERSION_STRING, about, long_about = None)]
+#[command(name="ethrex-replay", author, version=VERSION_STRING, about, long_about = None)]
 pub struct EthrexReplayCLI {
     #[command(subcommand)]
     command: EthrexReplayCommand,
 }
 
 #[derive(Subcommand)]
-enum SubcommandExecute {
+pub enum SubcommandExecute {
     #[command(about = "Execute a single block.")]
     Block {
         #[arg(help = "Block to use. Uses the latest if not specified.")]
@@ -198,13 +197,13 @@ impl SubcommandExecute {
 }
 
 #[derive(Subcommand)]
-enum SubcommandProve {
+pub enum SubcommandProve {
     #[command(about = "Proves a single block.")]
     Block {
         #[arg(help = "Block to use. Uses the latest if not specified.")]
         block: Option<usize>,
         #[arg(long, env = "RPC_URL", required = true)]
-        rpc_url: String,
+        rpc_url: Url,
         #[arg(
             long,
             help = "Name of the network or genesis file. Supported: mainnet, holesky, sepolia, hoodi. Default: mainnet",
@@ -260,7 +259,7 @@ impl SubcommandProve {
                 network,
                 bench,
             } => {
-                let eth_client = EthClient::new(&rpc_url)?;
+                let eth_client = EthClient::new(rpc_url.as_str())?;
                 let block = or_latest(block)?;
                 let cache = get_blockdata(eth_client, network.clone(), block).await?;
                 let future = async {
@@ -313,7 +312,7 @@ impl SubcommandProve {
 }
 
 #[derive(Subcommand)]
-enum EthrexReplayCommand {
+pub enum EthrexReplayCommand {
     #[command(
         subcommand,
         about = "Execute blocks, ranges of blocks, or individual transactions."

cmd/ethrex_replay/src/lib.rs

@@ -0,0 +1,6 @@
+mod bench;
+mod cache;
+pub mod cli;
+mod fetcher;
+mod plot_composition;
+mod run;

cmd/ethrex_replay/src/main.rs

@@ -1,13 +1,6 @@
 use std::str::FromStr;
 use tracing_subscriber::filter::Directive;
 
-mod bench;
-mod cache;
-mod cli;
-mod fetcher;
-mod plot_composition;
-mod run;
-
 #[cfg(feature = "jemalloc")]
 use jemallocator::Jemalloc;
 
@@ -30,7 +23,7 @@ async fn main() {
             .finish(),
     )
     .expect("setting default subscriber failed");
-    if let Err(e) = cli::start().await {
+    if let Err(e) = ethrex_replay::cli::start().await {
         tracing::error!("{e:?}");
         std::process::exit(1);
     }

tooling/replayer/Cargo.toml

@@ -0,0 +1,30 @@
+[package]
+name = "ethrex-replayer"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+ethrex-config.workspace = true
+ethrex-common.workspace = true
+ethrex-rpc.workspace = true
+ethrex-replay = { path = "../../cmd/ethrex_replay" }
+
+serde.workspace = true
+hex.workspace = true
+serde_json.workspace = true
+serde_with.workspace = true
+reqwest.workspace = true
+tracing-subscriber = { workspace = true, features = ["env-filter"] }
+tracing.workspace = true
+eyre.workspace = true
+tokio = { version = "1.21", default-features = false, features = ["full"] }
+clap.workspace = true
+futures.workspace = true
+
+[features]
+risc0 = ["ethrex-replay/risc0"]
+sp1 = ["ethrex-replay/sp1"]
+gpu = ["ethrex-replay/gpu"]
+l2 = ["ethrex-replay/l2"]
+profiling = ["ethrex-replay/profiling"]
+ci = ["ethrex-replay/ci"]