aegis-orchestrator 0.15.0-pre-alpha

100monkeys.ai AEGIS orchestrator CLI and daemon
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

// Copyright (c) 2026 100monkeys.ai
// SPDX-License-Identifier: AGPL-3.0
//! Cluster status and node handlers.

use std::sync::Arc;

use axum::extract::{Query, State};
use axum::Json;

use aegis_orchestrator_core::presentation::keycloak_auth::ScopeGuard;

use crate::daemon::cluster_helpers::{cluster_status_view, load_cluster_nodes};
use crate::daemon::handlers::{bounded_limit, LimitQuery};
use crate::daemon::state::AppState;

pub(crate) async fn cluster_status_handler(
    State(state): State<Arc<AppState>>,
    scope_guard: ScopeGuard,
) -> Result<
    impl axum::response::IntoResponse,
    (axum::http::StatusCode, axum::Json<serde_json::Value>),
> {
    scope_guard.require("node:read")?;
    Ok(Json(cluster_status_view(&state).await))
}

pub(crate) async fn cluster_nodes_handler(
    State(state): State<Arc<AppState>>,
    scope_guard: ScopeGuard,
    Query(query): Query<LimitQuery>,
) -> Result<
    impl axum::response::IntoResponse,
    (axum::http::StatusCode, axum::Json<serde_json::Value>),
> {
    scope_guard.require("node:list")?;
    let nodes = load_cluster_nodes(&state).await;
    let limit = bounded_limit(query.limit, nodes.len().max(1), 500);
    Ok(Json(serde_json::json!({
        "source": if state.cluster_repo.is_some() { "cluster_repository" } else { "local_fallback" },
        "items": nodes.into_iter().take(limit).collect::<Vec<_>>(),
    })))
}