Struct Broker 

pub struct Broker {
    inner: Mutex<BrokerInner>,
}

The central pub/sub broker for WaveEvents.

Fields

inner: Mutex<BrokerInner>

Implementations

impl Broker

pub fn new() -> Self

pub fn set_client(&self, client: Box<dyn WpsClient>)

pub fn subscribe(&self, route_id: &str, sub: SubscriptionRequest)

Subscribe a route to an event, optionally scoped.

Replay-on-subscribe: after registering the route, immediately deliver any persisted events that match the subscription. Lets late subscribers catch up on the most recent state without waiting for the next publish — closes the race for live-log streaming where the frontend learns the tool_use_id only after the wrapper has already finished publishing.

fn replay_to_route( inner: &mut BrokerInner, route_id: &str, sub: &SubscriptionRequest, )

Deliver any persisted events matching sub to route_id. Called inside subscribe so replay happens atomically under the broker lock — no live event published mid-replay can interleave.

Once-per-(route, event, scope). The frontend (frontend/app/store/wps.ts) flushes eventsub on every listener add/remove; each WebSocket connection has its own conn_id as the route key (PR #1418). Replaying persisted history on each of those flushes would re-emit completed bash logs every pane mount / tab switch / sibling subscription. The replayed set tracks tuples that already received their backfill and short-circuits subsequent resubscribes. Cleared per-route in unsubscribe_all so a true reconnect (route dropped + re-registered) gets a fresh replay.

Star-scope replay is intentionally not implemented (rare, requires scanning every persist key; can add later if needed).

pub fn unsubscribe(&self, route_id: &str, event_name: &str)

Unsubscribe a route from a specific event.

pub fn unsubscribe_all(&self, route_id: &str)

Unsubscribe a route from all events.

Also clears the replayed tracker for this route so a future reconnect (route registers again from scratch) gets a fresh replay of persisted history. Without this, a transient WebSocket drop would silently lose all subsequent replay.

fn unsubscribe_nolock(inner: &mut BrokerInner, route_id: &str, event_name: &str)

pub fn publish(&self, event: WaveEvent)

Publish an event to all matching subscribers.

pub fn read_event_history( &self, event_type: &str, scope: &str, max_items: usize, ) -> Vec<WaveEvent>

Read persisted event history.

fn persist_event(inner: &mut BrokerInner, event: &WaveEvent)

fn get_matching_routes(inner: &BrokerInner, event: &WaveEvent) -> Vec<String>

Trait Implementations

impl Default for Broker

fn default() -> Self

Returns the “default value” for a type.