Struct WsClient 

pub struct WsClient { /* private fields */ }

Implementations

impl WsClient

pub fn new( url: String, edge_id: String, version: String, capabilities: Vec<String>, engine: Arc<RoutingEngine>, glyphs: Arc<GlyphRegistry>, ) -> Self

pub fn outbox(&self) -> Sender<EdgeToServer>

Get a sender for outbound EdgeToServer frames. Clone as many times as needed; adapters publish state updates via this channel.

pub fn resync_sender(&self) -> Sender<()>

Clone the ws/edge (re)connect broadcaster. Fires once per successful connect + Hello exchange. State-pumps subscribe to this and replay the most recent frame per (service_type, target, property, output_id) key so weave-server recovers its full snapshot after a restart — otherwise idle zones / lights that haven’t changed since the last connect disappear from the UI because the adapter’s source-side dedup suppresses re-sends.

pub async fn prime_from_cache(&self) -> Result<()>

Populate the routing engine + glyph registry from the local cache, if one exists. Call this once at startup before entering run().

pub async fn run(self)

Run the reconnect loop. Never returns under normal operation.