manta-cli 2.0.0-beta.9

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

//! IMS image endpoints: list, bulk-delete.

use anyhow::Context;
use serde_json::Value;

use manta_shared::shared::dto::Image;
use manta_shared::shared::params::image::GetImagesParams;

use super::{MantaClient, QueryBuilder};

/// Image entry as returned by `GET /api/v1/images`.
#[derive(serde::Deserialize)]
struct ImageEntry {
  image: serde_json::Value,
  configuration_name: String,
  image_id: String,
  is_linked: bool,
}

impl MantaClient {
  pub async fn get_images(
    &self,
    token: &str,
    params: &GetImagesParams,
  ) -> anyhow::Result<Vec<(Image, String, String, bool)>> {
    let q = QueryBuilder::new()
      .opt("id", &params.id)
      .opt("hsm_group", &params.hsm_group)
      .opt_display("limit", &params.limit)
      .build();
    let entries: Vec<ImageEntry> = self.get_json(token, "/images", &q).await?;
    entries
      .into_iter()
      .map(|e| {
        let img: Image = serde_json::from_value(e.image)
          .context("Failed to deserialize image")?;
        Ok((img, e.configuration_name, e.image_id, e.is_linked))
      })
      .collect()
  }

  pub async fn delete_images(
    &self,
    token: &str,
    ids: &[&str],
    dry_run: bool,
  ) -> anyhow::Result<Value> {
    let q = [("ids", ids.join(",")), ("dry_run", dry_run.to_string())];
    self.delete_json_with_query(token, "/images", &q).await
  }
}