manta-cli 2.0.0-beta.68

//! Implements the `manta get nodes` command.
//!
//! Hits `GET /nodes` on `manta-server` to resolve a host expression
//! (xnames, NIDs, host-list syntax) into per-node detail records. The
//! handler then offers four user-facing presentations driven by clap
//! flags: a cluster status summary, a one-line CSV of NIDs, JSON, or a
//! [`crate::output::node`] table.

use anyhow::Error;

use crate::common::app_context::AppContext;
use crate::common::clap_ext::ArgMatchesExt;
use crate::http_client::{MantaClient, OpenApiResultExt};
use crate::output;
use manta_shared::types::api::node::GetNodesParams;

/// Parse CLI arguments into typed [`GetNodesParams`].
///
/// # Errors
///
/// Returns an error if the required `VALUE` positional argument is
/// missing.
fn parse_nodes_params(
  cli_args: &clap::ArgMatches,
) -> Result<GetNodesParams, Error> {
  let xname = cli_args.req_str("VALUE")?.to_string();

  Ok(GetNodesParams {
    host_expression: xname,
    include_siblings: cli_args.get_flag("include-siblings"),
    status_filter: cli_args.opt_string("status"),
  })
}

/// CLI adapter for `manta get nodes`.
///
/// Consumes clap matches for the `nodes` subcommand (positional host
/// expression, `--include-siblings`, `--status`, `--output`,
/// `--nids-only-one-line`, `--summary-status`), calls the server once,
/// and renders the response in the requested form.
///
/// # Errors
///
/// Returns an error if the positional host expression is missing, the
/// HTTP request fails, JSON serialisation fails (for `--output json` or
/// the cluster-status round-trip), or `--output` holds an unrecognised
/// value.
pub async fn exec(
  ctx: &AppContext<'_>,
  token: &str,
  cli_args: &clap::ArgMatches,
) -> Result<(), Error> {
  let params = parse_nodes_params(cli_args)?;
  let nids_only = cli_args.get_flag("nids-only-one-line");
  let output_opt = cli_args.opt_str("output");
  let status_summary = cli_args.get_flag("summary-status");

  let client = MantaClient::from_app_ctx(ctx, Some(token))?;
  let node_details_list = client
    .openapi
    .get_nodes(
      Some(params.include_siblings),
      params.status_filter.as_deref(),
      &params.host_expression,
      client.site_name(),
    )
    .await
    .into_anyhow()
    .await?;

  output::node::render_node_details(
    node_details_list,
    nids_only,
    false,
    status_summary,
    output_opt,
  )
}

#[cfg(test)]
mod tests {
  use super::*;

  fn nodes_cmd() -> clap::Command {
    crate::build::get::subcommand_get_node_details()
  }

  #[test]
  fn parse_xname_only() {
    let matches = nodes_cmd().get_matches_from(["nodes", "x1000c0s0b0n0"]);
    let params = parse_nodes_params(&matches).unwrap();
    assert_eq!(params.host_expression, "x1000c0s0b0n0");
    assert!(!params.include_siblings);
    assert!(params.status_filter.is_none());
  }

  #[test]
  fn parse_with_siblings() {
    let matches = nodes_cmd().get_matches_from([
      "nodes",
      "x1000c0s0b0n0",
      "--include-siblings",
    ]);
    let params = parse_nodes_params(&matches).unwrap();
    assert!(params.include_siblings);
  }

  #[test]
  fn parse_with_status() {
    let matches = nodes_cmd().get_matches_from([
      "nodes",
      "x1000c0s0b0n0",
      "--status",
      "ON",
    ]);
    let params = parse_nodes_params(&matches).unwrap();
    assert_eq!(params.status_filter.as_deref(), Some("ON"));
  }
}