Struct MessageHandler 

pub struct MessageHandler { /* private fields */ }

Handles incoming WebSocket messages

Implementations

impl MessageHandler

pub fn new( orderbooks: Arc<RwLock<HashMap<String, LocalOrderbook>>>, user_states: Arc<RwLock<HashMap<String, UserState>>>, price_histories: Arc<RwLock<HashMap<PriceHistoryKey, PriceHistory>>>, subscribed_user: Arc<RwLock<Option<String>>>, ) -> Self

Create a new message handler with shared state

pub async fn handle_message(&self, text: &str) -> Vec<WsEvent>

Handle an incoming message and return events

pub async fn init_orderbook(&self, orderbook_id: &str)

Initialize orderbook state for a subscription.

This must be called before subscribing to orderbook updates to ensure the local state exists when the first snapshot arrives. If not called, the handler will create the state on first message, but there may be a brief window where get_orderbook() returns None.

Uses atomic entry API to avoid race conditions with message handlers. Thread-safe: multiple concurrent calls are safe due to interior write lock.

pub async fn init_user_state(&self, user: &str)

Initialize user state for a subscription.

This must be called before subscribing to user events to ensure state is ready when the first event arrives. Also sets the tracked user for this connection (single user per connection model).

Thread-safe: uses interior write locks for both the subscribed user tracking and the user state map. Multiple concurrent calls are safe but will serialize on lock acquisition. State mutations from incoming events are applied atomically via the same lock.

pub async fn clear_subscribed_user(&self, user: &str)

Clear the subscribed user

pub async fn init_price_history( &self, orderbook_id: &str, resolution: &str, include_ohlcv: bool, )

Initialize price history state for a subscription.

Creates an empty price history container for the given orderbook and resolution. The actual price data will be populated when the snapshot message arrives from the server.

Arguments

• orderbook_id - The orderbook identifier (e.g., “BTC-USD:main”)
• resolution - The candle resolution (e.g., “1m”, “5m”, “1h”, “1d”)
• include_ohlcv - Whether OHLCV candle data should be tracked

Example

handler.init_price_history("BTC-USD:main", "1m", true).await;

pub async fn clear_orderbook(&self, orderbook_id: &str)

Clear orderbook state

pub async fn clear_user_state(&self, user: &str)

Clear user state

pub async fn clear_price_history(&self, orderbook_id: &str, resolution: &str)

Clear price history state

pub async fn clear_all(&self)

Clear all state

Trait Implementations

impl Debug for MessageHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.