GPS driver

from ados.sdk.drivers.gps import (
    GpsDriver,
    GpsCandidate,
    GpsCapabilities,
    GpsSession,
    GpsFix,
)

class MyGpsDriver(GpsDriver):
    async def discover(self) -> list[GpsCandidate]:
        ...

    async def open(self, candidate, config) -> GpsSession:
        ...

    async def close(self, session) -> None:
        ...

    def capabilities(self, session) -> GpsCapabilities:
        ...

    async def fix_iterator(self, session):
        # async generator yielding GpsFix
        ...

    async def inject_rtcm(self, session, payload: bytes) -> None:
        ...

use std::collections::BTreeMap;
use async_trait::async_trait;
use rmpv::Value;
use ados_sdk::drivers::{
    DriverResult, GpsCandidate, GpsCapabilities, GpsDriver, GpsFix, SampleStream,
};

struct MySession;
struct MyGpsDriver;

#[async_trait]
impl GpsDriver for MyGpsDriver {
    type Session = MySession;

    async fn discover(&self) -> DriverResult<Vec<GpsCandidate>> { todo!() }

    async fn open(
        &self,
        candidate: &GpsCandidate,
        config: &BTreeMap<String, Value>,
    ) -> DriverResult<Self::Session> { todo!() }

    async fn close(&self, session: Self::Session) -> DriverResult<()> { todo!() }

    fn capabilities(&self, session: &Self::Session) -> GpsCapabilities { todo!() }

    async fn fix_iterator(
        &self,
        session: &Self::Session,
    ) -> DriverResult<SampleStream<GpsFix>> { todo!() }

    async fn inject_rtcm(
        &self,
        session: &Self::Session,
        payload: &[u8],
    ) -> DriverResult<()> { todo!() }
}

GpsCapabilities(
    protocol="ubx",
    constellations=["GPS", "GLONASS", "Galileo", "BeiDou"],
    max_update_hz=10.0,
    supports_rtk=True,
    supports_dual_band=False,
    supports_heading=False,
)

GpsFix(
    timestamp_ns=ns,
    latitude_deg=-33.8568,
    longitude_deg=151.2153,
    altitude_msl_m=12.0,
    fix_type=3,
    satellites_used=14,
    hdop=0.9,
    vdop=1.4,
    speed_mps=0.0,
    heading_deg=None,
)