Struct WSOperatorSession 

pub struct WSOperatorSession { /* private fields */ }

1 sid = 1 session. Looked up by sid in the operator_sessions store on reconnect.

Trait Implementations

impl Operator for WSOperatorSession

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 Ctx, _system: Option<String>, _prompt: String, worker_token: CapToken, ) -> Pin<Box<dyn Future<Output = Result<WorkerResult, WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Thin control channel impl (the Spawn thin-control axis): system / prompt have already been baked into engine state on the server side (= bake_worker_system_prompt in OperatorSpawner.spawn + the existing fetch_prompt path). This impl encodes worker_token and hands it to the MainAI in a single Spawn message; the SubAgent then hits /v1/worker/prompt + /v1/worker/result itself over HTTP. The system / prompt arguments are intentionally not used here (= heavy payloads are not carried on WS — thin-path discipline).

The SubAgent’s result post (= HTTP POST /v1/worker/result) appends Final to output_tail; when the MainAI returns SpawnAck, this execute returns WorkerResult and control returns to the dispatch path.

impl SeniorBridge for WSOperatorSession

fn ask<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 TaskId, question: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Ask the Senior a question and wait for the answer (Value). The implementation is free — a CLI prompt, an MCP modal, another process, whatever.

impl SpawnHook for WSOperatorSession

fn before<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 Ctx, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Hook fired before the spawn. Returning Err aborts the spawn.

fn after<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 Ctx, result: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Hook fired after the spawn (once the worker has finished).