app.api.ws

WebSocket push to dashboards: vehicle.update every tick, alert and what-if events as they happen.

Events come from sync callbacks (alert engine, what-if) through Hub.publish; one task sends them and the periodic vehicle snapshot, computed once per tick for all clients. A client that can’t take a message within send_timeout_s is dropped instead of slowing everyone else down; the dashboard reconnects on its own (frontend/js/api.js) and gets a fresh snapshot.

Classes

Hub(*[, send_timeout_s])

class app.api.ws.Hub(*, send_timeout_s: float = 2.0)

Базовые классы: object

__init__(*, send_timeout_s: float = 2.0) → None

publish(msg: dict) → None

async run(snapshot: Callable[[], dict], tick_s: float = 1.0) → None

async send_all(msg: dict) → None

async app.api.ws.ws(websocket: fastapi.WebSocket) → None

Dashboard stream: a snapshot on connect, then vehicle.update / alert.* / whatif.result.