cli-engine 0.3.3

Rust CLI framework for consistent command modules
Documentation 
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

//! Built-in `env` command group: list/get/set/info for environments.
//!
//! Mounted automatically when [`crate::CliConfig::with_environments`] is used.
//! The group exposes:
//!
//! - `env list`  — list known environments with active flag.
//! - `env get`   — print the active environment name.
//! - `env set <name>` — persist the active environment.
//! - `env info`  — show the fully resolved active environment.

use serde_json::json;

use crate::{
    CommandResult, CommandSpec, GroupSpec, RuntimeCommandSpec, RuntimeGroupSpec, Tier,
    error::CliCoreError,
};

/// Builds the built-in `env` command group.
#[must_use]
pub fn env_command_group() -> RuntimeGroupSpec {
    RuntimeGroupSpec::new(GroupSpec::new("env", "Manage the active environment"))
        .with_command(RuntimeCommandSpec::new_with_context(
            CommandSpec::new("list", "List known environments")
                .no_auth(true)
                .with_system("env"),
            async |ctx| {
                let envs = ctx
                    .middleware
                    .environments
                    .as_ref()
                    .ok_or_else(|| CliCoreError::message("no environment system configured"))?;
                let active = ctx.middleware.env.clone();
                let items: Vec<_> = envs
                    .list()
                    .into_iter()
                    .map(|name| {
                        let is_active = name == active;
                        json!({ "name": name, "active": is_active })
                    })
                    .collect();
                Ok(CommandResult::new(json!(items)))
            },
        ))
        .with_command(RuntimeCommandSpec::new_with_context(
            CommandSpec::new("get", "Show the active environment name")
                .no_auth(true)
                .with_system("env"),
            async |ctx| Ok(CommandResult::new(json!({ "active": ctx.middleware.env }))),
        ))
        .with_command(RuntimeCommandSpec::new_with_context(
            CommandSpec::new("info", "Show the resolved active environment")
                .no_auth(true)
                .with_system("env"),
            async |ctx| {
                let env = ctx.environment()?;
                let oauth = env.oauth.map(|o| {
                    json!({
                        "client_id": o.client_id,
                        "auth_url": o.auth_url,
                        "token_url": o.token_url,
                        "scopes": o.scopes,
                    })
                });
                Ok(CommandResult::new(json!({
                    "name": env.name,
                    "oauth": oauth,
                    "extra": env.extra,
                })))
            },
        ))
        .with_command(RuntimeCommandSpec::new_with_context(
            CommandSpec::new("set", "Set and persist the active environment")
                .no_auth(true)
                .with_system("env")
                .with_tier(Tier::Mutate)
                .mutates(true)
                .with_arg(
                    clap::Arg::new("name")
                        .value_name("NAME")
                        .required(true)
                        .help("Environment to make active (must be a known environment)"),
                ),
            async |ctx| {
                let envs = ctx
                    .middleware
                    .environments
                    .as_ref()
                    .ok_or_else(|| CliCoreError::message("no environment system configured"))?;
                let name = string_arg(&ctx.args, "name");
                if name.is_empty() {
                    return Err(CliCoreError::message("missing environment name"));
                }
                envs.persist_active(&name)?;
                Ok(CommandResult::new(json!({ "active": name })))
            },
        ))
}

/// Reads a required string argument, defaulting to empty when absent.
fn string_arg(args: &serde_json::Map<String, serde_json::Value>, name: &str) -> String {
    args.get(name)
        .and_then(serde_json::Value::as_str)
        .unwrap_or_default()
        .to_owned()
}