Rail Network

// examples/rail_network_operations.rs — 879 lines
// 54 train services across 6 UK intercity/regional lines at 5 Hz.
// Realistic speed profiles, station dwell, signal aspects.

const SCHEMA_RAIL_V1: u32 = 0x00BA_1101;

// 52-byte binary telemetry: lat(f32) lon(f32) speed_kmh(f32)
// heading_rad(f32) acceleration_ms2(f32) traction_kw(f32)
// delay_s(f32) passenger_count(u16) seat_capacity(u16)
// signal_aspect(u8) door_status(u8) status(u8) brake_pct(u8)

const LINES: &[Line] = &[
    Line { name: "East Coast Mainline",  train_count: 10, max_kmh: 200.0 },
    Line { name: "West Coast Mainline",  train_count: 10, max_kmh: 200.0 },
    Line { name: "Great Western",        train_count:  8, max_kmh: 200.0 },
    Line { name: "Elizabeth/Crossrail",   train_count: 12, max_kmh: 130.0 },
    Line { name: "Scottish Mainline",    train_count:  6, max_kmh: 160.0 },
    Line { name: "TransPennine Express", train_count:  8, max_kmh: 160.0 },
];

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

    let client = TetrapusClient::connect(config).await?;
    let schema_id = SchemaId::new(SCHEMA_RAIL_V1);

    loop {
        for (train, line_idx) in &mut trains {
            train.tick(&LINES[*line_idx], dt, hour, &mut rng);
            client.send_raw(schema_id, &train.to_payload(t_us))?;
        }
        tokio::time::sleep(TICK_INTERVAL).await; // 200ms = 5Hz
    }
}