Satellite Tracking

// examples/satellite_tracking/main.rs — 81 lines
// Fetches TLE data from CelesTrak for Starlink constellation,
// computes ECEF positions via SGP4, streams 48-byte packets.

use tetrapus_sdk::{TetrapusClient, TetrapusConfig, SchemaId};
use std::time::{Duration, SystemTime, UNIX_EPOCH};

const SCHEMA_SATELLITE_V1: u32 = 0xCE1E_0001;

// 48-byte binary telemetry:
// satellite_id(u32) timestamp_us(u64)
// ecef_x(f32) ecef_y(f32) ecef_z(f32)
// lat_deg(f32) lon_deg(f32) alt_km(f32)
// velocity_km_s(f32) inclination_deg(f32) mean_motion(f32)

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let satellites = tle::fetch_starlink_tle()?;
    println!("Loaded {} satellites", satellites.len());

    let client = TetrapusClient::connect(
        TetrapusConfig::default()
    ).await?;
    let schema = SchemaId(SCHEMA_SATELLITE_V1);
    let mut buf = [0u8; 48];

    loop {
        let now_us = SystemTime::now()
            .duration_since(UNIX_EPOCH)?.as_micros() as u64;

        for (i, sat) in satellites.iter().enumerate() {
            let ecef = tle::propagate_to_ecef(sat, time_offset);
            let (lat, lon, alt_km) = tle::ecef_to_lla(ecef);

            buf[0..4].copy_from_slice(&(i as u32).to_le_bytes());
            buf[4..12].copy_from_slice(&now_us.to_le_bytes());
            buf[12..16].copy_from_slice(&(ecef[0] as f32).to_le_bytes());
            // ... encode remaining fields
            buf[40..44].copy_from_slice(&(sat.inclination as f32).to_le_bytes());
            buf[44..48].copy_from_slice(&(sat.mean_motion as f32).to_le_bytes());

            client.send_raw(schema, &buf)?;
        }
        tokio::time::sleep(Duration::from_secs(1)).await;
    }
}