msight_core.nodes.source_websocket

msight_core.nodes.source_websocket

WebSocketClientSourceNode

Bases: AsyncSourceNode

on_message(data)

Wrap the received WebSocket message into BytesData.

If it's a string, we encode as UTF-8. If it's already bytes (binary WS message), use as-is.

create(name, publish_topic_name, sensor_name, server_url, gap=0) classmethod

Convenience factory, matching your base class API.