feat: cli init

Author: GrapeBaBa

Cargo.lock

@@ -15,7 +15,7 @@ exclude = ["**/target", "benches/", "tests"]
 eth2 = { git = "https://github.com/sigp/lighthouse.git", tag = "v5.2.1" }
 warp_utils = { git = "https://github.com/sigp/lighthouse.git", tag = "v5.2.1" }
 
-clap = "4"
+clap = { version = "4", features = ["derive", "env"] }
 futures-util = "0.3"
 reqwest = "0.12"
 serde_json = "1.0.94"
@@ -34,6 +34,7 @@ rand = "0.8.5"
 once_cell = "1.19.0"
 hex = "0.4.3"
 tracing-subscriber = "0.3.18"
+tracing-appender = "0.2.3"
 uuid = { version = "1.10.0", features = ["v4", "fast-rng", "macro-diagnostics"] }
 warp = "0.3.2"
-ssz_rs = "0.9.0"
+ssz_rs = "0.9.0"

Cargo.toml

@@ -1 +1,24 @@
-# blob-archiver-rs
+# blob-archiver-rs
+This is a Rust implementation of
+the [Beacon Chain blob archiver](https://github.com/base-org/blob-archiver)
+
+### Development
+```sh
+# Run the tests
+cargo test --workspace --all-features --all-targets --locked
+
+# Lint the project
+cargo clippy --workspace --all-targets --all-features -- -D warnings
+
+# Build the project
+cargo build --workspace --all-targets --all-features
+
+```
+
+#### Run Locally
+To run the project locally, you should first copy `.env.template` to `.env` and then modify the environment variables
+to your beacon client and storage backend of choice. Then you can run the project with:
+
+```sh
+docker compose up
+```

README.md

@@ -3,6 +3,21 @@ mod api;
 #[allow(dead_code)]
 static INIT: std::sync::Once = std::sync::Once::new();
 
+use clap::Parser;
+
 fn main() {
     println!("Hello, world!");
 }
+
+#[derive(Parser, Debug)]
+#[clap(author, version, about, long_about = None)]
+struct CliArgs {
+    #[clap(short, long, value_parser, default_value = "config.toml")]
+    config: String,
+
+    #[clap(short, long, action = clap::ArgAction::Count)]
+    verbose: u8,
+
+    #[clap(short, long)]
+    dry_run: bool,
+}

bin/api/src/main.rs

@@ -24,6 +24,7 @@ hex.workspace = true
 tracing-subscriber.workspace = true
 uuid.workspace = true
 warp.workspace = true
+tracing-appender.workspace = true
 blob-archiver-storage = { path = "../../crates/storage" }
 blob-archiver-beacon = { path = "../../crates/beacon" }
 

bin/archiver/Cargo.toml

@@ -3,14 +3,17 @@ use again::RetryPolicy;
 use blob_archiver_beacon::beacon_client::BeaconClientEth2;
 use blob_archiver_beacon::blob_test_helper;
 use blob_archiver_storage::fs::FSStorage;
+use clap::Parser;
 use eth2::types::BlockId;
 use eth2::{BeaconNodeHttpClient, SensitiveUrl, Timeouts};
+use serde::Serialize;
 use std::path::PathBuf;
 use std::str::FromStr;
 use std::sync::Arc;
 use std::time::Duration;
 use tokio::sync::Mutex;
 use tracing::log::error;
+use tracing_appender::rolling::{RollingFileAppender, Rotation};
 use tracing_subscriber::fmt;
 use tracing_subscriber::layer::SubscriberExt;
 use tracing_subscriber::util::SubscriberInitExt;
@@ -74,3 +77,26 @@ fn setup_tracing() {
         tracing_subscriber::registry().with(fmt::layer()).init();
     });
 }
+
+#[allow(dead_code)]
+fn setup_logging() {
+    // Create a rolling file appender
+    let file_appender = RollingFileAppender::new(Rotation::DAILY, "logs/", "app.log");
+
+    // Create a subscriber that uses the rolling file appender
+    let subscriber = tracing_subscriber::registry()
+        .with(fmt::Layer::new().with_writer(file_appender))
+        .with(tracing_subscriber::EnvFilter::from_default_env());
+
+    // Set the subscriber as the global default
+    tracing::subscriber::set_global_default(subscriber).expect("Failed to set subscriber");
+}
+
+#[derive(Parser, Serialize)]
+struct CliArgs {
+    #[clap(short, long, action = clap::ArgAction::Count, default_value = "3")]
+    verbose: u8,
+
+    #[clap(short, long, default_value = "logs")]
+    log_dir: Option<String>,
+}