Struct SseCommandExecutor 

pub struct SseCommandExecutor { /* private fields */ }

Execute commands against a remote cli daemon over plain HTTP — one POST per command to the daemon’s /execute route, with the result streamed back as Server-Sent Events.

The daemon runs each request IN-PROCESS (no child binary) with the AgentArguments headers applied as a per-request config override (mcp_session_id has no header; the daemon’s filesystem layout and secret are never overridable). This is what lets a consumer — notably the viewer — run on a different machine than the cli: the only local requirement is network reach to the daemon’s published http:// address.

Wire contract (one request per execute):

• client POSTs the cli::command::Request serde JSON as the raw body — nothing wraps it — with the auth signature in the X-OBJECTIVEAI-SIGNATURE header and the AgentArguments identity in the X-OBJECTIVEAI-AGENT-INSTANCE-HIERARCHY / -AGENT-ID / -AGENT-FULL-ID / -AGENT-REMOTE / -RESPONSE-ID / -RESPONSE-IDS request headers — the same names the api stamps on outbound calls, one header per Some field (mcp_session_id has no header). A missing header DELETES that config field for the run — the daemon never inherits its own resident value;
• the daemon replies text/event-stream, one SSE data: event per stream item — exactly the cli’s stdout JSONL line shapes (a T JSON, or a crate::cli::Error {"type":"error",...} line) — then ends the response body;
• the response body ending IS the end-of-stream marker (the HTTP equivalent of the old WebSocket Close); dropping the stream aborts the request, which cancels the in-process run on the daemon.

Auth is the X-OBJECTIVEAI-SIGNATURE header (the same header the daemon’s SSE watcher routes use): when the daemon has a DAEMON_SECRET, the header must carry the pre-derived sha256=<hex(SHA256(secret))> — set it verbatim via Self::signature — or the daemon answers 401 Unauthorized.

Implementations

impl SseCommandExecutor

pub fn new(url: impl Into<String>) -> Self

pub fn signature(self, signature: impl Into<String>) -> Self

Attach the daemon auth signature (the pre-derived sha256=<hex(SHA256(DAEMON_SECRET))>), sent as the X-OBJECTIVEAI-SIGNATURE header on every request. Without it the daemon must be running without a secret.

Trait Implementations

impl CommandExecutor for SseCommandExecutor

type Error = Error

type Stream<T> = Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> where T: Send + 'static

async fn execute<R, T>( &self, request: R, agent_arguments: Option<&AgentArguments>, ) -> Result<Self::Stream<T>, Error>

where R: CommandRequest + Send + Serialize, T: CommandResponse + Serialize + DeserializeOwned + Send + 'static,

async fn execute_one<R, T>( &self, request: R, agent_arguments: Option<&AgentArguments>, ) -> Result<T, Error>

where R: CommandRequest + Send + Serialize, T: CommandResponse + Serialize + DeserializeOwned + Send + 'static,

Convenience for unary commands: run the request and resolve the first item from the stream. Implementations should error with their own “empty stream” variant if the stream closes without producing an item.