Struct ContextRepository 

pub struct ContextRepository { /* private fields */ }

Implementations

impl ContextRepository

pub async fn create_context( &self, user_id: &UserId, session_id: Option<&SessionId>, name: &str, ) -> Result<ContextId, RepositoryError>

pub async fn validate_context_ownership( &self, context_id: &ContextId, user_id: &UserId, ) -> Result<(), RepositoryError>

pub async fn update_context_name( &self, context_id: &ContextId, user_id: &UserId, name: &str, ) -> Result<(), RepositoryError>

pub async fn delete_context( &self, context_id: &ContextId, user_id: &UserId, ) -> Result<(), RepositoryError>

impl ContextRepository

pub async fn find_user_id_for_context( &self, context_id: &ContextId, ) -> Result<Option<UserId>, RepositoryError>

pub async fn get_context( &self, context_id: &ContextId, user_id: &UserId, ) -> Result<UserContext, RepositoryError>

pub async fn list_contexts_basic( &self, user_id: &UserId, ) -> Result<Vec<UserContext>, RepositoryError>

pub async fn list_contexts_with_stats( &self, user_id: &UserId, ) -> Result<Vec<UserContextWithStats>, RepositoryError>

pub async fn find_by_session_id( &self, session_id: &SessionId, ) -> Result<Option<UserContext>, RepositoryError>

pub async fn get_context_events_since( &self, context_id: &ContextId, last_seen: DateTime<Utc>, ) -> Result<Vec<ContextStateEvent>, RepositoryError>

impl ContextRepository

pub fn new(db: &DbPool) -> Result<Self, AgentError>

Trait Implementations

impl Clone for ContextRepository

fn clone(&self) -> ContextRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContextRepository

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

Formats the value using the given formatter.