nomoreide-daemon 0.20.1

The NoMoreIDE daemon: the local HTTP server, its route registry, and the embedded web dashboard.
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
46
47
48
49

//! Starting and stopping named groups of services.

use crate::server::app::AppState;
use crate::server::errors::{method_not_allowed, mutation_error};
use axum::extract::{Path, State};
use axum::response::{IntoResponse, Response};
use axum::routing::post;
use axum::{Json, Router};
use nomoreide_daemon_client::protocol::BundleMutationEnvelope;

pub(crate) fn routes() -> Router<AppState> {
    Router::new()
        // Pattern routes in the reference, so a wrong method is its own 405
        // rather than the shell's 404.
        .route(
            "/api/bundles/:name/start",
            post(start_bundle).fallback(method_not_allowed),
        )
        .route(
            "/api/bundles/:name/stop",
            post(stop_bundle).fallback(method_not_allowed),
        )
}

async fn start_bundle(State(state): State<AppState>, Path(name): Path<String>) -> Response {
    bundle_action(state, name, BundleAction::Start).await
}

async fn stop_bundle(State(state): State<AppState>, Path(name): Path<String>) -> Response {
    bundle_action(state, name, BundleAction::Stop).await
}

enum BundleAction {
    Start,
    Stop,
}

/// Ordering, dependency expansion, and how far a partial failure gets are all
/// the runtime's policy; the route only reports the statuses it hands back.
async fn bundle_action(state: AppState, name: String, action: BundleAction) -> Response {
    let result = match action {
        BundleAction::Start => state.runtime.start_bundle(&name).await,
        BundleAction::Stop => state.runtime.stop_bundle(&name).await,
    };
    match result {
        Ok(statuses) => Json(BundleMutationEnvelope { ok: true, statuses }).into_response(),
        Err(error) => mutation_error(error),
    }
}