Struct MessageService 

pub struct MessageService { /* private fields */ }

Implementations

impl MessageService

pub fn new(db_pool: DbPool) -> Self

pub async fn persist_message_in_tx( &self, tx: &mut dyn DatabaseTransaction, message: &Message, task_id: &TaskId, context_id: &ContextId, user_id: Option<&UserId>, session_id: &SessionId, trace_id: &TraceId, ) -> Result<i32>

pub async fn persist_messages( &self, task_id: &TaskId, context_id: &ContextId, messages: Vec<Message>, user_id: Option<&UserId>, session_id: &SessionId, trace_id: &TraceId, ) -> Result<Vec<i32>>

pub async fn create_tool_execution_message( &self, task_id: &TaskId, context_id: &ContextId, tool_name: &str, tool_args: &Value, request_context: &RequestContext, ) -> Result<(String, i32)>

Trait Implementations

impl Debug for MessageService

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

Formats the value using the given formatter.