Struct CodexAppServerSession 

pub struct CodexAppServerSession {
    transport: Arc<AppServerTransport>,
    state: Mutex<SessionState>,
}

Fields

transport: Arc<AppServerTransport>

state: Mutex<SessionState>

Implementations

impl CodexAppServerSession

pub fn new(transport: Arc<AppServerTransport>) -> Self

pub async fn start_thread( &self, options: ThreadStartOptions, timeout: Duration, ) -> Result<String, CodexAppServerProtocolError>

pub async fn resume_thread( &self, thread_id: String, model: Option<String>, cwd: Option<String>, timeout: Duration, ) -> Result<String, CodexAppServerProtocolError>

pub async fn start_turn( &self, text: String, timeout: Duration, ) -> Result<String, CodexAppServerProtocolError>

pub async fn fork_thread( &self, options: ThreadForkOptions, timeout: Duration, ) -> Result<String, CodexAppServerProtocolError>

Fork the active thread without changing this session’s thread identity. The returned id is independent and must be persisted by the caller that creates the new AgentMux pane.

pub async fn read_thread( &self, include_turns: bool, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn list_threads( &self, options: ThreadListOptions, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn archive_thread( &self, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn compact_thread( &self, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn read_account( &self, refresh_token: bool, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

Verify the account selected by the caller’s isolated CODEX_HOME.

pub async fn logout_account( &self, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn login_account( &self, options: AccountLoginOptions, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn cancel_login( &self, login_id: String, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

pub async fn steer_turn( &self, text: String, expected_turn_id: String, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

Add input to the active turn only when the caller supplies the exact turn precondition. Ordinary queued messages should not call this API.

pub async fn interrupt_turn( &self, timeout: Duration, ) -> Result<Value, CodexAppServerProtocolError>

Interrupt the active turn. The turn remains active locally until its authoritative turn/completed notification arrives.

fn active_turn(&self) -> Result<(String, String), CodexAppServerProtocolError>

pub fn accept_server_request( &self, incoming: AppServerIncoming, ) -> Result<PendingServerRequest, CodexAppServerProtocolError>

Validate and queue a server request for an explicit UI/policy decision. No request is approved implicitly.

pub async fn respond_server_request( &self, id: &RpcId, result: Result<Value, ServerResponseError>, timeout: Duration, ) -> Result<(), CodexAppServerProtocolError>

Send a decision for a queued request. The request remains pending if the transport write fails, allowing a retry; successful responses consume it.

pub fn pending_server_requests(&self) -> Vec<PendingServerRequest>

pub fn snapshot(&self) -> SessionSnapshot

pub fn apply_incoming( &self, incoming: AppServerIncoming, ) -> Result<CodexAppServerEvent, CodexAppServerProtocolError>