rullst-core 12.1.1

Core runtime, routing engine, and telemetry for the Rullst framework suite.
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
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
78

//! Studio Control Center local web server and API endpoints.

use crate::artisan::studio_views::{
    studio_ai_handler, studio_capital_handler, studio_data_handler, studio_home_handler,
    studio_security_handler, studio_telemetry_handler, studio_traces_handler,
};

#[derive(serde::Serialize)]
struct ApiResponse {
    success: bool,
    message: String,
}

#[cfg_attr(mutants, mutants::skip)]
pub(crate) async fn start_studio_server() {
    println!("📊 Starting Rullst Studio on http://127.0.0.1:5555/studio...");
    let app = axum::Router::new()
        .route(
            "/",
            axum::routing::get(|| async { axum::response::Redirect::permanent("/studio") }),
        )
        .route("/studio", axum::routing::get(studio_home_handler))
        .route("/studio/data", axum::routing::get(studio_data_handler))
        .route("/studio/ai", axum::routing::get(studio_ai_handler))
        .route(
            "/studio/security",
            axum::routing::get(studio_security_handler),
        )
        .route(
            "/studio/telemetry",
            axum::routing::get(studio_telemetry_handler),
        )
        .route(
            "/studio/capital",
            axum::routing::get(studio_capital_handler),
        )
        .route("/studio/traces", axum::routing::get(studio_traces_handler))
        .route(
            "/studio/api/migrations/run",
            axum::routing::post(handle_run_migrations),
        )
        .route(
            "/studio/api/migrations/rollback",
            axum::routing::post(handle_rollback_migrations),
        )
        .route(
            "/studio/api/seeders/run",
            axum::routing::post(handle_run_seeders),
        );

    if let Ok(listener) = tokio::net::TcpListener::bind("127.0.0.1:5555").await {
        let _ = axum::serve(listener, app).await;
    }
}

pub(crate) async fn handle_run_migrations() -> impl axum::response::IntoResponse {
    unavailable_registry("run migrations")
}

pub(crate) async fn handle_rollback_migrations() -> impl axum::response::IntoResponse {
    unavailable_registry("roll back migrations")
}

pub(crate) async fn handle_run_seeders() -> impl axum::response::IntoResponse {
    unavailable_registry("run seeders")
}

fn unavailable_registry(operation: &str) -> (axum::http::StatusCode, axum::Json<ApiResponse>) {
    (
        axum::http::StatusCode::NOT_IMPLEMENTED,
        axum::Json(ApiResponse {
            success: false,
            message: format!(
                "Studio cannot {operation} without an explicitly supplied application registry; use the project CLI"
            ),
        }),
    )
}