adsb-anomaly 0.2.2

A sophisticated real-time anomaly detection system for ADS-B aircraft data with multi-tier detection algorithms, real-time web dashboard, and production-grade architecture built in Rust
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

// ABOUTME: Simplified dashboard implementation for testing template compilation
// ABOUTME: Basic HTML responses without complex template derivation

use axum::{
    extract::{Query, State},
    response::Html,
    routing::get,
    Router,
};
use serde::Deserialize;
use sqlx::SqlitePool;

use crate::store::sessions;

#[derive(Debug, Deserialize)]
pub struct PaginationQuery {
    pub limit: Option<usize>,
}

/// Simple dashboard routes
pub fn router() -> Router<SqlitePool> {
    Router::new().route("/simple", get(simple_sessions_page))
}

/// Handler for simple sessions page
async fn simple_sessions_page(
    State(pool): State<SqlitePool>,
    Query(pagination): Query<PaginationQuery>,
) -> Result<Html<String>, axum::http::StatusCode> {
    let limit = pagination.limit.unwrap_or(10).min(50);

    match sessions::list_sessions(&pool, limit).await {
        Ok(sessions) => {
            let mut html = String::from(
                r#"
<!DOCTYPE html>
<html>
<head>
    <title>Simple ADS-B Dashboard</title>
    <style>
        body { font-family: Arial, sans-serif; margin: 20px; }
        table { border-collapse: collapse; width: 100%; }
        th, td { border: 1px solid #ddd; padding: 8px; text-align: left; }
        th { background-color: #f2f2f2; }
    </style>
</head>
<body>
    <h1>Aircraft Sessions</h1>
    <table>
        <thead>
            <tr>
                <th>HEX</th>
                <th>Flight</th>
                <th>Position</th>
                <th>Last Seen</th>
                <th>Messages</th>
            </tr>
        </thead>
        <tbody>
"#,
            );

            for session in sessions {
                let flight = session.flight.unwrap_or_else(|| "—".to_string());
                let position = match (session.lat, session.lon) {
                    (Some(lat), Some(lon)) => format!("{:.4}, {:.4}", lat, lon),
                    _ => "—".to_string(),
                };

                html.push_str(&format!(
                    r#"            <tr>
                <td>{}</td>
                <td>{}</td>
                <td>{}</td>
                <td>{}</td>
                <td>{}</td>
            </tr>
"#,
                    session.hex, flight, position, session.last_seen_ms, session.message_count
                ));
            }

            html.push_str(
                r#"        </tbody>
    </table>
</body>
</html>"#,
            );

            Ok(Html(html))
        }
        Err(_) => Err(axum::http::StatusCode::INTERNAL_SERVER_ERROR),
    }
}