Energy & HVAC

// examples/hvac_caravan_park.rs — 641 lines
// 2,000 split-system AC units across 14 zones at 10 Hz.
// Port Hedland climate: 26-40°C daily cycle with thermal
// mass, wall conductance, solar gain, and occupant heat.

const SCHEMA_HVAC_V1: u32 = 0xAC00_0001;

// 72-byte binary telemetry schema:
// unit_id(u32) zone_id(u32) timestamp_us(u64)
// actual_temp(f32) setpoint_temp(f32) ambient_temp(f32)
// compressor_load(f32) fan_rpm(f32) supply_air_temp(f32)
// return_air_temp(f32) refrigerant_psi(f32) humidity(f32)
// co2_ppm(f32) comfort_index(f32) occupancy_confidence(f32)
// mode(u8) fault_code(u8) filter_hours(u8) occupied(u8) online(u8)

const NUM_ZONES: usize = 14;
const ZONE_NAMES: [&str; 14] = [
    "100 Block", "200 Block", "300 Block", "400 Block",
    "500 Block", "600 Block", "700 Block", "800 Block",
    "A Block", "B Block", "B Block Annex", "C Block",
    "W Block", "Misc Rooms",
];

#[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(1400)
        .with_flush_interval(Duration::from_millis(5))
        .insecure();

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

    // Bidirectional: set_setpoint, set_mode, force_defrost
    let shared_units = Arc::new(Mutex::new(init_units));
    client.set_command_handler(HvacCommandHandler {
        units: shared_units.clone(),
    });

    loop {
        let ambient = ambient_temp(elapsed);
        let mut units = shared_units.lock();
        for unit in units.iter_mut() {
            unit.tick(dt_s, ambient, sim_time, &mut rng);
            let payload = unit.to_payload(ambient, t_us);
            client.send_raw(schema_id, &payload)?;
        }
        tokio::time::sleep(TICK_INTERVAL).await;
    }
}