manta-cli 2.0.0-beta.17

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

//! SAT file apply endpoints.
//!
//! The three `apply_sat_*` methods POST one SAT element at a time and
//! drive the CLI's plan-based dispatcher.

use std::collections::HashMap;

use serde_json::Value;

use super::MantaClient;

impl MantaClient {
  /// `POST /api/v1/sat-file/configurations` — apply one SAT
  /// configuration entry. Returns the created `CfsConfigurationResponse`
  /// as `Value` (the dispatcher passes it straight through to the
  /// summary). `dry_run` returns a mock response with the configuration
  /// name set.
  pub async fn apply_sat_configuration(
    &self,
    token: &str,
    configuration: &Value,
    overwrite: bool,
    dry_run: bool,
  ) -> anyhow::Result<Value> {
    let body = serde_json::json!({
      "configuration": configuration,
      "overwrite": overwrite,
      "dry_run": dry_run,
    });
    self.post_json(token, "/sat-file/configurations", &body).await
  }

  /// `POST /api/v1/sat-file/images` — apply one SAT image entry.
  /// `ref_lookup` carries the CLI's accumulated `ref_name.or(name) ->
  /// image_id` map; the backend uses it to resolve `base.image_ref`.
  /// Returns the created `Image` as `Value`.
  #[allow(clippy::too_many_arguments)]
  pub async fn apply_sat_image(
    &self,
    token: &str,
    image: &Value,
    ref_lookup: &HashMap<String, String>,
    ansible_verbosity: Option<u8>,
    ansible_passthrough: Option<&str>,
    watch_logs: bool,
    timestamps: bool,
    dry_run: bool,
  ) -> anyhow::Result<Value> {
    let body = serde_json::json!({
      "image": image,
      "ref_lookup": ref_lookup,
      "ansible_verbosity": ansible_verbosity,
      "ansible_passthrough": ansible_passthrough,
      "watch_logs": watch_logs,
      "timestamps": timestamps,
      "dry_run": dry_run,
    });
    self.post_json(token, "/sat-file/images", &body).await
  }

  /// `POST /api/v1/sat-file/session-templates` — apply one SAT
  /// session_template entry. Returns the server's
  /// `PostSatSessionTemplateResponse` body (`{ template, session }`)
  /// as `Value`.
  pub async fn apply_sat_session_template(
    &self,
    token: &str,
    session_template: &Value,
    ref_lookup: &HashMap<String, String>,
    reboot: bool,
    dry_run: bool,
  ) -> anyhow::Result<Value> {
    let body = serde_json::json!({
      "session_template": session_template,
      "ref_lookup": ref_lookup,
      "reboot": reboot,
      "dry_run": dry_run,
    });
    self.post_json(token, "/sat-file/session-templates", &body).await
  }
}