Struct WsBridge 

pub struct WsBridge { /* private fields */ }

Implementations

impl WsBridge

pub fn new( mqtt_tx: Sender<WsEnvelope>, mqtt_client: Arc<MqttClient>, mqtt_host: String, mqtt_ws_port: u16, ) -> Self

pub fn spawn_monitor_task(&self)

Spawn a background task that:

1. Consumes raw MQTT envelopes from the broadcast channel.
2. Updates MonitorState.
3. Broadcasts Python-compatible JSON patches to all /ws clients.

pub fn router(&self) -> Router

Build the axum Router with /ws and /mqtt routes.