diff options
author | Alex Auvolat <alex@adnab.me> | 2021-10-26 11:22:28 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2021-10-26 11:36:30 +0200 |
commit | 3e7f766d95a7101681ebadfff9c7eadb18314a25 (patch) | |
tree | 60fa91e9eb880273f569f473355eaf8ad8b44a71 /src/garage/main.rs | |
parent | 43e13a501dc00628fbe67ba011649b30ccd4b832 (diff) | |
download | garage-3e7f766d95a7101681ebadfff9c7eadb18314a25.tar.gz garage-3e7f766d95a7101681ebadfff9c7eadb18314a25.zip |
CLI: default rpc_hostv0.4-rc1
Diffstat (limited to 'src/garage/main.rs')
-rw-r--r-- | src/garage/main.rs | 25 |
1 files changed, 20 insertions, 5 deletions
diff --git a/src/garage/main.rs b/src/garage/main.rs index 7f7196d9..2a939730 100644 --- a/src/garage/main.rs +++ b/src/garage/main.rs @@ -9,6 +9,7 @@ mod cli; mod repair; mod server; +use std::net::SocketAddr; use std::path::PathBuf; use structopt::StructOpt; @@ -46,6 +47,9 @@ struct Opt { #[tokio::main] async fn main() { + if std::env::var("RUST_LOG").is_err() { + std::env::set_var("RUST_LOG", "garage=info") + } pretty_env_logger::init(); sodiumoxide::init().expect("Unable to init sodiumoxide"); @@ -99,12 +103,23 @@ async fn cli_command(opt: Opt) -> Result<(), Error> { let (id, addr) = if let Some(h) = opt.rpc_host { let (id, addrs) = parse_and_resolve_peer_addr(&h).ok_or_else(|| format!("Invalid RPC remote node identifier: {}. Expected format is <pubkey>@<IP or hostname>:<port>.", h))?; (id, addrs[0]) - } else if let Some(a) = config.as_ref().map(|c| c.rpc_public_addr).flatten() { - let node_id = garage_rpc::system::read_node_id(&config.unwrap().metadata_dir) - .err_context(READ_KEY_ERROR)?; - (node_id, a) } else { - return Err(Error::Message("No RPC host provided".into())); + let node_id = garage_rpc::system::read_node_id(&config.as_ref().unwrap().metadata_dir) + .err_context(READ_KEY_ERROR)?; + if let Some(a) = config.as_ref().map(|c| c.rpc_public_addr).flatten() { + (node_id, a) + } else { + let default_addr = SocketAddr::new( + "127.0.0.1".parse().unwrap(), + config.as_ref().unwrap().rpc_bind_addr.port(), + ); + warn!( + "Trying to contact Garage node at default address {}", + default_addr + ); + warn!("If this doesn't work, consider adding rpc_public_addr in your config file or specifying the -h command line parameter."); + (node_id, default_addr) + } }; // Connect to target host |