manta-cli 1.64.0

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
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
130

//! Implements the `manta console target-ansible` command.

use anyhow::{Context, Error, bail};
use manta_backend_dispatcher::{
  interfaces::{cfs::CfsTrait, console::ConsoleTrait},
  types::K8sDetails,
};

use crate::{
  cli::commands::console_common,
  common::authorization::get_groups_names_available,
  manta_backend_dispatcher::StaticBackendDispatcher,
};

/// Open an interactive console to a CFS session container.
pub async fn exec(
  backend: &StaticBackendDispatcher,
  site_name: &str,
  token: &str,
  settings_hsm_group_name_opt: Option<&str>,
  shasta_base_url: &str,
  shasta_root_cert: &[u8],
  session_name: &str,
  k8s: &K8sDetails,
) -> Result<(), Error> {
  let hsm_group_name_vec = get_groups_names_available(
    backend,
    token,
    None,
    settings_hsm_group_name_opt,
  )
  .await?;

  let cfs_session_vec = backend
    .get_and_filter_sessions(
      token,
      shasta_base_url,
      shasta_root_cert,
      Vec::new(),
      Vec::new(),
      None,
      None,
      None,
      None,
      Some(&session_name.to_string()),
      None,
      None,
    )
    .await
    .context("Failed to get CFS sessions")?;

  if cfs_session_vec.is_empty() {
    bail!("No CFS session found");
  }

  let cfs_session_details =
    cfs_session_vec.first().context("No CFS session found")?;

  if cfs_session_details
    .target
    .as_ref()
    .context("CFS session target is missing")?
    .definition
    .as_ref()
    .context("CFS session target definition is missing")?
    .ne("image")
  {
    bail!(
      "CFS session found {} is type not \
       'image'",
      cfs_session_details.name
    );
  }

  if cfs_session_details
    .status
    .as_ref()
    .context("CFS session status is missing")?
    .session
    .as_ref()
    .context("CFS session status session is missing")?
    .status
    .ne(&Some("running".to_string()))
  {
    bail!(
      "CFS session found {} state is not \
       'running'",
      cfs_session_details.name
    );
  }

  if !cfs_session_details
    .target
    .as_ref()
    .context("CFS session target is missing")?
    .groups
    .as_ref()
    .context("CFS session target groups is missing")?
    .iter()
    .any(|group| hsm_group_name_vec.contains(&group.name.to_string()))
  {
    bail!(
      "CFS session found {} is not related \
       to any available HSM groups {:?}",
      cfs_session_details.name,
      hsm_group_name_vec
    );
  }

  tracing::info!("session: {}", session_name);

  let (width, height) = crossterm::terminal::size()?;

  let (a_input, a_output) = backend
    .attach_to_session_console(
      token,
      site_name,
      session_name,
      width,
      height,
      k8s,
    )
    .await?;

  let result = console_common::run_console_loop(a_input, a_output).await;

  console_common::handle_console_result(result);

  Ok(())
}