Struct MessageRepository 

pub struct MessageRepository { /* private fields */ }

Implementations

impl MessageRepository

pub fn new(db_pool: DbPool) -> Result<Self, RepositoryError>

pub async fn get_messages_by_task( &self, task_id: &TaskId, ) -> Result<Vec<Message>, RepositoryError>

pub async fn get_messages_by_context( &self, context_id: &ContextId, ) -> Result<Vec<Message>, RepositoryError>

pub async fn get_next_sequence_number( &self, task_id: &TaskId, ) -> Result<i32, RepositoryError>

pub async fn persist_message_sqlx( &self, tx: &mut Transaction<'_, Postgres>, message: &Message, task_id: &TaskId, context_id: &ContextId, sequence_number: i32, user_id: Option<&UserId>, session_id: &SessionId, trace_id: &TraceId, upload_ctx: Option<&FileUploadContext<'_>>, ) -> Result<(), RepositoryError>

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

Trait Implementations

impl Clone for MessageRepository

fn clone(&self) -> MessageRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageRepository

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

Formats the value using the given formatter.