oxios-web 0.1.1

Web dashboard channel for Oxios
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
65
66
67
68
69
70
71
72
73
74
75
76
77

//! REST API routes for system resource monitoring.
//!
//! Exposes endpoints for current resource snapshots, historical data,
//! and overload detection via the Oxios kernel's ResourceMonitor.

use std::sync::Arc;

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

use crate::error::AppError;
use crate::server::AppState;

// ---------------------------------------------------------------------------
// Query Parameters
// ---------------------------------------------------------------------------

/// Query parameters for history endpoint.
#[derive(Debug, Deserialize)]
pub struct HistoryQuery {
    /// Number of most recent snapshots to return.
    #[serde(default = "default_last_n")]
    pub last_n: usize,
}

fn default_last_n() -> usize {
    30
}

// ---------------------------------------------------------------------------
// Handlers
// ---------------------------------------------------------------------------

/// GET /api/resources — Get current resource snapshot.
pub(crate) async fn handle_resource_snapshot(
    State(state): State<Arc<AppState>>,
) -> Result<Json<serde_json::Value>, AppError> {
    let snapshot = state.kernel.infra.resource_snapshot();
    serde_json::to_value(&snapshot)
        .map(Json)
        .map_err(|e| AppError::Internal(format!("failed to serialize snapshot: {}", e)))
}

/// GET /api/resources/history — Get historical snapshots.
pub(crate) async fn handle_resource_history(
    State(state): State<Arc<AppState>>,
    Query(params): Query<HistoryQuery>,
) -> Result<Json<serde_json::Value>, AppError> {
    let snapshots = state.kernel.infra.resource_history(params.last_n);
    let count = snapshots.len();
    serde_json::to_value(serde_json::json!({
        "snapshots": snapshots,
        "count": count,
    }))
    .map(Json)
    .map_err(|e| AppError::Internal(format!("failed to serialize history: {}", e)))
}

/// GET /api/resources/overload — Check if system is overloaded.
pub(crate) async fn handle_resource_overload(
    State(state): State<Arc<AppState>>,
) -> Result<Json<serde_json::Value>, AppError> {
    let overloaded = state.kernel.infra.is_overloaded();
    let rm_config = &state.kernel.infra.config().resource_monitor;

    serde_json::to_value(serde_json::json!({
        "overloaded": overloaded,
        "threshold": {
            "cpu_percent": rm_config.cpu_threshold,
            "memory_percent": rm_config.memory_threshold,
            "load_avg": rm_config.load_threshold,
        },
    }))
    .map(Json)
    .map_err(|e| AppError::Internal(format!("failed to serialize overload status: {}", e)))
}