Struct StoreCommandHost 

pub struct StoreCommandHost { /* private fields */ }

Store-backed CommandHost shared by all hosts (server full/dev mode via worker adapters, in-process runtime via its runtime stores). Reuses inspect_turn_context and the reason-path message-building conventions so command completions see exactly what a main turn would.

One instance is built per command dispatch; the assembled context is memoized so turn_context() + completion() assemble once.

Implementations

impl StoreCommandHost

pub fn new( session_id: SessionId, harness_store: Arc<dyn HarnessStore>, agent_store: Arc<dyn AgentStore>, session_store: Arc<dyn SessionStore>, message_retriever: Arc<dyn MessageRetriever>, provider_store: Arc<dyn LlmProviderStore>, capability_registry: CapabilityRegistry, driver_registry: DriverRegistry, ) -> Self

pub fn with_image_resolver(self, image_resolver: Arc<dyn ImageResolver>) -> Self

Resolve image_file references in messages to inline image data. Without a resolver, images degrade to placeholder text.

pub fn with_file_store(self, file_store: Arc<dyn SessionFileSystem>) -> Self

Session filesystem for dynamic system prompt contributions (AGENTS.md, skills discovery).

pub fn with_assembled_context(self, assembled: AssembledTurnContext) -> Self

Seed the memoized turn context when the host already assembled one (e.g. the in-process runtime assembles it to resolve command dispatch).

Trait Implementations

impl CommandHost for StoreCommandHost

fn turn_context<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<CommandTurnContext>> + Send + 'async_trait>>

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

Assemble the same merged context a main turn would see.

fn completion<'life0, 'async_trait>( &'life0 self, request: SessionCompletionRequest, ) -> Pin<Box<dyn Future<Output = Result<SessionCompletion, SessionCompletionError>> + Send + 'async_trait>>

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

Run a tool-less completion against the session’s resolved model (or a Controls model override). Persists nothing.

fn completion_stream<'life0, 'async_trait>( &'life0 self, request: SessionCompletionRequest, ) -> Pin<Box<dyn Future<Output = Result<SessionCompletionStream, SessionCompletionError>> + Send + 'async_trait>>

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

Streaming variant of Self::completion for commands that surface progressive output. Same request semantics, same out-of-band guarantee: nothing is persisted.