manta-cli 1.62.5

Another CLI for ALPS
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

use crate::cli::commands;
use crate::common::app_context::AppContext;
use crate::common::authentication::get_api_token;
use anyhow::{Context, Error, bail};
use clap::ArgMatches;

/// Dispatch the `manta log` command to stream Kubernetes
/// pod logs for a CFS session or a node's console.
pub async fn handle_log(
  cli_log: &ArgMatches,
  ctx: &AppContext<'_>,
) -> Result<(), Error> {
  let token = get_api_token(ctx.infra.backend, ctx.infra.site_name).await?;

  let user_input = cli_log
    .get_one::<String>("VALUE")
    .context("The 'VALUE' argument is mandatory")?;
  let timestamps = cli_log.get_flag("timestamps");
  let site = ctx.cli
    .configuration
    .sites
    .get(&ctx.cli.configuration.site)
    .context("Site not found in configuration")?;
  let k8s_details = site
    .k8s
    .as_ref()
    .context("k8s section not found in configuration")?;
  match commands::log::exec(
    ctx.infra.backend,
    ctx.infra.site_name,
    &token,
    ctx.infra.shasta_base_url,
    ctx.infra.shasta_root_cert,
    user_input,
    timestamps,
    k8s_details,
  )
  .await
  {
    Ok(_) => {
      println!("Log streaming ended");
      Ok(())
    }
    Err(e) => bail!("{e}"),
  }
}