Struct ConversationHandler 

pub struct ConversationHandler { /* private fields */ }

Handles all conversation store operations: creation, rehydration, and persistence.

Implementations

impl ConversationHandler

pub fn new(store: ConversationStore) -> Self

pub async fn get_or_create( &self, ctx: &RequestContext, ) -> ExecutorResult<ConversationData>

Gets an existing conversation or creates one.

Reads conversation_id from ctx.original_request.

Errors

Returns ExecutorError if conversation_id is absent, the store is disabled, or the database query fails.

pub async fn get( &self, ctx: &RequestContext, ) -> ExecutorResult<ConversationData>

Gets an existing conversation.

Reads conversation_id from ctx.original_request.

Errors

Returns ExecutorError if conversation_id is absent, the store is disabled, the conversation does not exist, or the database query fails.

pub async fn create(&self) -> ExecutorResult<ConversationData>

Creates a brand-new conversation with a freshly generated ID.

Errors

Returns ExecutorError if the store is disabled or the database query fails.

pub async fn rehydrate( &self, ctx: &RequestContext, ) -> ExecutorResult<Vec<InOutItem>>

Loads all history items for the conversation referenced by the request.

Reads conversation_id from ctx.original_request. Returns an empty vec if the conversation exists but has no items yet.

Errors

Returns ExecutorError if conversation_id is absent, the store is disabled, or the database query fails.

pub async fn rehydrate_snapshot( &self, ctx: &RequestContext, ) -> ExecutorResult<ConversationSnapshot>

Loads the conversation’s history items and storage version.

Reads conversation_id from ctx.original_request.

Errors

Returns ExecutorError if conversation_id is absent, the store is disabled, or the database query fails.

pub async fn execute_turn( &self, ctx: RequestContext, output_items: Vec<OutputItem>, ) -> ExecutorResult<()>

Persists one conversation turn — only the new items from this turn.

Takes ctx and output_items by value so fields can be moved directly into ResponseMetadata without cloning. The store tracks sequence numbers and appends, so prior history must not be re-inserted.

Errors

Returns ExecutorError if conversation_id is absent on the context, the store is disabled, or the database operation fails.

Trait Implementations

impl Clone for ConversationHandler

fn clone(&self) -> ConversationHandler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConversationHandler

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

Formats the value using the given formatter.