Struct AssistantService 

pub struct AssistantService { /* private fields */ }

A conversational assistant over one runtime, multiplexed by session_id.

Implementations

impl AssistantService

pub fn new( generator: Arc<dyn TurnGenerator>, runtime: Arc<Runtime>, cfg: AssistantConfig, system: String, ) -> Self

pub fn new_durable( generator: Arc<dyn TurnGenerator>, runtime: Arc<Runtime>, cfg: AssistantConfig, system: String, durability: Arc<dyn AssistantDurability>, repository_root: PathBuf, ) -> Self

pub fn cancel(&self, session_id: &str)

Signal the session’s in-flight turn to stop before its next model call.

pub fn resolve_approval(&self, approval_id: &str, approved: bool) -> bool

Resolve a pending approval (from an agent.chat.approve reverse-call). Returns true if an approval by that id was waiting.

pub async fn handle_turn<E, Fut>( &self, session_id: &str, prompt: &str, attachments: Option<Vec<Value>>, emit: E, )

where E: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Run one chat turn for session_id, streaming agent.chat.event payloads (each already stamped with session_id) through emit. Returns when the turn reaches a terminal state. attachments are image ContentBlocks (image_base64/image_url) forwarded to a vision model on the first model call. The caller should have already acked the agent.chat request and spawned this on its own task.

pub async fn handle_turn_with_model<E, Fut>( &self, session_id: &str, prompt: &str, attachments: Option<Vec<Value>>, model: Option<&str>, emit: E, )

where E: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Run one chat turn with an optional host-selected CAR model. A missing selector preserves the supervised agent’s configured model; a supplied selector is strict so the explicit native choice cannot silently fall back to a different model.

pub async fn handle_goal_turn<E, Fut>( &self, session_id: &str, prompt: &str, _attachments: Option<Vec<Value>>, goal: ChatGoal, emit: E, )

where E: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Run one chat turn as a deterministic goal loop. The user prompt is the pinned objective; completion is decided by goal.check exiting 0 through the runtime, and every verifier pass streams goal_evaluated.

pub async fn handle_goal_turn_with_model<E, Fut>( &self, session_id: &str, prompt: &str, _attachments: Option<Vec<Value>>, goal: ChatGoal, model: Option<&str>, emit: E, )

where E: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Goal-turn counterpart to Self::handle_turn_with_model.