manta-cli 2.0.0-beta.53

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

//! Power on/off/reset endpoints.
//!
//! - [`MantaClient::power`] POSTs to `/power` and returns
//!   immediately with the PCS transition start output
//!   (`{ "transitionID": …, "operation": … }`).
//! - [`MantaClient::power_transition`] snapshots an in-flight
//!   transition via `GET /power/transitions/{id}` — used by the
//!   CLI poll loop in `power_common::poll_until_done`.
//!
//! Both responses come back as untyped `serde_json::Value` — the
//! dispatcher/typed shapes (`TransitionStartOutput`,
//! `TransitionResponse`) live in csm-rs / manta-backend-dispatcher;
//! the CLI walks the JSON directly. Wire field names are PCS-style
//! camelCase (`transitionID`, `transitionStatus`, `taskCounts.…`).

use serde_json::Value;

pub use manta_shared::types::wire::power::{
  PowerAction, PowerRequest, PowerTargetType,
};

use super::MantaClient;

impl MantaClient {
  /// `POST /api/v1/power` — start a PCS power transition and return
  /// immediately. Does **not** block until the transition completes.
  /// The response carries the PCS `transitionID` the caller then
  /// polls with [`MantaClient::power_transition`].
  ///
  /// The server maps `(action, force)` to the PCS wire-level
  /// operation (`"on"` / `"soft-off"` / `"force-off"` /
  /// `"soft-restart"` / `"hard-restart"`).
  pub async fn power(
    &self,
    token: &str,
    req: &PowerRequest,
  ) -> anyhow::Result<Value> {
    self.post_json(token, "/power", req).await
  }

  /// `GET /api/v1/power/transitions/{id}` — snapshot an in-flight
  /// (or completed) power transition. Returns the full PCS
  /// `TransitionResponse` shape as a JSON value: `transitionStatus`,
  /// `taskCounts` (`total`, `failed`, `in-progress`, `succeeded`,
  /// `new`, `un-supported`), and per-task detail in `tasks`.
  /// Termination condition for the CLI poll loop:
  /// `transitionStatus == "completed"`.
  pub async fn power_transition(
    &self,
    token: &str,
    transition_id: &str,
  ) -> anyhow::Result<Value> {
    self
      .get_json(token, &format!("/power/transitions/{transition_id}"), &[])
      .await
  }
}