manta-server 2.0.0-beta.68

Manta HTTP server — single API that proxies to CSM / Ochami backends.
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

//! Runtime-configuration handler.
//!
//! - `PUT /v2/runtime-configuration` → [`apply_runtime_configuration`]
//!
//! Thin wrapper around
//! [`crate::service::runtime_configuration::apply_runtime_configuration`].

use axum::{Json, http::StatusCode, response::IntoResponse};

use super::{ErrorResponse, RequestCtx, SiteHeader, to_handler_error};
use crate::service;

pub use manta_shared::types::api::runtime_configuration::ApplyRuntimeConfigurationRequest;

/// `PUT /v2/runtime-configuration` — assign a CFS configuration as
/// the desired runtime configuration for a set of nodes.
#[utoipa::path(put, path = "/runtime-configuration", tag = "runtime-configuration",
  params(SiteHeader),
  request_body = ApplyRuntimeConfigurationRequest,
  security(("bearerAuth" = [])),
  responses(
    (status = 200, description = "Runtime configuration applied",  body = serde_json::Value),
    (status = 400, description = "Bad request",                    body = ErrorResponse),
    (status = 401, description = "Unauthorized",                   body = ErrorResponse),
    (status = 403, description = "Forbidden",                      body = ErrorResponse),
    (status = 404, description = "Not found",                      body = ErrorResponse),
    (status = 500, description = "Internal error",                 body = ErrorResponse),
  )
)]
#[tracing::instrument(skip_all)]
pub async fn apply_runtime_configuration(
  ctx: RequestCtx,
  Json(body): Json<ApplyRuntimeConfigurationRequest>,
) -> Result<impl IntoResponse, (StatusCode, Json<ErrorResponse>)> {
  tracing::info!(
    "apply_runtime_configuration cfs_configuration_name={} hosts={} enabled={} dry_run={}",
    body.cfs_configuration_name,
    body.hosts_expression,
    body.enabled,
    body.dry_run
  );
  let infra = ctx.infra();

  let xnames = service::runtime_configuration::apply_runtime_configuration(
    &infra,
    &ctx.token,
    &body.cfs_configuration_name,
    &body.hosts_expression,
    body.enabled,
    body.dry_run,
  )
  .await
  .map_err(to_handler_error)?;

  Ok((
    StatusCode::OK,
    Json(serde_json::json!({
      "dry_run": body.dry_run,
      "cfs_configuration_name": body.cfs_configuration_name,
      "enabled": body.enabled,
      "nodes": xnames,
    })),
  ))
}