ee000d5219
## Proposed Changes Add a new hardcoded spec for the Gnosis Beacon Chain. Ideally, official Lighthouse executables will be able to connect to the gnosis beacon chain from now on, using `--network gnosis` CLI option.
105 lines
3.6 KiB
Rust
105 lines
3.6 KiB
Rust
//! Creates a simple DISCV5 server which can be used to bootstrap an Eth2 network.
|
|
use clap::ArgMatches;
|
|
use slog::{o, Drain, Level, Logger};
|
|
|
|
use eth2_network_config::Eth2NetworkConfig;
|
|
use std::fs::File;
|
|
use std::path::PathBuf;
|
|
mod cli;
|
|
pub mod config;
|
|
mod server;
|
|
pub use cli::cli_app;
|
|
use config::{BootNodeConfig, BootNodeConfigSerialization};
|
|
use types::{EthSpec, EthSpecId};
|
|
|
|
const LOG_CHANNEL_SIZE: usize = 2048;
|
|
|
|
/// Run the bootnode given the CLI configuration.
|
|
pub fn run(
|
|
lh_matches: &ArgMatches<'_>,
|
|
bn_matches: &ArgMatches<'_>,
|
|
eth_spec_id: EthSpecId,
|
|
eth2_network_config: &Eth2NetworkConfig,
|
|
debug_level: String,
|
|
) {
|
|
let debug_level = match debug_level.as_str() {
|
|
"trace" => log::Level::Trace,
|
|
"debug" => log::Level::Debug,
|
|
"info" => log::Level::Info,
|
|
"warn" => log::Level::Warn,
|
|
"error" => log::Level::Error,
|
|
"crit" => log::Level::Error,
|
|
_ => unreachable!(),
|
|
};
|
|
|
|
// Setting up the initial logger format and building it.
|
|
let drain = {
|
|
let decorator = slog_term::TermDecorator::new().build();
|
|
let decorator = logging::AlignedTermDecorator::new(decorator, logging::MAX_MESSAGE_WIDTH);
|
|
let drain = slog_term::FullFormat::new(decorator).build().fuse();
|
|
slog_async::Async::new(drain)
|
|
.chan_size(LOG_CHANNEL_SIZE)
|
|
.build()
|
|
};
|
|
|
|
let drain = match debug_level {
|
|
log::Level::Info => drain.filter_level(Level::Info),
|
|
log::Level::Debug => drain.filter_level(Level::Debug),
|
|
log::Level::Trace => drain.filter_level(Level::Trace),
|
|
log::Level::Warn => drain.filter_level(Level::Warning),
|
|
log::Level::Error => drain.filter_level(Level::Error),
|
|
};
|
|
|
|
let logger = Logger::root(drain.fuse(), o!());
|
|
let _scope_guard = slog_scope::set_global_logger(logger);
|
|
let _log_guard = slog_stdlog::init_with_level(debug_level).unwrap();
|
|
|
|
let log = slog_scope::logger();
|
|
// Run the main function emitting any errors
|
|
if let Err(e) = match eth_spec_id {
|
|
EthSpecId::Minimal => {
|
|
main::<types::MinimalEthSpec>(lh_matches, bn_matches, eth2_network_config, log)
|
|
}
|
|
EthSpecId::Mainnet => {
|
|
main::<types::MainnetEthSpec>(lh_matches, bn_matches, eth2_network_config, log)
|
|
}
|
|
EthSpecId::Gnosis => {
|
|
main::<types::GnosisEthSpec>(lh_matches, bn_matches, eth2_network_config, log)
|
|
}
|
|
} {
|
|
slog::crit!(slog_scope::logger(), "{}", e);
|
|
}
|
|
}
|
|
|
|
fn main<T: EthSpec>(
|
|
lh_matches: &ArgMatches<'_>,
|
|
bn_matches: &ArgMatches<'_>,
|
|
eth2_network_config: &Eth2NetworkConfig,
|
|
log: slog::Logger,
|
|
) -> Result<(), String> {
|
|
// Builds a custom executor for the bootnode
|
|
let runtime = tokio::runtime::Builder::new_multi_thread()
|
|
.enable_all()
|
|
.build()
|
|
.map_err(|e| format!("Failed to build runtime: {}", e))?;
|
|
|
|
// parse the CLI args into a useable config
|
|
let config: BootNodeConfig<T> = BootNodeConfig::new(bn_matches, eth2_network_config)?;
|
|
|
|
// Dump config if `dump-config` flag is set
|
|
let dump_config = clap_utils::parse_optional::<PathBuf>(lh_matches, "dump-config")?;
|
|
if let Some(dump_path) = dump_config {
|
|
let config_sz = BootNodeConfigSerialization::from_config_ref(&config);
|
|
let mut file = File::create(dump_path)
|
|
.map_err(|e| format!("Failed to create dumped config: {:?}", e))?;
|
|
serde_json::to_writer(&mut file, &config_sz)
|
|
.map_err(|e| format!("Error serializing config: {:?}", e))?;
|
|
}
|
|
|
|
// Run the boot node
|
|
if !lh_matches.is_present("immediate-shutdown") {
|
|
runtime.block_on(server::run(config, log));
|
|
}
|
|
Ok(())
|
|
}
|