wifi-densepose-mat 0.3.2

Mass Casualty Assessment Tool - WiFi-based disaster survivor detection
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

//! REST API endpoints for WiFi-DensePose MAT disaster response monitoring.
//!
//! This module provides a complete REST API and WebSocket interface for
//! managing disaster events, zones, survivors, and alerts in real-time.
//!
//! ## Endpoints
//!
//! ### Disaster Events
//! - `GET /api/v1/mat/events` - List all disaster events
//! - `POST /api/v1/mat/events` - Create new disaster event
//! - `GET /api/v1/mat/events/{id}` - Get event details
//!
//! ### Zones
//! - `GET /api/v1/mat/events/{id}/zones` - List zones for event
//! - `POST /api/v1/mat/events/{id}/zones` - Add zone to event
//!
//! ### Survivors
//! - `GET /api/v1/mat/events/{id}/survivors` - List survivors in event
//!
//! ### Alerts
//! - `GET /api/v1/mat/events/{id}/alerts` - List alerts for event
//! - `POST /api/v1/mat/alerts/{id}/acknowledge` - Acknowledge alert
//!
//! ### Scan Control
//! - `POST /api/v1/mat/scan/csi` - Push raw CSI data into detection pipeline
//! - `POST /api/v1/mat/scan/control` - Start/stop/pause/resume scanning
//! - `GET /api/v1/mat/scan/status` - Get detection pipeline status
//!
//! ### Domain Events
//! - `GET /api/v1/mat/events/domain` - List domain events from event store
//!
//! ### WebSocket
//! - `WS /ws/mat/stream` - Real-time survivor and alert stream

pub mod dto;
pub mod error;
pub mod handlers;
pub mod state;
pub mod websocket;

use axum::{
    routing::{get, post},
    Router,
};

pub use dto::*;
pub use error::ApiError;
pub use state::AppState;

/// Create the MAT API router with all endpoints.
///
/// # Example
///
/// ```rust,no_run
/// use wifi_densepose_mat::api::{create_router, AppState};
///
/// #[tokio::main]
/// async fn main() {
///     let state = AppState::new();
///     let app = create_router(state);
///     // ... serve with axum
/// }
/// ```
pub fn create_router(state: AppState) -> Router {
    Router::new()
        // Event endpoints
        .route(
            "/api/v1/mat/events",
            get(handlers::list_events).post(handlers::create_event),
        )
        .route("/api/v1/mat/events/:event_id", get(handlers::get_event))
        // Zone endpoints
        .route(
            "/api/v1/mat/events/:event_id/zones",
            get(handlers::list_zones).post(handlers::add_zone),
        )
        // Survivor endpoints
        .route(
            "/api/v1/mat/events/:event_id/survivors",
            get(handlers::list_survivors),
        )
        // Alert endpoints
        .route(
            "/api/v1/mat/events/:event_id/alerts",
            get(handlers::list_alerts),
        )
        .route(
            "/api/v1/mat/alerts/:alert_id/acknowledge",
            post(handlers::acknowledge_alert),
        )
        // Scan control endpoints (ADR-001: CSI data ingestion + pipeline control)
        .route("/api/v1/mat/scan/csi", post(handlers::push_csi_data))
        .route("/api/v1/mat/scan/control", post(handlers::scan_control))
        .route("/api/v1/mat/scan/status", get(handlers::pipeline_status))
        // Domain event store endpoint
        .route(
            "/api/v1/mat/events/domain",
            get(handlers::list_domain_events),
        )
        // WebSocket endpoint
        .route("/ws/mat/stream", get(websocket::ws_handler))
        .with_state(state)
}