Camera driver

from ados.sdk.drivers.camera import (
    CameraDriver,
    CameraCandidate,
    CameraCapabilities,
    CameraSession,
    FrameBuffer,
)

class MyCameraDriver(CameraDriver):
    async def discover(self) -> list[CameraCandidate]:
        ...

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

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

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

    async def frame_iterator(self, session):
        # async generator yielding FrameBuffer
        ...

    async def set_param(self, session, param, value) -> None:
        ...

CameraCandidate(
    driver_id="com.example.my-camera",
    device_id="usb-1.2.3",
    label="MyCorp ThermalCam on USB 1.2.3",
    bus="usb",
    vid_pid=(0x1e4e, 0x0100),
)

CameraCapabilities(
    radiometric=True,
    bit_depth=14,
    width=160,
    height=120,
    fps=8.7,
    pixel_format="Y16",
    streaming_protocol="uvc",
    color_spaces=[],
    has_audio=False,
)

FrameBuffer(
    timestamp_ns=ns,
    sequence=seq,
    width=160,
    height=120,
    pixel_format="Y16",
    data=memoryview(raw_bytes),
    radiometric_k=memoryview(temp_k_matrix),
    metadata={"shutter_open": True},
)

class Plugin:
    async def on_start(self, ctx):
        self.driver = MyCameraDriver(self.backend_factory())
        candidates = await self.driver.discover()
        if not candidates:
            await ctx.events.publish("com.example.my-camera.status", {"state": "no_device"})
            return
        self.session = await self.driver.open(candidates[0], {})
        self.task = asyncio.create_task(self.pump(ctx))

    async def pump(self, ctx):
        async for frame in self.driver.frame_iterator(self.session):
            ...  # process, then publish what your GCS half shows

    async def on_stop(self, ctx):
        self.task.cancel()
        await self.driver.close(self.session)