Aviation

// examples/global_aviation_simple.rs — 1,277 lines
// Simulates every commercial flight in the world using real
// airport locations and great circle arcs. ~12,000 flights
// airborne at any time, streaming at 2 Hz (~20,000 msg/s).

const SCHEMA_AVIATION_V1: u32 = 0xAE10_0001;
const PACKET_SIZE: usize = 96;

// 96-byte binary telemetry schema:
// lat(f32) lon(f32) altitude_ft(f32) heading_deg(f32)
// ground_speed_kts(f32) vertical_speed_fpm(f32) mach(f32)
// fuel_pct(f32) squawk(u16) flight_phase(u8) ...

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = TetrapusConfig::new("127.0.0.1:4433")
        .with_queue_capacity(200_000)
        .with_batch_size(1_400)
        .with_flush_interval(Duration::from_millis(5))
        .insecure();

    let client = TetrapusClient::connect(config).await?;

    // Bidirectional commands — operators can modify flights
    let shared_flights = Arc::new(Mutex::new(flights));
    client.set_command_handler(AviationCommandHandler {
        flights: shared_flights.clone(),
    });

    let schema_id = SchemaId::new(SCHEMA_AVIATION_V1);

    loop {
        let now_s = SystemTime::now()
            .duration_since(UNIX_EPOCH)?.as_secs_f64();

        let flights = shared_flights.lock();
        for flight in flights.iter() {
            if !flight.is_active(now_s) { continue; }
            let state = flight.compute_state(now_s, &mut rng);
            let payload = encode_packet(flight, &state, t_us);
            client.send_raw(schema_id, &payload)?;
        }
        tokio::time::sleep(Duration::from_millis(500)).await;
    }
}