manta-cli 2.0.0-beta.6

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

//! Node CRUD endpoints (console lives in `console.rs`).

use serde_json::Value;

use manta_shared::shared::dto::NodeDetails;
use manta_shared::shared::params::node::GetNodesParams;

use super::{MantaClient, QueryBuilder};

impl MantaClient {
  pub async fn get_nodes(
    &self,
    token: &str,
    params: &GetNodesParams,
  ) -> anyhow::Result<Vec<NodeDetails>> {
    let q = QueryBuilder::new()
      .pair("xname", params.xname.clone())
      .flag("include_siblings", params.include_siblings)
      .opt("status", &params.status_filter)
      .build();
    self.get_json(token, "/nodes", &q).await
  }

  pub async fn add_node(
    &self,
    token: &str,
    id: &str,
    group: &str,
    enabled: bool,
    arch: Option<String>,
  ) -> anyhow::Result<()> {
    let body = serde_json::json!({ "id": id, "group": group, "enabled": enabled, "arch": arch });
    let _: Value = self.post_json(token, "/nodes", &body).await?;
    Ok(())
  }

  pub async fn delete_node(&self, token: &str, id: &str) -> anyhow::Result<()> {
    self
      .delete_no_content(token, &format!("/nodes/{}", id))
      .await
  }
}