passing arguments to the service provider startup

This commit is contained in:
Jedrzej Stuczynski
2019-12-09 10:44:21 +00:00
parent 818389839f
commit 8ac76cb152
3 changed files with 153 additions and 2 deletions
+87 -1
View File
@@ -1,5 +1,91 @@
use clap::{App, Arg, ArgMatches, SubCommand};
use curve25519_dalek::scalar::Scalar;
use std::net::ToSocketAddrs;
use std::process;
mod provider;
fn main() {
fn execute(matches: ArgMatches) -> Result<(), String> {
match matches.subcommand() {
("run", Some(m)) => Ok(run(m)),
_ => Err(String::from("Unknown command")),
}
}
fn run(matches: &ArgMatches) {
println!("Running the service provider!");
let host = matches.value_of("host").unwrap_or("0.0.0.0");
let port = match matches.value_of("port").unwrap().parse::<u16>() {
Ok(n) => n,
Err(err) => panic!("Invalid port value provided - {:?}", err),
};
let secret_key: Scalar = match matches.value_of("keyfile") {
Some(keyfile) => {
println!("Todo: load keyfile from <{:?}>", keyfile);
Default::default()
}
None => {
println!("Todo: generate fresh sphinx keypair");
Default::default()
}
};
println!("The value of host is: {:?}", host);
println!("The value of port is: {:?}", port);
println!("The value of key is: {:?}", secret_key);
let socket_address = (host, port)
.to_socket_addrs()
.expect("Failed to combine host and port")
.next()
.expect("Failed to extract the socket address from the iterator");
println!("The full combined socket address is {}", socket_address);
// make sure our socket_address is equal to our predefined-hardcoded value
assert_eq!("127.0.0.1:8081", socket_address.to_string());
provider::listening_loop().unwrap();
}
fn main() {
let arg_matches = App::new("Nym Service Provider")
.version("0.1.0")
.author("Nymtech")
.about("Implementation of the Loopix-based Service Provider")
.subcommand(
SubCommand::with_name("run")
.about("Starts the mixnode")
.arg(
Arg::with_name("host")
.short("h")
.long("host")
.help("The custom host on which the service provider will be running")
.takes_value(true),
)
.arg(
Arg::with_name("port")
.short("p")
.long("port")
.help("The port on which the service provider will be listening")
.takes_value(true)
.required(true),
)
.arg(
Arg::with_name("keyfile")
.short("k")
.long("keyfile")
.help("Optional path to the persistent keyfile of the node")
.takes_value(true),
),
)
.get_matches();
if let Err(e) = execute(arg_matches) {
println!("Application error: {}", e);
process::exit(1);
}
}