ax 2.18.2

ax distributed event databank and command line tool
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

mod get;
mod local;
mod schema;
mod set;
mod unset;

use std::str::FromStr;

use crate::cmd::AxCliCommand;
use ax_core::settings::{Scope, ScopeError};
use futures::Future;
use get::GetOpt;
use local::SettingsLocalOpts;
use schema::SchemaOpt;
use set::SetOpt;
use std::convert::TryFrom;
use unset::UnsetOpt;

#[derive(clap::Subcommand, Debug, Clone)]
/// manage node settings
pub enum SettingsOpts {
    /// Configure settings of a node
    Set(SetOpt),
    /// Remove settings from a node
    Unset(UnsetOpt),
    /// Get settings from a node
    Get(GetOpt),
    /// Get setting schemas from a node
    Schema(SchemaOpt),
    /// Locally get/set/unset settings directly to settings.db file inside an ax-data directory
    #[command(subcommand, arg_required_else_help(true))]
    Local(SettingsLocalOpts),
}

pub fn run(opts: SettingsOpts, json: bool) -> Box<dyn Future<Output = ()> + Unpin> {
    match opts {
        SettingsOpts::Set(opt) => set::SettingsSet::output(opt, json),
        SettingsOpts::Get(opt) => get::SettingsGet::output(opt, json),
        SettingsOpts::Schema(opt) => schema::SettingsSchema::output(opt, json),
        SettingsOpts::Unset(opt) => unset::SettingsUnset::output(opt, json),
        SettingsOpts::Local(opt) => local::run(opt, json),
    }
}

fn parse_scope(value: &str) -> Result<Scope, ScopeError> {
    if !value.starts_with('/') {
        return Err(ScopeError::MalformedScope(value.to_string()));
    }
    if value == "/" {
        Scope::from_str("com.actyx")
    } else {
        Scope::try_from(format!("com.actyx{}", value))
    }
}

fn print_scope(scope: Scope) -> String {
    let scope = scope.drop_first();
    if scope.is_root() {
        // printing <ROOT> incorrectly as `/`, but this can’t ever happen anyway due to the above function
        "/".to_string()
    } else {
        format!("/{}", scope)
    }
}