github-starred/komodo
2
0
Fork 1
mirror of https://github.com/moghtech/komodo.git synced 2026-04-29 21:27:26 -05:00
Code Issues 3.1k Packages Projects Releases 103 Wiki Activity

0.1.4 across all crates

Browse Source
This commit is contained in:
mbecker20
2023-01-11 06:52:02 +00:00
parent bda5a93ea4
commit f885398d7c
11 changed files with 74 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cli/Cargo.toml
View File

@@ -1,6 +1,6 @@
[package]
name = "monitor_cli"
version = "0.1.2"
version = "0.1.4"
edition = "2021"
authors = ["MoghTech"]
description = "monitor cli | tools to setup monitor system"

27
cli/src/helpers.rs
View File

@@ -41,26 +41,26 @@ pub fn gen_core_config(sub_matches: &ArgMatches) {
.expect("invalid port");
let mongo_uri = sub_matches
.get_one::<String>("mongo_uri")
.get_one::<String>("mongo-uri")
.map(|p| p.as_str())
.unwrap_or("mongodb://monitor-mongo")
.to_string();
let mongo_db_name = sub_matches
.get_one::<String>("mongo_db_name")
.get_one::<String>("mongo-db-name")
.map(|p| p.as_str())
.unwrap_or("monitor")
.to_string();
let jwt_valid_for = sub_matches
.get_one::<String>("jwt_valid_for")
.get_one::<String>("jwt-valid-for")
.map(|p| p.as_str())
.unwrap_or("1-wk")
.parse()
.expect("invalid jwt_valid_for");
.expect("invalid jwt-valid-for");
let slack_url = sub_matches
.get_one::<String>("slack_url")
.get_one::<String>("slack-url")
.map(|p| p.to_owned());
let config = CoreConfig {
@@ -156,6 +156,7 @@ pub fn start_mongo(sub_matches: &ArgMatches) {
println!("{}: {port}", "port".dimmed());
println!("{}: {mount}", "mount".dimmed());
println!("{}: {network}", "network".dimmed());
println!("{}: {restart}", "restart".dimmed());
println!(
"\npress {} to start {}. {}",
@@ -184,7 +185,7 @@ pub fn start_mongo(sub_matches: &ArgMatches) {
pub fn start_core(sub_matches: &ArgMatches) {
let config_path = sub_matches
.get_one::<String>("config_path")
.get_one::<String>("config-path")
.map(|p| p.as_str())
.unwrap_or("~/.monitor/core.config.toml")
.to_string();
@@ -221,6 +222,7 @@ pub fn start_core(sub_matches: &ArgMatches) {
println!("{}: {config_path}", "config path".dimmed());
println!("{}: {port}", "port".dimmed());
println!("{}: {network}", "network".dimmed());
println!("{}: {restart}", "restart".dimmed());
println!(
"\npress {} to start {}. {}",
@@ -262,14 +264,14 @@ pub fn gen_periphery_config(sub_matches: &ArgMatches) {
.expect("invalid port");
let stats_polling_rate = sub_matches
.get_one::<String>("stats_polling_rate")
.get_one::<String>("stats-polling-rate")
.map(|p| p.as_str())
.unwrap_or("5-sec")
.parse::<Timelength>()
.expect("invalid timelength");
let allowed_ips = sub_matches
.get_one::<String>("allowed_ips")
.get_one::<String>("allowed-ips")
.map(|p| p.as_str())
.unwrap_or("")
.split(",")
@@ -281,7 +283,7 @@ pub fn gen_periphery_config(sub_matches: &ArgMatches) {
.collect::<Vec<IpAddr>>();
let repo_dir = sub_matches
.get_one::<String>("repo_dir")
.get_one::<String>("repo-dir")
.map(|p| p.as_str())
.unwrap_or("~/.monitor/repos")
.to_string()
@@ -307,7 +309,7 @@ pub fn gen_periphery_config(sub_matches: &ArgMatches) {
pub fn start_periphery_daemon(sub_matches: &ArgMatches) {
let config_path = sub_matches
.get_one::<String>("config_path")
.get_one::<String>("config-path")
.map(|p| p.as_str())
.unwrap_or("~/.monitor/periphery.config.toml")
.to_string();
@@ -376,13 +378,13 @@ pub fn start_periphery_daemon(sub_matches: &ArgMatches) {
pub fn start_periphery_container(sub_matches: &ArgMatches) {
let config_path = sub_matches
.get_one::<String>("config_path")
.get_one::<String>("config-path")
.map(|p| p.as_str())
.unwrap_or("~/.monitor/periphery.config.toml")
.to_string();
let repo_dir = sub_matches
.get_one::<String>("repo_dir")
.get_one::<String>("repo-dir")
.map(|p| p.as_str())
.unwrap_or("~/.monitor/repos")
.to_string();
@@ -420,6 +422,7 @@ pub fn start_periphery_container(sub_matches: &ArgMatches) {
println!("{}: {repo_dir}", "repo folder".dimmed());
println!("{}: {port}", "port".dimmed());
println!("{}: {network}", "network".dimmed());
println!("{}: {restart}", "restart".dimmed());
println!(
"\npress {} to start {}. {}",

60
cli/src/main.rs
View File

@@ -21,7 +21,7 @@ fn cli() -> Command {
.arg_required_else_help(true)
.allow_external_subcommands(true)
.subcommand(
Command::new("gen_config")
Command::new("gen-config")
.about("generate a core config file")
.arg(
arg!(--host <HOST> "the host to use with oauth redirect url, whatever host the user hits to access monitor. eg 'https://monitor.mogh.tech'")
@@ -36,25 +36,25 @@ fn cli() -> Command {
.required(false)
)
.arg(
arg!(--mongo_uri <URI> "sets the mongo uri to use. default is 'mongodb://monitor-mongo'")
arg!(--mongo-uri <URI> "sets the mongo uri to use. default is 'mongodb://monitor-mongo'")
.required(false)
)
.arg(
arg!(--mongo_db_name <NAME> "sets the db name to use. default is 'monitor'")
arg!(--mongo-db-name <NAME> "sets the db name to use. default is 'monitor'")
.required(false)
)
.arg(
arg!(--jwt_valid_for <TIMELENGTH> "sets the length of time jwt stays valid for. default is 1-wk (one week)")
arg!(--jwt-valid-for <TIMELENGTH> "sets the length of time jwt stays valid for. default is 1-wk (one week)")
.required(false)
)
.arg(
arg!(--slack_url <URL> "sets the slack url to use for slack notifications")
arg!(--slack-url <URL> "sets the slack url to use for slack notifications")
.required(false)
),
)
.subcommand(
Command::new("start_mongo")
.about("start up a local mongo container for monitor")
Command::new("start-mongo")
.about("start up a local mongo container for monitor core")
.arg(
arg!(--name <NAME> "specify the name of the mongo container. default is monitor-mongo")
.required(false)
@@ -90,7 +90,7 @@ fn cli() -> Command {
arg!(--name <NAME> "specify the name of the monitor core container. default is monitor-core")
)
.arg(
arg!(--config_path <PATH> "specify the file path to use for config. default is ~/.monitor/core.config.toml")
arg!(--config-path <PATH> "specify the file path to use for config. default is ~/.monitor/core.config.toml")
.required(false)
)
.arg(
@@ -113,7 +113,7 @@ fn cli() -> Command {
.arg_required_else_help(true)
.allow_external_subcommands(true)
.subcommand(
Command::new("gen_config")
Command::new("gen-config")
.about("generate a periphery config file")
.arg(
arg!(--path <PATH> "sets path of generated config file. default is '~/.monitor/periphery.config.toml'")
@@ -124,21 +124,21 @@ fn cli() -> Command {
.required(false)
)
.arg(
arg!(--stats_polling_rate <INTERVAL> "sets stats polling rate to control granularity of system stats returned. default is 5-sec. options: 1-sec, 5-sec, 10-sec, 30-sec, 1-min")
arg!(--stats-polling-rate <INTERVAL> "sets stats polling rate to control granularity of system stats returned. default is 5-sec. options: 1-sec, 5-sec, 10-sec, 30-sec, 1-min")
.required(false)
)
.arg(
arg!(--allowed_ips <IPS> "used to only accept requests from known ips. give ips as comma seperated list, like '--allowed_ips 127.0.0.1,10.20.30.43'. default is empty, which will not block any ip.")
arg!(--allowed-ips <IPS> "used to only accept requests from known ips. give ips as comma seperated list, like '--allowed_ips 127.0.0.1,10.20.30.43'. default is empty, which will not block any ip.")
.required(false)
)
.arg(
arg!(--repo_dir <PATH> "if running in container, this should be '/repos'. default is ~/.monitor/repos").required(false)
arg!(--repo-dir <PATH> "if running in container, this should be '/repos'. default is ~/.monitor/repos").required(false)
)
)
.subcommand(
Command::new("gen_service")
.about("generate a periphery systemd service file")
)
// .subcommand(
// Command::new("gen-service-file")
// .about("generate a periphery systemd service file")
// )
.subcommand(
Command::new("start")
.about("tools to start periphery as daemon or container")
@@ -146,7 +146,7 @@ fn cli() -> Command {
Command::new("daemon")
.about("start up monitor periphery daemon")
.arg(
arg!(--config_path <PATH> "specify the file path to use for config. default is ~/.monitor/periphery.config.toml")
arg!(--config-path <PATH> "specify the file path to use for config. default is ~/.monitor/periphery.config.toml")
.required(false)
)
.arg(
@@ -165,10 +165,10 @@ fn cli() -> Command {
arg!(--name <NAME> "specify the name of the monitor periphery container. default is monitor-periphery")
)
.arg(
arg!(--config_path <PATH> "specify the file path to use for config. default is ~/.monitor/periphery.config.toml")
arg!(--config-path <PATH> "specify the file path to use for config. default is ~/.monitor/periphery.config.toml")
.required(false)
)
.arg(arg!(--repo_dir <PATH> "specify the folder on host to clone repos into. default is ~/.monitor/repos"))
.arg(arg!(--repo-dir <PATH> "specify the folder on host to clone repos into. default is ~/.monitor/repos"))
.arg(
arg!(--port <PORT> "sets port monitor periphery will run on. default is 8000")
.required(false)
@@ -190,36 +190,36 @@ fn main() {
match matches.subcommand() {
Some(("core", sub_matches)) => {
let core_command = sub_matches.subcommand().expect("\n❌ invalid call, should be 'monitor_cli core <gen_config, start_mongo, start> <flags>' ❌\n");
let core_command = sub_matches.subcommand().expect("\n❌ invalid call, should be 'monitor core <gen-config, start-mongo, start> <flags>' ❌\n");
match core_command {
("gen_config", sub_matches) => gen_core_config(sub_matches),
("start_mongo", sub_matches) => start_mongo(sub_matches),
("gen-config", sub_matches) => gen_core_config(sub_matches),
("start-mongo", sub_matches) => start_mongo(sub_matches),
("start", sub_matches) => start_core(sub_matches),
_ => {
println!("\n❌ invalid call, should be 'monitor_cli core <gen_config, start_mongo, start> <flags>' ❌\n")
println!("\n❌ invalid call, should be 'monitor core <gen-config, start-mongo, start> <flags>' ❌\n")
}
}
}
Some(("periphery", sub_matches)) => {
let periphery_command = sub_matches.subcommand().expect(
"\n❌ invalid call, should be 'monitor_cli periphery <gen_config, start> <flags>' ❌\n",
"\n❌ invalid call, should be 'monitor periphery <gen-config, start> <flags>' ❌\n",
);
match periphery_command {
("gen_config", sub_matches) => gen_periphery_config(sub_matches),
("gen_service", sub_matches) => gen_periphery_service_file(sub_matches),
("gen-config", sub_matches) => gen_periphery_config(sub_matches),
// ("gen-service-file", sub_matches) => gen_periphery_service_file(sub_matches),
("start", sub_matches) => {
let periphery_start_command = sub_matches.subcommand().expect("\n❌ invalid call, should be 'monitor_cli periphery start <daemon, container> <flags>' ❌\n");
let periphery_start_command = sub_matches.subcommand().expect("\n❌ invalid call, should be 'monitor periphery start <daemon, container> <flags>' ❌\n");
match periphery_start_command {
("daemon", sub_matches) => start_periphery_daemon(sub_matches),
("container", sub_matches) => start_periphery_container(sub_matches),
_ => println!("\n❌ invalid call, should be 'monitor_cli periphery start <daemon, container> <flags>' ❌\n")
_ => println!("\n❌ invalid call, should be 'monitor periphery start <daemon, container> <flags>' ❌\n")
}
}
_ => {
println!("\n❌ invalid call, should be 'monitor_cli periphery <gen_config, start>...' ❌\n")
println!("\n❌ invalid call, should be 'monitor periphery <gen-config, start>...' ❌\n")
}
}
}
_ => println!("\n❌ invalid call, should be 'monitor_cli <core, periphery> ...' ❌\n"),
_ => println!("\n❌ invalid call, should be 'monitor <core, periphery> ...' ❌\n"),
}
}