net-cli 0.38.2

Unified `net-mesh` command-line tool for the Net mesh
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

//! Explicit opt-in for commands backed only by a fresh Deck supervisor.

use clap::Args;

use crate::error::{invalid_args, CliError};

pub(super) const NOTICE: &str =
    "Starts a temporary supervisor for this command; does not inspect a running node.";

#[derive(Args, Debug)]
pub struct LocalScope {
    #[arg(long, help = NOTICE)]
    pub local: bool,
}

/// Read-only views that can resolve their temporary context without starting it.
#[derive(Args, Debug)]
pub struct InspectableLocalScope {
    #[arg(long, help = NOTICE)]
    pub local: bool,
    /// Inspect context selection without starting a temporary supervisor.
    #[arg(long)]
    pub inspect_target: bool,
}

pub(super) async fn inspect_temporary(
    profile: &crate::config::Profile,
    identity: Option<&std::path::Path>,
    node: u64,
    output: Option<crate::output::OutputFormat>,
) -> Result<(), CliError> {
    inspect_context(profile, identity, node, output, false).await
}

pub(super) async fn inspect_temporary_write(
    profile: &crate::config::Profile,
    identity: Option<&std::path::Path>,
    node: u64,
    output: Option<crate::output::OutputFormat>,
) -> Result<(), CliError> {
    inspect_context(profile, identity, node, output, true).await
}

async fn inspect_context(
    profile: &crate::config::Profile,
    identity: Option<&std::path::Path>,
    node: u64,
    output: Option<crate::output::OutputFormat>,
    identity_required: bool,
) -> Result<(), CliError> {
    crate::context::validate_endpoint(profile)?;
    let mut target = crate::target::inspect(
        profile,
        &super::aggregator::RemoteAttachArgs::default(),
        identity,
        None,
        "temporary_supervisor",
    )
    .await?;
    if identity_required && identity.or(profile.identity.as_deref()).is_none() {
        target.unavailable_identity("execution requires a configured identity");
    }
    #[derive(serde::Serialize)]
    struct View {
        #[serde(flatten)]
        target: crate::target::TargetInspection,
        supervisor_node_id: u64,
        identity_required: bool,
    }
    crate::output::emit_value(
        crate::output::OutputFormat::resolve_oneshot(output),
        &View {
            target,
            supervisor_node_id: node,
            identity_required,
        },
    )
    .map_err(|e| crate::error::generic(format!("write inspection: {e}")))
}

pub(super) fn validate_local(local: bool, command: &str) -> Result<(), CliError> {
    if !local {
        return Err(invalid_args(format!(
            "`{command}` cannot read a running deployment or administer it. \
             Pass --local only for development use. {NOTICE} \
             Remote Deck administration is not implemented; remote aggregator \
             RPC is a separate, explicitly targeted operation."
        )));
    }
    Ok(())
}

pub(super) fn require_local(local: bool, command: &str) -> Result<(), CliError> {
    validate_local(local, command)?;
    // Scope is a safety disclosure, not progress: do not hide it under --quiet
    // or let an environment logging filter suppress it.
    eprintln!("net-mesh: --local: {NOTICE}");
    Ok(())
}