Struct AppState 

pub struct AppState { /* private fields */ }

Shared application state wrapped in Arc for use with Axum.

Implementations

impl AppState

pub async fn add_pending_approval( &self, id: String, approval: PendingApproval, ) -> Receiver<ApprovalResult>

Add a pending approval request.

Returns a oneshot::Receiver that the caller can .await to block until the approval is resolved (or the state is torn down / interrupted).

pub async fn resolve_approval( &self, id: &str, approved: bool, auto_approve: bool, ) -> Option<PendingApproval>

Resolve a pending approval by sending through the oneshot channel.

Returns the approval metadata if found, None if not found or already resolved.

pub async fn get_pending_approval(&self, id: &str) -> Option<PendingApproval>

Get metadata for a pending approval (without resolving it).

pub async fn clear_session_approvals(&self, session_id: &str)

Clear all pending approvals for a session (e.g. when session ends).

Sends rejection through the oneshot channels so any blocked agent tasks wake up rather than hanging forever.

pub async fn add_pending_ask_user( &self, id: String, ask_user: PendingAskUser, ) -> Receiver<AskUserResult>

Add a pending ask-user request.

Returns a oneshot::Receiver that the agent can .await.

pub async fn resolve_ask_user( &self, id: &str, answers: Option<Value>, cancelled: bool, ) -> Option<PendingAskUser>

Resolve a pending ask-user request.

pub async fn get_pending_ask_user(&self, id: &str) -> Option<PendingAskUser>

Get metadata for a pending ask-user request.

pub async fn add_pending_plan_approval( &self, id: String, plan_approval: PendingPlanApproval, ) -> Receiver<PlanApprovalResult>

Add a pending plan approval request.

Returns a oneshot::Receiver that the agent can .await to block until the plan is approved, rejected, or revised.

pub async fn resolve_plan_approval( &self, id: &str, action: String, feedback: String, ) -> Option<PendingPlanApproval>

Resolve a pending plan approval.

action is typically “approve”, “reject”, or “revise”. feedback is optional textual feedback from the user.

Returns the plan-approval metadata if found, None if already resolved.

pub async fn get_pending_plan_approval( &self, id: &str, ) -> Option<PendingPlanApproval>

Get metadata for a pending plan approval.

pub async fn clear_session_plan_approvals(&self, session_id: &str)

Clear all pending plan approvals for a session.

impl AppState

pub async fn is_bridge_mode(&self) -> bool

Check if bridge mode is active (TUI owns execution, Web UI mirrors).

pub async fn bridge_session_id(&self) -> Option<String>

Get the bridge session ID, if bridge mode is active.

pub async fn set_bridge_session(&self, session_id: String)

Activate bridge mode for a given session.

While active, the Web UI should not start its own agent execution for this session; instead it should route messages to the TUI injector.

pub async fn clear_bridge_session(&self)

Deactivate bridge mode.

pub async fn is_bridge_guarded(&self, session_id: &str) -> bool

Check whether a mutation on a session should be blocked because the TUI owns it in bridge mode.

Returns true if the session is bridge-owned and should not be mutated by the web server’s own agent executor.

pub async fn get_or_create_injection_queue( &self, session_id: &str, ) -> (Sender<String>, Option<Receiver<String>>)

Get or create the injection queue sender for a session.

Returns (sender, Option<receiver>). The receiver is Some only when the queue was first created – the caller that creates the session’s agent loop should take the receiver. Subsequent callers get None for the receiver.

pub async fn try_inject_message( &self, session_id: &str, message: String, ) -> Result<(), String>

Try to inject a message into a running session’s queue.

Returns Ok(()) on success, Err(message) if queue is full or not found.

pub async fn clear_injection_queue(&self, session_id: &str)

Remove the injection queue for a session.

pub async fn set_agent_executor(&self, executor: Arc<dyn AgentExecutor>)

Set the agent executor implementation.

pub async fn agent_executor(&self) -> Option<Arc<dyn AgentExecutor>>

Get the agent executor (if set).

impl AppState

pub fn new( session_manager: SessionManager, config: AppConfig, working_dir: String, user_store: UserStore, model_registry: ModelRegistry, ) -> Self

Create a new AppState.

pub async fn session_manager(&self) -> RwLockReadGuard<'_, SessionManager>

Get a read guard for the session manager.

pub async fn session_manager_mut(&self) -> RwLockWriteGuard<'_, SessionManager>

Get a write guard for the session manager.

pub async fn current_session_id(&self) -> Option<String>

Get the current session ID (if a session is loaded).

pub async fn config(&self) -> RwLockReadGuard<'_, AppConfig>

Get a read guard for the app config.

pub async fn config_mut(&self) -> RwLockWriteGuard<'_, AppConfig>

Get a write guard for the app config.

pub fn working_dir(&self) -> &str

Get the working directory.

pub fn user_store(&self) -> &UserStore

Get a reference to the user store.

pub async fn model_registry(&self) -> RwLockReadGuard<'_, ModelRegistry>

Get a read guard for the model registry.

pub async fn model_registry_mut(&self) -> RwLockWriteGuard<'_, ModelRegistry>

Get a write guard for the model registry.

pub fn ws_sender(&self) -> Sender<WsBroadcast>

Get a clone of the broadcast sender.

pub fn ws_subscribe(&self) -> Receiver<WsBroadcast>

Subscribe to WebSocket broadcasts.

pub fn broadcast(&self, msg: WsBroadcast)

Broadcast a message to all WebSocket subscribers.

pub async fn mode(&self) -> OperationMode

Get the current operation mode.

pub async fn set_mode(&self, mode: OperationMode)

Set the operation mode.

pub async fn autonomy_level(&self) -> String

Get the current autonomy level.

pub async fn set_autonomy_level(&self, level: String)

Set the autonomy level.

pub async fn request_interrupt(&self)

Request an interrupt.

Also denies all pending approvals, ask-user, and plan-approval requests by sending rejection through their oneshot channels so blocked tasks wake up.

pub async fn clear_interrupt(&self)

Clear the interrupt flag.

pub async fn is_interrupt_requested(&self) -> bool

Check if interrupt has been requested.

pub async fn set_session_running(&self, session_id: String)

Mark a session as running.

pub async fn set_session_idle(&self, session_id: &str)

Mark a session as idle.

pub async fn is_session_running(&self, session_id: &str) -> bool

Check if a session is running.

pub fn git_branch(&self) -> Option<String>

Get the git branch for the working directory.

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.