csm-rs 0.83.1

A library for Shasta
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
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
131

use crate::{
  cfs::{
    configuration::http_client::v2::types::cfs_configuration_response::CfsConfigurationResponse,
    session::http_client::v2::types::CfsSessionGetResponse,
  },
  error::Error,
};

#[derive(Debug)]
pub struct ClusterDetails {
  pub hsm_group_label: String,
  pub most_recent_cfs_configuration_name_created: CfsConfigurationResponse,
  pub most_recent_cfs_session_name_created: CfsSessionGetResponse,
  pub members: Vec<String>,
}

pub async fn get_details(
  shasta_token: &str,
  shasta_base_url: &str,
  shasta_root_cert: &[u8],
  hsm_group_name: &str,
) -> Result<Vec<ClusterDetails>, Error> {
  let mut clusters_details = vec![];

  // Get HSM groups matching cluster name
  let hsm_group_value_vec = crate::hsm::group::http_client::get_hsm_group_vec(
    shasta_token,
    shasta_base_url,
    shasta_root_cert,
    Some(&hsm_group_name.to_string()),
  )
  .await?;

  for hsm_group in hsm_group_value_vec {
    let hsm_group_name = hsm_group.label.as_str();

    let hsm_group_members: String =
      crate::hsm::group::utils::get_member_vec_from_hsm_group(&hsm_group)
        .join(",");

    // Get all CFS sessions
    let mut cfs_session_vec = crate::cfs::session::get_and_sort(
      shasta_token,
      shasta_base_url,
      shasta_root_cert,
      None,
      None,
      None,
      None,
      Some(true),
    )
    .await?;

    crate::cfs::session::utils::filter_by_hsm(
      shasta_token,
      shasta_base_url,
      shasta_root_cert,
      &mut cfs_session_vec,
      &[hsm_group_name.to_string()],
      None,
      true,
    )
    .await?;

    let most_recent_cfs_session;
    let cfs_configuration;

    for cfs_session_value in cfs_session_vec {
      // println!("cfs_session_value:\n{:#?}", cfs_session_value);
      let target_groups = cfs_session_value
        .target
        .as_ref()
        .unwrap()
        .groups
        .as_ref()
        .unwrap();
      let ansible_limit = cfs_session_value
        .ansible
        .as_ref()
        .unwrap()
        .limit
        .as_ref()
        .unwrap();

      // Check CFS session is linkged to HSM GROUP name or any of its members
      if target_groups
        .iter()
        .map(|target_group| target_group.name.as_ref())
        .collect::<Vec<&str>>()
        .contains(&hsm_group_name)
        || ansible_limit.contains(&hsm_group_members)
      {
        most_recent_cfs_session = cfs_session_value;

        // Get CFS configuration linked to CFS session related to HSM GROUP or any of its
        // members
        let cfs_configuration_vec =
          crate::cfs::configuration::http_client::v2::get(
            shasta_token,
            shasta_base_url,
            shasta_root_cert,
            Some(
              &most_recent_cfs_session
                .configuration
                .as_ref()
                .unwrap()
                .name
                .clone()
                .unwrap(),
            ),
          )
          .await?;

        cfs_configuration = cfs_configuration_vec.first().unwrap();

        let cluster_details = ClusterDetails {
          hsm_group_label: hsm_group_name.to_string(),
          most_recent_cfs_configuration_name_created: cfs_configuration.clone(),
          most_recent_cfs_session_name_created: most_recent_cfs_session,
          members: hsm_group.get_members(),
        };

        clusters_details.push(cluster_details);

        break;
      }
    }
  }

  Ok(clusters_details)
}