Struct App 

pub struct App { /* private fields */ }

Holds an Oxicode engine (composition root) and a single Agent built from it. The legacy App::new(settings) constructor is gone; use App::from_oxicode with a wired Oxicode from build_oxicode_engine.

Implementations

impl App

pub async fn from_oxicode( oxicode: Oxicode, settings: Settings, ownership_session_id: String, session_state: Option<SessionState>, ) -> Result<Self>

Build an App from a wired Oxicode engine and a settings object.

The Oxicode should be created via build_oxicode_engine (or services::build_oxicode) so that all 11 ports are wired. The settings hold the user’s runtime configuration (model, thinking level, etc.).

ownership_session_id is the per-process liveness identity used by the agent’s issue tool (ToolContext.session_id), the TUI panel, and the /issue slash command. It must be unique per process in every mode (tui-<pid>-<uuid> / proc-<pid>-<uuid>) so two parallel sessions never share one flock name — a shared name silently broke ownership exclusivity between them.

session_state is the pre-built SessionState passed into the agent’s with_session_hooks call. When None, fresh state is constructed (the default for tests and most call sites — bootstrap constructs it explicitly so the runtime and AgentSession share the SAME queues + stop flag).

pub fn ownership_session_id(&self) -> &str

Per-process liveness identity. Used by the agent’s issue tool and any other surface that gates on is_session_alive.

pub fn has_liveness_lock(&self) -> bool

True iff App holds a live liveness flock under ownership_session_id. False when there is no issue_store (e.g. headless test) or when another live process already holds the lock (the assignment feature will surface Assigned errors in that case — by design).

pub fn settings(&self) -> &Settings

Get the current settings

pub fn set_wasm_ext(&mut self, ext: Option<Arc<WasmExtensionManager>>)

Set the WASM extension manager

pub fn wasm_ext(&self) -> Option<&Arc<WasmExtensionManager>>

Get the WASM extension manager

pub fn issue_store(&self) -> Option<FileIssueStore>

Get a clone of the local issue store, if one was opened successfully.

pub fn oxicode(&self) -> &Oxicode

Get a reference to the underlying Oxicode engine. The catalog port and other ports are accessible through it.

pub fn catalog(&self) -> Arc<dyn ModelCatalog>

Get a clone of the model catalog port (the canonical provider/model metadata source). Used by the TUI to browse the full catalog in-TUI.

pub fn agent(&self) -> Arc<Agent>

Get a reference to the underlying agent.

pub fn agent_tools(&self) -> Arc<ToolRegistry>

Get the tool registry (for registering extension tools)

pub fn ask_bridge(&self) -> Option<&Arc<AskBridge>>

Get the ask bridge, if initialized.

pub fn skills(&self) -> RwLockReadGuard<'_, SkillManager>

Get a reference to the skill manager

pub fn activate_skill(&self, name: &str) -> Result<(), String>

Activate a skill by name. Returns an error string if not found.

pub fn deactivate_skill(&self, name: &str)

Deactivate a skill by name.

pub fn active_skills(&self) -> Vec<String>

List currently active skill names

pub fn agent_state(&self) -> AgentState

Get a clone of the current state

pub async fn run_prompt(&self, prompt: String) -> Result<String>

Run a single prompt and return the response

pub async fn run_prompt_with_events<F>( &self, prompt: String, on_event: F, ) -> Result<String>

where F: FnMut(AgentEvent) + Send + 'static,

Run a prompt with event callback

pub fn reset(&self)

Reset the conversation

pub async fn switch_model(&self, model_id: &str) -> Result<()>

Switch the model used for future LLM calls.

The new provider is re-credentialed by the SDK resolver via the wired AuthProvider port; the api_key parameter was removed in 0.55.0 (issues #39/#40).

pub fn model_id(&self) -> String

Get the current model ID

pub fn session_state(&self) -> &SessionState

Borrow the pre-built SessionState (stop flag + steering + follow-up queues). The runtime clones the Arcs it needs into AgentSession so the runtime and the agent’s session-level closures share the SAME state — required for Ctrl+C and /steer to take effect mid-run.

pub fn should_stop_flag(&self) -> Arc<AtomicBool>

Clone the shared stop flag. Cheap (single Arc bump).

pub fn steering_queue(&self) -> Arc<RwLock<VecDeque<Message>>>

Clone the shared steering queue.

pub fn follow_up_queue(&self) -> Arc<RwLock<VecDeque<Message>>>

Clone the shared follow-up queue.