Struct WsSession 

pub struct WsSession {
    pub url: String,
    pub protocol: WsProtocol,
    pub domain: String,
    /* private fields */
}

An active WebSocket session.

Wraps a tokio-tungstenite connection with session metadata (cookies, auth tokens, protocol details).

Fields

url: String

The WebSocket URL this session is connected to.

protocol: WsProtocol

The protocol used (Raw, Socket.IO, SockJS, SignalR).

domain: String

Domain of the connected site.

Implementations

impl WsSession

pub async fn connect( endpoint: &WsEndpoint, cookies: &HashMap<String, String>, ) -> Result<Self>

Connect to a WebSocket endpoint.

Builds the connection URL and optional headers (cookies, auth tokens), then opens the WebSocket connection.

pub async fn send_json<T: Serialize>(&mut self, msg: &T) -> Result<()>

Send a JSON-serializable message over the WebSocket.

For Socket.IO, wraps the message in the appropriate frame format. For raw WebSocket, sends as-is.

pub async fn receive(&mut self) -> Result<Option<String>>

Receive the next message from the WebSocket.

Returns None if the connection is closed. Automatically skips ping/pong control frames and returns the next data message.

pub async fn watch(&mut self, duration_ms: u64) -> Result<Vec<WsMessage>>

Receive messages for a given duration, returning all collected messages.

pub async fn close(&mut self) -> Result<()>

Close the WebSocket connection gracefully.

pub fn is_connected(&self) -> bool

Whether the connection is currently open.

pub fn history(&self) -> &[WsMessage]

Get the message history.