Struct ServerState 

pub struct ServerState {
    pub session: Arc<Mutex<Session>>,
    pub ws_tx: Sender<String>,
}

Shared state accessible by all axum handlers.

Fields

session: Arc<Mutex<Session>>

The agent session, protected by a mutex.

ws_tx: Sender<String>

Broadcast sender for WebSocket fan-out. Messages are JSON-serialized TuiMessage strings.

Implementations

impl ServerState

pub fn new(session: Session, ws_tx: Sender<String>) -> Self

Create new shared state from a session and broadcast sender.

pub fn spawn_drain_task(self, workflow_rx: UnboundedReceiver<TuiMessage>)

Spawn a background task that owns the workflow receiver and broadcasts each message to all WebSocket subscribers.

The receiver is moved into the task — no locking needed to await it. When a message arrives, the task briefly locks the session to call handle_workflow_message, then broadcasts the JSON to WebSocket clients.

Trait Implementations

impl Clone for ServerState

fn clone(&self) -> ServerState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.