Enum ClientMsg 

pub enum ClientMsg {
    Answer {
        req_id: String,
        value: Value,
    },
    HookAck {
        req_id: String,
        ok: bool,
        reason: Option<String>,
    },
    SpawnAck {
        req_id: String,
        value: Value,
        ok: bool,
        error: Option<String>,
    },
}

Client → server reply messages on WS /v1/operators/:sid/ws. Each variant resolves the pending oneshot registered under its req_id (see super::session::WSOperatorSession::resolve_pending).

Variants

Answer

Reply to ServerMsg::Ask (SeniorBridge.ask result).

Fields

req_id: String

Correlation key copied from the originating ServerMsg::Ask.

value: Value

Answer payload returned to the engine middleware.

HookAck

Ack for SpawnHook.before. ok=false rejects the spawn (= MainAIMiddleware converts it into SpawnError::RejectedByMiddleware). reason propagates as Err(reason).

Fields

req_id: String

Correlation key copied from the originating ServerMsg::HookBefore.

ok: bool

true allows the spawn; false rejects it.

reason: Option<String>

Optional rejection reason surfaced to the engine when ok=false.

SpawnAck

Ack for Operator.execute (Spawn). value = WorkerResult.value, ok = WorkerResult.ok. When error is Some, the Operator returns it as WorkerError.

After the thin-path switch (= the thin-control axis): if the MainAI returns this ack after the SubAgent has hit HTTP /v1/worker/result, the server-side dispatch path can complete with both the Final in output_tail and this ack’s value aligned. Sending an empty JSON {} for value makes the task.last_result written by the HTTP path (= post_result) canonical (= the ack-side value is duplicate / informational).

Fields

req_id: String

Correlation key copied from the originating ServerMsg::Spawn.

value: Value

WorkerResult.value equivalent; empty {} defers to the HTTP-path result (see the variant doc above).

ok: bool

WorkerResult.ok equivalent; defaults to true when omitted.

error: Option<String>

When Some, the Operator surfaces it as a WorkerError.

Trait Implementations

impl Debug for ClientMsg

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClientMsg

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.