2019-02-27 23:24:27 +00:00
mod run ;
2019-02-14 01:09:18 +00:00
2019-06-09 10:26:34 +00:00
use clap ::{ App , Arg } ;
2019-08-15 02:48:34 +00:00
use client ::{ ClientConfig , Eth2Config , GenesisState } ;
2019-04-15 03:58:41 +00:00
use env_logger ::{ Builder , Env } ;
2019-07-01 06:38:42 +00:00
use eth2_config ::{ read_from_file , write_to_file } ;
2019-08-10 01:44:17 +00:00
use slog ::{ crit , o , warn , Drain , Level } ;
2019-07-01 06:38:42 +00:00
use std ::fs ;
2019-06-09 00:21:50 +00:00
use std ::path ::PathBuf ;
2019-06-08 01:00:34 +00:00
pub const DEFAULT_DATA_DIR : & str = " .lighthouse " ;
2019-02-14 01:09:18 +00:00
2019-06-09 10:41:51 +00:00
pub const CLIENT_CONFIG_FILENAME : & str = " beacon-node.toml " ;
2019-06-09 10:35:36 +00:00
pub const ETH2_CONFIG_FILENAME : & str = " eth2-spec.toml " ;
2019-08-06 03:29:27 +00:00
pub const TESTNET_CONFIG_FILENAME : & str = " testnet.toml " ;
2019-06-08 17:17:03 +00:00
2019-02-14 01:09:18 +00:00
fn main ( ) {
2019-04-15 03:58:41 +00:00
// debugging output for libp2p and external crates
Builder ::from_env ( Env ::default ( ) ) . init ( ) ;
2019-02-14 01:09:18 +00:00
let matches = App ::new ( " Lighthouse " )
2019-02-27 23:24:27 +00:00
. version ( version ::version ( ) . as_str ( ) )
. author ( " Sigma Prime <contact@sigmaprime.io> " )
2019-02-14 01:09:18 +00:00
. about ( " Eth 2.0 Client " )
2019-08-06 03:29:27 +00:00
/*
* Configuration directory locations .
* /
2019-02-14 01:09:18 +00:00
. arg (
Arg ::with_name ( " datadir " )
. long ( " datadir " )
. value_name ( " DIR " )
. help ( " Data directory for keys and databases. " )
2019-06-08 01:00:34 +00:00
. takes_value ( true )
2019-02-14 01:09:18 +00:00
)
2019-07-10 00:27:44 +00:00
. arg (
Arg ::with_name ( " logfile " )
. long ( " logfile " )
. value_name ( " logfile " )
. help ( " File path where output will be written. " )
. takes_value ( true ) ,
)
2019-07-29 03:45:45 +00:00
. arg (
Arg ::with_name ( " network-dir " )
. long ( " network-dir " )
. value_name ( " NETWORK-DIR " )
. help ( " Data directory for network keys. " )
. takes_value ( true )
)
2019-08-06 03:29:27 +00:00
/*
* Network parameters .
* /
2019-02-27 23:24:27 +00:00
. arg (
2019-04-01 05:29:11 +00:00
Arg ::with_name ( " listen-address " )
2019-03-19 22:58:31 +00:00
. long ( " listen-address " )
2019-08-10 01:44:17 +00:00
. value_name ( " ADDRESS " )
2019-06-25 08:02:11 +00:00
. help ( " The address lighthouse will listen for UDP and TCP connections. (default 127.0.0.1). " )
2019-02-14 01:09:18 +00:00
. takes_value ( true ) ,
)
2019-08-10 01:44:17 +00:00
. arg (
Arg ::with_name ( " port " )
. long ( " port " )
. value_name ( " PORT " )
. help ( " The TCP/UDP port to listen on. The UDP port can be modified by the --discovery-port flag. " )
. takes_value ( true ) ,
)
2019-06-25 04:51:45 +00:00
. arg (
Arg ::with_name ( " maxpeers " )
. long ( " maxpeers " )
2019-06-25 08:02:11 +00:00
. help ( " The maximum number of peers (default 10). " )
2019-06-25 04:51:45 +00:00
. takes_value ( true ) ,
)
2019-04-01 01:14:44 +00:00
. arg (
Arg ::with_name ( " boot-nodes " )
. long ( " boot-nodes " )
2019-06-25 04:51:45 +00:00
. allow_hyphen_values ( true )
2019-04-01 01:14:44 +00:00
. value_name ( " BOOTNODES " )
2019-06-25 04:51:45 +00:00
. help ( " One or more comma-delimited base64-encoded ENR's to bootstrap the p2p network. " )
. takes_value ( true ) ,
)
. arg (
Arg ::with_name ( " discovery-port " )
. long ( " disc-port " )
2019-08-10 01:44:17 +00:00
. value_name ( " PORT " )
2019-06-25 08:02:11 +00:00
. help ( " The discovery UDP port. " )
. takes_value ( true ) ,
)
. arg (
Arg ::with_name ( " discovery-address " )
. long ( " discovery-address " )
2019-08-10 01:44:17 +00:00
. value_name ( " ADDRESS " )
2019-07-01 06:38:42 +00:00
. help ( " The IP address to broadcast to other peers on how to reach this node. " )
2019-04-01 01:14:44 +00:00
. takes_value ( true ) ,
)
2019-08-10 01:44:17 +00:00
. arg (
Arg ::with_name ( " topics " )
. long ( " topics " )
. value_name ( " STRING " )
. help ( " One or more comma-delimited gossipsub topic strings to subscribe to. " )
. takes_value ( true ) ,
)
. arg (
Arg ::with_name ( " libp2p-addresses " )
. long ( " libp2p-addresses " )
. value_name ( " MULTIADDR " )
. help ( " One or more comma-delimited multiaddrs to manually connect to a libp2p peer without an ENR. " )
. takes_value ( true ) ,
)
2019-08-06 03:29:27 +00:00
/*
* gRPC parameters .
* /
2019-03-19 13:01:00 +00:00
. arg (
Arg ::with_name ( " rpc " )
2019-03-19 22:58:31 +00:00
. long ( " rpc " )
2019-03-19 13:01:00 +00:00
. value_name ( " RPC " )
. help ( " Enable the RPC server. " )
. takes_value ( false ) ,
)
. arg (
Arg ::with_name ( " rpc-address " )
2019-03-19 22:58:31 +00:00
. long ( " rpc-address " )
2019-06-25 08:02:11 +00:00
. value_name ( " Address " )
2019-03-19 13:01:00 +00:00
. help ( " Listen address for RPC endpoint. " )
. takes_value ( true ) ,
)
. arg (
Arg ::with_name ( " rpc-port " )
2019-03-19 22:58:31 +00:00
. long ( " rpc-port " )
2019-03-19 13:01:00 +00:00
. help ( " Listen port for RPC endpoint. " )
. takes_value ( true ) ,
)
2019-08-10 01:44:17 +00:00
/* Client related arguments */
First RESTful HTTP API (#399)
* Added generated code for REST API.
- Created a new crate rest_api, which will adapt the openapi generated code to Lighthouse
- Committed automatically generated code from openapi-generator-cli (via docker). Should hopfully not have to modify this at all, and do all changes in the rest_api crate.
* Removed openapi generated code, because it was the rust client, not the rust server.
* Added the correct rust-server code, automatically generated from openapi.
* Added generated code for REST API.
- Created a new crate rest_api, which will adapt the openapi generated code to Lighthouse
- Committed automatically generated code from openapi-generator-cli (via docker). Should hopfully not have to modify this at all, and do all changes in the rest_api crate.
* Removed openapi generated code, because it was the rust client, not the rust server.
* Added the correct rust-server code, automatically generated from openapi.
* Included REST API in configuratuion.
- Started adding the rest_api into the beacon node's dependencies.
- Set up configuration file for rest_api and integrated into main client config
- Added CLI flags for REST API.
* Futher work on REST API.
- Adding the dependencies to rest_api crate
- Created a skeleton BeaconNodeService, which will handle /node requests.
- Started the rest_api server definition, with the high level request handling logic.
* Added generated code for REST API.
- Created a new crate rest_api, which will adapt the openapi generated code to Lighthouse
- Committed automatically generated code from openapi-generator-cli (via docker). Should hopfully not have to modify this at all, and do all changes in the rest_api crate.
* Removed openapi generated code, because it was the rust client, not the rust server.
* Added the correct rust-server code, automatically generated from openapi.
* Included REST API in configuratuion.
- Started adding the rest_api into the beacon node's dependencies.
- Set up configuration file for rest_api and integrated into main client config
- Added CLI flags for REST API.
* Futher work on REST API.
- Adding the dependencies to rest_api crate
- Created a skeleton BeaconNodeService, which will handle /node requests.
- Started the rest_api server definition, with the high level request handling logic.
* WIP: Restructured REST API to use hyper_router and separate services.
* WIP: Fixing rust for REST API
* WIP: Fixed up many bugs in trying to get router to compile.
* WIP: Got the beacon_node to compile with the REST changes
* Basic API works!
- Changed CLI flags from rest-api* to api*
- Fixed port cli flag
- Tested, works over HTTP
* WIP: Moved things around so that we can get state inside the handlers.
* WIP: Significant API updates.
- Started writing a macro for getting the handler functions.
- Added the BeaconChain into the type map, gives stateful access to the beacon state.
- Created new generic error types (haven't figured out yet), to reduce code duplication.
- Moved common stuff into lib.rs
* WIP: Factored macros, defined API result and error.
- did more logging when creating HTTP responses
- Tried moving stuff into macros, but can't get macros in macros to compile.
- Pulled out a lot of placeholder code.
* Fixed macros so that things compile.
* Cleaned up code.
- Removed unused imports
- Removed comments
- Addressed all compiler warnings.
- Ran cargo fmt.
* Removed auto-generated OpenAPI code.
* Addressed Paul's suggestions.
- Fixed spelling mistake
- Moved the simple macros into functions, since it doesn't make sense for them to be macros.
- Removed redundant code & inclusions.
* Removed redundant validate_request function.
* Included graceful shutdown in Hyper server.
* Fixing the dropped exit_signal, which prevented the API from starting.
* Wrapped the exit signal, to get an API shutdown log line.
2019-07-31 08:29:41 +00:00
. arg (
Arg ::with_name ( " api " )
. long ( " api " )
. value_name ( " API " )
. help ( " Enable the RESTful HTTP API server. " )
. takes_value ( false ) ,
)
. arg (
Arg ::with_name ( " api-address " )
. long ( " api-address " )
. value_name ( " APIADDRESS " )
. help ( " Set the listen address for the RESTful HTTP API server. " )
. takes_value ( true ) ,
)
. arg (
Arg ::with_name ( " api-port " )
. long ( " api-port " )
. value_name ( " APIPORT " )
. help ( " Set the listen TCP port for the RESTful HTTP API server. " )
. takes_value ( true ) ,
)
2019-08-06 03:29:27 +00:00
/*
* Database parameters .
* /
2019-03-31 07:57:48 +00:00
. arg (
Arg ::with_name ( " db " )
. long ( " db " )
. value_name ( " DB " )
. help ( " Type of database to use. " )
. takes_value ( true )
2019-05-21 07:45:35 +00:00
. possible_values ( & [ " disk " , " memory " ] )
2019-03-31 07:57:48 +00:00
. default_value ( " memory " ) ,
)
2019-08-06 03:29:27 +00:00
/*
* Specification / testnet params .
* /
2019-06-08 17:17:03 +00:00
. arg (
2019-08-06 03:29:27 +00:00
Arg ::with_name ( " default-spec " )
. long ( " default-spec " )
2019-06-08 21:53:22 +00:00
. value_name ( " TITLE " )
2019-08-06 03:29:27 +00:00
. short ( " default-spec " )
2019-08-10 01:44:17 +00:00
. help ( " Specifies the default eth2 spec to be used. This will override any spec written to disk and will therefore be used by default in future instances. " )
2019-06-08 21:53:22 +00:00
. takes_value ( true )
2019-08-10 01:44:17 +00:00
. possible_values ( & [ " mainnet " , " minimal " , " interop " ] )
2019-06-08 21:53:22 +00:00
)
. arg (
Arg ::with_name ( " recent-genesis " )
. long ( " recent-genesis " )
2019-06-09 00:21:50 +00:00
. short ( " r " )
2019-06-08 17:17:03 +00:00
. help ( " When present, genesis will be within 30 minutes prior. Only for testing " ) ,
)
2019-08-06 03:29:27 +00:00
/*
* Logging .
* /
2019-07-29 03:45:45 +00:00
. arg (
Arg ::with_name ( " debug-level " )
. long ( " debug-level " )
. value_name ( " LEVEL " )
. help ( " The title of the spec constants for chain config. " )
. takes_value ( true )
. possible_values ( & [ " info " , " debug " , " trace " , " warn " , " error " , " crit " ] )
2019-08-10 01:44:17 +00:00
. default_value ( " trace " ) ,
2019-07-29 03:45:45 +00:00
)
2019-04-15 01:29:08 +00:00
. arg (
Arg ::with_name ( " verbosity " )
. short ( " v " )
. multiple ( true )
. help ( " Sets the verbosity level " )
. takes_value ( true ) ,
)
2019-08-15 02:48:34 +00:00
/*
* Bootstrap .
* /
. arg (
Arg ::with_name ( " bootstrap " )
. long ( " bootstrap " )
. value_name ( " HTTP_SERVER " )
. help ( " Load the genesis state and libp2p address from the HTTP API of another Lighthouse node. " )
. takes_value ( true )
)
2019-02-14 01:09:18 +00:00
. get_matches ( ) ;
2019-04-15 01:29:08 +00:00
// build the initial logger
let decorator = slog_term ::TermDecorator ::new ( ) . build ( ) ;
2019-07-30 23:06:53 +00:00
let decorator = logging ::AlignedTermDecorator ::new ( decorator , logging ::MAX_MESSAGE_WIDTH ) ;
2019-07-29 03:45:45 +00:00
let drain = slog_term ::FullFormat ::new ( decorator ) . build ( ) . fuse ( ) ;
2019-04-15 01:29:08 +00:00
let drain = slog_async ::Async ::new ( drain ) . build ( ) ;
2019-07-29 03:45:45 +00:00
let drain = match matches . value_of ( " debug-level " ) {
Some ( " info " ) = > drain . filter_level ( Level ::Info ) ,
Some ( " debug " ) = > drain . filter_level ( Level ::Debug ) ,
Some ( " trace " ) = > drain . filter_level ( Level ::Trace ) ,
Some ( " warn " ) = > drain . filter_level ( Level ::Warning ) ,
Some ( " error " ) = > drain . filter_level ( Level ::Error ) ,
Some ( " crit " ) = > drain . filter_level ( Level ::Critical ) ,
_ = > unreachable! ( " guarded by clap " ) ,
} ;
2019-04-15 01:29:08 +00:00
let drain = match matches . occurrences_of ( " verbosity " ) {
0 = > drain . filter_level ( Level ::Info ) ,
1 = > drain . filter_level ( Level ::Debug ) ,
2 = > drain . filter_level ( Level ::Trace ) ,
2019-07-16 07:28:15 +00:00
_ = > drain . filter_level ( Level ::Trace ) ,
2019-04-15 01:29:08 +00:00
} ;
2019-07-10 00:27:44 +00:00
let mut log = slog ::Logger ::root ( drain . fuse ( ) , o! ( ) ) ;
2019-04-15 01:29:08 +00:00
2019-07-02 07:32:14 +00:00
let data_dir = match matches
2019-07-01 06:38:42 +00:00
. value_of ( " datadir " )
. and_then ( | v | Some ( PathBuf ::from ( v ) ) )
2019-07-02 07:32:14 +00:00
{
Some ( v ) = > v ,
None = > {
// use the default
let mut default_dir = match dirs ::home_dir ( ) {
Some ( v ) = > v ,
None = > {
crit! ( log , " Failed to find a home directory " ) ;
return ;
}
} ;
default_dir . push ( DEFAULT_DATA_DIR ) ;
Update to frozen spec ❄️ (v0.8.1) (#444)
* types: first updates for v0.8
* state_processing: epoch processing v0.8.0
* state_processing: block processing v0.8.0
* tree_hash_derive: support generics in SignedRoot
* types v0.8: update to use ssz_types
* state_processing v0.8: use ssz_types
* ssz_types: add bitwise methods and from_elem
* types: fix v0.8 FIXMEs
* ssz_types: add bitfield shift_up
* ssz_types: iterators and DerefMut for VariableList
* types,state_processing: use VariableList
* ssz_types: fix BitVector Decode impl
Fixed a typo in the implementation of ssz::Decode for BitVector, which caused it
to be considered variable length!
* types: fix test modules for v0.8 update
* types: remove slow type-level arithmetic
* state_processing: fix tests for v0.8
* op_pool: update for v0.8
* ssz_types: Bitfield difference length-independent
Allow computing the difference of two bitfields of different lengths.
* Implement compact committee support
* epoch_processing: committee & active index roots
* state_processing: genesis state builder v0.8
* state_processing: implement v0.8.1
* Further improve tree_hash
* Strip examples, tests from cached_tree_hash
* Update TreeHash, un-impl CachedTreeHash
* Update bitfield TreeHash, un-impl CachedTreeHash
* Update FixedLenVec TreeHash, unimpl CachedTreeHash
* Update update tree_hash_derive for new TreeHash
* Fix TreeHash, un-impl CachedTreeHash for ssz_types
* Remove fixed_len_vec, ssz benches
SSZ benches relied upon fixed_len_vec -- it is easier to just delete
them and rebuild them later (when necessary)
* Remove boolean_bitfield crate
* Fix fake_crypto BLS compile errors
* Update ef_tests for new v.8 type params
* Update ef_tests submodule to v0.8.1 tag
* Make fixes to support parsing ssz ef_tests
* `compact_committee...` to `compact_committees...`
* Derive more traits for `CompactCommittee`
* Flip bitfield byte-endianness
* Fix tree_hash for bitfields
* Modify CLI output for ef_tests
* Bump ssz crate version
* Update ssz_types doc comment
* Del cached tree hash tests from ssz_static tests
* Tidy SSZ dependencies
* Rename ssz_types crate to eth2_ssz_types
* validator_client: update for v0.8
* ssz_types: update union/difference for bit order swap
* beacon_node: update for v0.8, EthSpec
* types: disable cached tree hash, update min spec
* state_processing: fix slot bug in committee update
* tests: temporarily disable fork choice harness test
See #447
* committee cache: prevent out-of-bounds access
In the case where we tried to access the committee of a shard that didn't have a committee in the
current epoch, we were accessing elements beyond the end of the shuffling vector and panicking! This
commit adds a check to make the failure safe and explicit.
* fix bug in get_indexed_attestation and simplify
There was a bug in our implementation of get_indexed_attestation whereby
incorrect "committee indices" were used to index into the custody bitfield. The
bug was only observable in the case where some bits of the custody bitfield were
set to 1. The implementation has been simplified to remove the bug, and a test
added.
* state_proc: workaround for compact committees bug
https://github.com/ethereum/eth2.0-specs/issues/1315
* v0.8: updates to make the EF tests pass
* Remove redundant max operation checks.
* Always supply both messages when checking attestation signatures -- allowing
verification of an attestation with no signatures.
* Swap the order of the fork and domain constant in `get_domain`, to match
the spec.
* rustfmt
* ef_tests: add new epoch processing tests
* Integrate v0.8 into master (compiles)
* Remove unused crates, fix clippy lints
* Replace v0.6.3 tags w/ v0.8.1
* Remove old comment
* Ensure lmd ghost tests only run in release
* Update readme
2019-07-30 02:44:51 +00:00
default_dir
2019-07-02 07:32:14 +00:00
}
} ;
2019-07-01 06:38:42 +00:00
// create the directory if needed
match fs ::create_dir_all ( & data_dir ) {
Ok ( _ ) = > { }
2019-06-09 00:21:50 +00:00
Err ( e ) = > {
2019-07-01 06:38:42 +00:00
crit! ( log , " Failed to initialize data dir " ; " error " = > format! ( " {} " , e ) ) ;
2019-06-09 00:21:50 +00:00
return ;
}
2019-07-01 06:38:42 +00:00
}
2019-06-09 00:21:50 +00:00
let client_config_path = data_dir . join ( CLIENT_CONFIG_FILENAME ) ;
2019-04-15 01:29:08 +00:00
// Attempt to load the `ClientConfig` from disk.
2019-06-09 00:21:50 +00:00
//
// If file doesn't exist, create a new, default one.
let mut client_config = match read_from_file ::< ClientConfig > ( client_config_path . clone ( ) ) {
2019-06-08 21:53:22 +00:00
Ok ( Some ( c ) ) = > c ,
Ok ( None ) = > {
let default = ClientConfig ::default ( ) ;
2019-06-09 00:21:50 +00:00
if let Err ( e ) = write_to_file ( client_config_path , & default ) {
2019-07-01 06:38:42 +00:00
crit! ( log , " Failed to write default ClientConfig to file " ; " error " = > format! ( " {:?} " , e ) ) ;
2019-06-08 21:53:22 +00:00
return ;
}
default
2019-06-09 00:21:50 +00:00
}
2019-06-08 01:00:34 +00:00
Err ( e ) = > {
2019-07-01 06:38:42 +00:00
crit! ( log , " Failed to load a ChainConfig file " ; " error " = > format! ( " {:?} " , e ) ) ;
2019-06-08 01:00:34 +00:00
return ;
}
} ;
2019-06-07 23:44:27 +00:00
2019-06-09 00:21:50 +00:00
// Ensure the `data_dir` in the config matches that supplied to the CLI.
client_config . data_dir = data_dir . clone ( ) ;
2019-06-08 17:17:03 +00:00
2019-06-09 00:21:50 +00:00
// Update the client config with any CLI args.
2019-07-10 00:27:44 +00:00
match client_config . apply_cli_args ( & matches , & mut log ) {
2019-06-08 17:17:03 +00:00
Ok ( ( ) ) = > ( ) ,
Err ( s ) = > {
2019-07-01 06:38:42 +00:00
crit! ( log , " Failed to parse ClientConfig CLI arguments " ; " error " = > s ) ;
2019-06-08 17:17:03 +00:00
return ;
}
} ;
2019-08-15 02:48:34 +00:00
// If the `--bootstrap` flag is provided, overwrite the default configuration.
if let Some ( server ) = matches . value_of ( " bootstrap " ) {
client_config . genesis_state = GenesisState ::HttpBootstrap {
server : server . to_string ( ) ,
} ;
}
2019-06-09 00:21:50 +00:00
let eth2_config_path = data_dir . join ( ETH2_CONFIG_FILENAME ) ;
2019-08-10 01:44:17 +00:00
// Initialise the `Eth2Config`.
2019-06-09 00:21:50 +00:00
//
2019-08-10 01:44:17 +00:00
// If a CLI parameter is set, overwrite any config file present.
// If a parameter is not set, use either the config file present or default to minimal.
let cli_config = match matches . value_of ( " default-spec " ) {
Some ( " mainnet " ) = > Some ( Eth2Config ::mainnet ( ) ) ,
Some ( " minimal " ) = > Some ( Eth2Config ::minimal ( ) ) ,
Some ( " interop " ) = > Some ( Eth2Config ::interop ( ) ) ,
_ = > None ,
} ;
// if a CLI flag is specified, write the new config if it doesn't exist,
// otherwise notify the user that the file will not be written.
let eth2_config_from_file = match read_from_file ::< Eth2Config > ( eth2_config_path . clone ( ) ) {
Ok ( config ) = > config ,
2019-06-08 17:17:03 +00:00
Err ( e ) = > {
2019-08-10 01:44:17 +00:00
crit! ( log , " Failed to read the Eth2Config from file " ; " error " = > format! ( " {:?} " , e ) ) ;
2019-06-08 17:17:03 +00:00
return ;
}
} ;
2019-08-10 01:44:17 +00:00
let mut eth2_config = {
if let Some ( cli_config ) = cli_config {
if eth2_config_from_file . is_none ( ) {
// write to file if one doesn't exist
if let Err ( e ) = write_to_file ( eth2_config_path , & cli_config ) {
crit! ( log , " Failed to write default Eth2Config to file " ; " error " = > format! ( " {:?} " , e ) ) ;
return ;
}
} else {
warn! (
log ,
" Eth2Config file exists. Configuration file is ignored, using default "
) ;
}
cli_config
} else {
// CLI config not specified, read from disk
match eth2_config_from_file {
Some ( config ) = > config ,
None = > {
// set default to minimal
let eth2_config = Eth2Config ::minimal ( ) ;
if let Err ( e ) = write_to_file ( eth2_config_path , & eth2_config ) {
crit! ( log , " Failed to write default Eth2Config to file " ; " error " = > format! ( " {:?} " , e ) ) ;
return ;
}
eth2_config
}
}
}
} ;
2019-06-09 00:21:50 +00:00
// Update the eth2 config with any CLI flags.
2019-06-08 17:17:03 +00:00
match eth2_config . apply_cli_args ( & matches ) {
2019-06-07 23:44:27 +00:00
Ok ( ( ) ) = > ( ) ,
Err ( s ) = > {
2019-07-01 06:38:42 +00:00
crit! ( log , " Failed to parse Eth2Config CLI arguments " ; " error " = > s ) ;
2019-06-07 23:44:27 +00:00
return ;
}
} ;
2019-02-14 01:09:18 +00:00
2019-08-10 01:44:17 +00:00
// check to ensure the spec constants between the client and eth2_config match
if eth2_config . spec_constants ! = client_config . spec_constants {
crit! ( log , " Specification constants do not match. " ; " client_config " = > format! ( " {} " , client_config . spec_constants ) , " eth2_config " = > format! ( " {} " , eth2_config . spec_constants ) ) ;
return ;
}
2019-07-29 03:45:45 +00:00
// Start the node using a `tokio` executor.
2019-07-01 06:38:42 +00:00
match run ::run_beacon_node ( client_config , eth2_config , & log ) {
2019-03-19 11:53:51 +00:00
Ok ( _ ) = > { }
2019-07-01 06:38:42 +00:00
Err ( e ) = > crit! ( log , " Beacon node failed to start " ; " reason " = > format! ( " {:} " , e ) ) ,
2019-03-19 11:53:51 +00:00
}
2019-02-14 01:09:18 +00:00
}