plane 0.5.5

Session backend orchestrator for ambitious browser-based apps.
Documentation 
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

use super::{core::Controller, error::IntoApiError};
use axum::{
    extract::{Path, State},
    response::Response,
    Json,
};
use plane_common::{
    names::DroneName,
    types::{ClusterName, DrainResult},
};

async fn drain(
    controller: &Controller,
    cluster: &ClusterName,
    drone: &DroneName,
) -> Result<DrainResult, Response> {
    let drone_id = controller
        .db
        .node()
        .get_id(cluster, drone)
        .await
        .or_internal_error("Database error")?
        .or_not_found("Drone does not exist")?;

    println!("Draining drone with id {}", drone_id);

    let updated = controller
        .db
        .drone()
        .drain(drone_id)
        .await
        .or_internal_error("Database error")?;

    println!("Done");

    Ok(DrainResult { updated })
}

pub async fn handle_drain(
    Path((cluster, drone)): Path<(ClusterName, DroneName)>,
    State(controller): State<Controller>,
) -> Result<Json<DrainResult>, Response> {
    let result = drain(&controller, &cluster, &drone).await?;
    Ok(Json(result))
}