Struct AroraWSServer 

pub struct AroraWSServer { /* private fields */ }

WebSocket server bridging the Arora API.

Handles connections, parses messages, and dispatches to registered handlers. Supports at most one active client at a time – when a new client connects, the previous one is disconnected.

Implementations

impl AroraWSServer

pub fn new(config: ServerConfig) -> Self

Create a new server with the given configuration.

pub fn with_port(port: u16) -> Self

Create a new server with default configuration.

pub fn push(&self, msg: Outgoing)

Push a server-initiated message to the connected client(s).

pub fn subscribe(&self) -> Receiver<Outgoing>

Subscribe to the outbound push channel.

pub fn registry(&self) -> &Arc<Registry>

Get a reference to the registry.

pub async fn set_write_values_handler<F>(&self, handler: F)

where F: Fn(HashMap<String, Value>) -> Result<(), String> + Send + Sync + 'static,

Set the write-values handler callback. This is called whenever a valid WriteValues message is received.

pub async fn set_read_values_handler(&self, handler: ReadValuesHandler)

Set the read-values handler callback. This is called whenever a valid ReadValues message is received.

pub async fn set_on_client_connected_handler( &self, handler: OnClientConnectedHandler, )

Set the handler called when a new client connects.

pub async fn disconnect_client(&self)

Disconnect the current active client (if any).

pub async fn is_running(&self) -> bool

Check if the server is running.

pub fn port(&self) -> u16

Get the configured port.

pub async fn run(&self, cancel_token: CancellationToken) -> Result<(), String>

Run the server until the cancellation token is triggered.

pub fn connection_id(&self) -> String

Get the connection identifier.