Struct AppState 

pub struct AppState {
    pub engine: Engine,
    pub sessions: Arc<Mutex<SessionStore>>,
    pub task_app: Arc<TaskApplication>,
    pub ws_operator_factory: Option<Arc<OperatorSpawnerFactory>>,
    pub data_store: Arc<dyn OutputStore>,
    pub operator_sessions: Arc<Mutex<HashMap<String, Arc<OperatorSessionEntry>>>>,
    pub roles_to_sid: Arc<Mutex<HashMap<String, String>>>,
}

Shared axum handler state for the whole router. Cloned per-request (all fields are Arc/cheap-clone), constructed once in build_router_with_ws_factory.

Fields

engine: Engine

The engine SoT (attach/detach, dispatch, registries).

sessions: Arc<Mutex<SessionStore>>

Live /v1/sessions attach records (Operator/Worker/etc session tokens).

task_app: Arc<TaskApplication>

Application used at the task entry to resolve BlueprintRef. Without a Store, runs in Inline-only mode.

ws_operator_factory: Option<Arc<OperatorSpawnerFactory>>

When Some, on WS connect a new WSOperatorSession is automatically registered with this factory under the sid name (= a kind=operator + operator_ref=<sid> AgentDef binds to the WSOperatorSession backend). When None, no auto-registration happens; the session is only registered on engine.OperatorRegistry (= only the OperatorDelegateMiddleware path is effective; the OperatorSpawnerFactory path is dead).

data_store: Arc<dyn OutputStore>

Owner of the Store on the Data path (Big Response handling). Added in v9. Independent layer — the Engine core and the Domain path (/v1/worker/result) are not involved. Default = InMemoryOutputStore (constructed inside build_router_with_ws_factory); callers can swap in an sqlite/fs backend later (future carry).

operator_sessions: Arc<Mutex<HashMap<String, Arc<OperatorSessionEntry>>>>

Login-flow session store (POST /v1/operators mint records). sid → OperatorSessionEntry. This is the sole session store for the WS Operator role. See operator_ws::login module doc.

roles_to_sid: Arc<Mutex<HashMap<String, String>>>

S1 login-flow roles-exclusivity map. Role name → owning sid. Checked (and updated) atomically under a single lock in operator_ws::login::operators_create — a role already present here causes POST /v1/operators to return 409 CONFLICT. Entries are released on DELETE /v1/operators/:sid.

Trait Implementations

impl Clone for AppState

fn clone(&self) -> AppState

Returns a duplicate of the value.

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

Performs copy-assignment from source.