mockforge-ui 0.3.88

Admin UI for MockForge - web-based interface for managing mock servers
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

//! Pillars: [DevX]
//!
//! # MockForge UI
//!
//! Web-based admin interface for managing mock servers.

pub mod audit;
pub mod auth;
pub mod handlers;
pub mod rbac;
pub mod routes;
// Templates module removed; static assets in `static/` are the single source of truth
pub mod models;
pub mod prometheus_client;
pub mod time_travel_handlers;

pub use models::{RequestLog, RouteInfo, ServerStatus, SystemInfo};
pub use routes::create_admin_router;

use std::net::SocketAddr;

/// Start the admin UI server
///
/// # Arguments
/// * `addr` - Address to bind the admin server to
/// * `http_server_addr` - HTTP server address
/// * `ws_server_addr` - WebSocket server address
/// * `grpc_server_addr` - gRPC server address
/// * `graphql_server_addr` - GraphQL server address
/// * `api_enabled` - Whether API endpoints are enabled
/// * `prometheus_url` - Prometheus metrics URL
/// * `chaos_api_state` - Optional chaos API state for hot-reload support
/// * `latency_injector` - Optional latency injector for hot-reload support
/// * `mockai` - Optional MockAI instance for hot-reload support
/// * `continuum_config` - Optional Reality Continuum configuration
/// * `virtual_clock` - Optional virtual clock for time-based progression
/// * `recorder` - Optional traffic recorder
/// * `federation` - Optional federation instance
/// * `vbr_engine` - Optional VBR engine
#[allow(clippy::too_many_arguments)]
pub async fn start_admin_server(
    addr: SocketAddr,
    http_server_addr: Option<SocketAddr>,
    ws_server_addr: Option<SocketAddr>,
    grpc_server_addr: Option<SocketAddr>,
    graphql_server_addr: Option<SocketAddr>,
    api_enabled: bool,
    prometheus_url: String,
    chaos_api_state: Option<std::sync::Arc<mockforge_chaos::api::ChaosApiState>>,
    latency_injector: Option<
        std::sync::Arc<tokio::sync::RwLock<mockforge_core::latency::LatencyInjector>>,
    >,
    mockai: Option<
        std::sync::Arc<tokio::sync::RwLock<mockforge_core::intelligent_behavior::MockAI>>,
    >,
    continuum_config: Option<mockforge_core::ContinuumConfig>,
    virtual_clock: Option<std::sync::Arc<mockforge_core::VirtualClock>>,
    recorder: Option<std::sync::Arc<mockforge_recorder::Recorder>>,
    federation: Option<std::sync::Arc<mockforge_federation::Federation>>,
    vbr_engine: Option<std::sync::Arc<mockforge_vbr::VbrEngine>>,
) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let app = create_admin_router(
        http_server_addr,
        ws_server_addr,
        grpc_server_addr,
        graphql_server_addr,
        api_enabled,
        addr.port(),
        prometheus_url,
        chaos_api_state,
        latency_injector,
        mockai,
        continuum_config,
        virtual_clock,
        recorder,
        federation,
        vbr_engine,
    );

    tracing::info!("Starting MockForge Admin UI on {}", addr);

    let listener = tokio::net::TcpListener::bind(addr).await.map_err(|e| {
        format!(
            "Failed to bind Admin UI server to port {}: {}\n\
             Hint: The port may already be in use. Try using a different port with --admin-port or check if another process is using this port with: lsof -i :{} or netstat -tulpn | grep {}",
            addr.port(), e, addr.port(), addr.port()
        )
    })?;

    axum::serve(listener, app).await?;

    Ok(())
}

// Generated by build.rs — embeds real UI assets when available, placeholders otherwise.
include!(concat!(env!("OUT_DIR"), "/ui_content.rs"));

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_get_admin_html() {
        let html = get_admin_html();
        assert!(!html.is_empty());
        assert!(html.contains("<!DOCTYPE html>") || html.contains("<html"));
    }

    #[test]
    fn test_get_admin_css() {
        let _css = get_admin_css();
        // Content may be a placeholder when UI is not built
    }

    #[test]
    fn test_get_admin_js() {
        let _js = get_admin_js();
        // Content may be a placeholder when UI is not built
    }
}