mgt 0.2.1

Command line tool to analyze the WildFly management model.
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

//! CLI entry point and subcommand dispatch for `mgt`.

mod app;
mod args;
mod command;
mod completion;
mod constants;
mod container;
mod download;
mod json;
mod label;
mod neo4j;
mod progress;
mod registry;

use crate::args::{meta_item_argument, meta_items_argument};
use crate::command::{
    analyze, browse, completions, feature_packs_cmd, images, ps, push, start, stop, update,
    versions,
};
use crate::completion::{complete_multiple_identifiers, complete_single_identifier};
use crate::registry::{images_registry, init_registries, packs_registry};
use anyhow::Result;
use app::build_app;
use clap_complete::engine::ArgValueCompleter;
use wildfly_meta::{DslOptions, MetaItem, parse_meta_item, parse_meta_items};

/// Extends [`build_app()`] with value parsers and tab-completion handlers.
fn build_app_full() -> clap::Command {
    build_app()
        .mut_subcommand("analyze", |sub_cmd| {
            sub_cmd.mut_arg("identifier", |arg| {
                arg.value_parser(parse_single)
                    .add(ArgValueCompleter::new(complete_single_identifier))
            })
        })
        .mut_subcommand("push", |sub_cmd| {
            sub_cmd
                .mut_arg("identifier", |arg| {
                    arg.value_parser(parse_list)
                        .add(ArgValueCompleter::new(complete_multiple_identifiers))
                })
                .mut_arg("chunks", |arg| arg.value_parser(clap::value_parser!(u16)))
        })
        .mut_subcommand("start", |sub_cmd| {
            sub_cmd.mut_arg("identifier", |arg| {
                arg.value_parser(parse_list)
                    .add(ArgValueCompleter::new(complete_multiple_identifiers))
            })
        })
        .mut_subcommand("stop", |sub_cmd| {
            sub_cmd.mut_arg("identifier", |arg| {
                arg.value_parser(parse_list)
                    .add(ArgValueCompleter::new(complete_multiple_identifiers))
            })
        })
        .mut_subcommand("browse", |sub_cmd| {
            sub_cmd.mut_arg("identifier", |arg| {
                arg.value_parser(parse_list)
                    .add(ArgValueCompleter::new(complete_multiple_identifiers))
            })
        })
}

#[tokio::main]
async fn main() -> Result<()> {
    init_registries().await?;

    clap_complete::CompleteEnv::with_factory(build_app_full).complete();

    let matches = build_app_full().get_matches();
    let json = matches.get_flag("json");

    match matches.subcommand() {
        Some(("analyze", m)) => analyze(&meta_item_argument(m)).await,
        Some(("push", m)) => {
            let chunk_size = m.get_one::<u16>("chunks").copied().unwrap_or(0);
            push(&meta_items_argument(m), chunk_size).await
        }
        Some(("start", m)) => start(&meta_items_argument(m), json).await,
        Some(("stop", m)) => {
            let all = m.get_flag("all");
            let items = m.get_one::<Vec<MetaItem>>("identifier");
            stop(items.map(|v| v.as_slice()), all, json).await
        }
        Some(("versions", _)) => {
            versions(json);
            Ok(())
        }
        Some(("feature-packs", _)) => {
            feature_packs_cmd(json);
            Ok(())
        }
        Some(("images", m)) => {
            let wildfly = m.get_flag("wildfly");
            let feature_packs = m.get_flag("feature-packs");
            images(wildfly, feature_packs).await
        }
        Some(("ps", _)) => ps(json).await,
        Some(("browse", m)) => {
            for item in &meta_items_argument(m) {
                browse(item)?;
            }
            Ok(())
        }
        Some(("update", _)) => update().await,
        Some(("completions", m)) => completions(m),
        _ => unreachable!("Unknown subcommand"),
    }
}

// ------------------------------------------------------ validation

/// Clap value parser that converts a CLI string into a single [`MetaItem`].
fn parse_single(input: &str) -> Result<MetaItem, String> {
    parse_meta_item(input, images_registry(), packs_registry()).map_err(|err| err.to_string())
}

/// Clap value parser that converts a comma-separated or range string into a list of [`MetaItem`]s.
fn parse_list(input: &str) -> Result<Vec<MetaItem>, String> {
    parse_meta_items(
        input,
        images_registry(),
        packs_registry(),
        &DslOptions::all(),
        &DslOptions::none(),
    )
    .map_err(|err| err.to_string())
}