Struct UserRepository 

pub struct UserRepository { /* private fields */ }

Implementations

impl UserRepository

pub async fn create_api_key( &self, params: CreateApiKeyParams<'_>, ) -> Result<UserApiKey>

pub async fn find_active_api_key_by_prefix( &self, key_prefix: &str, ) -> Result<Option<UserApiKey>>

pub async fn list_api_keys_for_user( &self, user_id: &UserId, ) -> Result<Vec<UserApiKey>>

pub async fn revoke_api_key( &self, id: &ApiKeyId, user_id: &UserId, ) -> Result<bool>

pub async fn list_revoked_api_key_ids_for_user( &self, user_id: &UserId, ) -> Result<Vec<String>>

pub async fn touch_api_key_usage(&self, id: &ApiKeyId) -> Result<()>

impl UserRepository

pub async fn enroll_device_cert( &self, params: EnrollDeviceCertParams<'_>, ) -> Result<UserDeviceCert>

pub async fn find_active_device_cert_by_fingerprint( &self, fingerprint: &str, ) -> Result<Option<UserDeviceCert>>

pub async fn list_device_certs_for_user( &self, user_id: &UserId, ) -> Result<Vec<UserDeviceCert>>

pub async fn revoke_device_cert( &self, id: &DeviceCertId, user_id: &UserId, ) -> Result<bool>

impl UserRepository

pub async fn find_federated( &self, issuer: &str, external_sub: &str, ) -> Result<Option<UserId>>

pub async fn find_or_create_federated( &self, issuer: &str, external_sub: &str, claims: &FederatedIdentityClaims, ) -> Result<User>

impl UserRepository

pub async fn find_by_id(&self, id: &UserId) -> Result<Option<User>>

pub async fn find_by_email(&self, email: &str) -> Result<Option<User>>

pub async fn find_by_name(&self, name: &str) -> Result<Option<User>>

pub async fn find_by_role(&self, role: UserRole) -> Result<Vec<User>>

pub async fn find_first_user(&self) -> Result<Option<User>>

pub async fn find_first_admin(&self) -> Result<Option<User>>

pub async fn find_authenticated_user( &self, user_id: &UserId, ) -> Result<Option<User>>

impl UserRepository

pub async fn find_with_sessions( &self, user_id: &UserId, ) -> Result<Option<UserWithSessions>>

pub async fn get_activity(&self, user_id: &UserId) -> Result<UserActivity>

pub async fn list(&self, limit: i64, offset: i64) -> Result<Vec<User>>

pub async fn list_all(&self) -> Result<Vec<User>>

pub async fn search(&self, query: &str, limit: i64) -> Result<Vec<User>>

pub async fn count(&self) -> Result<i64>

pub async fn bulk_update_status( &self, user_ids: &[UserId], new_status: &str, ) -> Result<u64>

pub async fn bulk_delete(&self, user_ids: &[UserId]) -> Result<u64>

pub async fn list_by_filter( &self, status: Option<&str>, role: Option<&str>, older_than_days: Option<i64>, limit: i64, ) -> Result<Vec<User>>

pub async fn is_temporary_anonymous(&self, id: &UserId) -> Result<bool>

pub async fn list_non_anonymous_with_sessions( &self, limit: i64, ) -> Result<Vec<UserWithSessions>>

impl UserRepository

pub async fn merge_users( &self, source_id: &UserId, target_id: &UserId, ) -> Result<MergeResult>

impl UserRepository

pub async fn create( &self, name: &str, email: &str, full_name: Option<&str>, display_name: Option<&str>, ) -> Result<User>

pub async fn create_if_absent( &self, name: &str, email: &str, full_name: Option<&str>, display_name: Option<&str>, ) -> Result<Option<User>>

Inserts the user, yielding None when one already holds that name or email.

create is the right call when the caller owns the identity it is minting. This one is for the auto-provisioning paths, where several processes resolve the same well-known identity — the local-trial admin — and would otherwise each read “absent” and then race to insert it, leaving every loser with a unique-violation the caller can only tell apart by matching on the driver’s error text.

pub async fn create_anonymous(&self, fingerprint: &str) -> Result<User>

pub async fn update_email(&self, id: &UserId, email: &str) -> Result<User>

pub async fn update_full_name( &self, id: &UserId, full_name: &str, ) -> Result<User>

pub async fn update_status( &self, id: &UserId, status: UserStatus, ) -> Result<User>

pub async fn update_email_verified( &self, id: &UserId, verified: bool, ) -> Result<User>

pub async fn update_display_name( &self, id: &UserId, display_name: &str, ) -> Result<User>

pub async fn update_all_fields( &self, id: &UserId, params: UpdateUserParams<'_>, ) -> Result<User>

pub async fn assign_roles(&self, id: &UserId, roles: &[String]) -> Result<User>

pub async fn delete(&self, id: &UserId) -> Result<()>

pub async fn cleanup_old_anonymous(&self, days: i32) -> Result<u64>

impl UserRepository

pub async fn list_sessions(&self, user_id: &UserId) -> Result<Vec<UserSession>>

pub async fn list_active_sessions( &self, user_id: &UserId, ) -> Result<Vec<UserSession>>

pub async fn list_recent_sessions( &self, user_id: &UserId, limit: i64, ) -> Result<Vec<UserSession>>

pub async fn session_exists(&self, session_id: &SessionId) -> Result<bool>

pub async fn end_session(&self, session_id: &SessionId) -> Result<bool>

pub async fn end_all_sessions(&self, user_id: &UserId) -> Result<u64>

impl UserRepository

pub async fn count_by_status(&self) -> Result<Vec<(String, i64)>>

pub async fn count_by_role(&self) -> Result<Vec<(String, i64)>>

pub async fn get_stats(&self) -> Result<UserStats>

impl UserRepository

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

Trait Implementations

impl Clone for UserRepository

fn clone(&self) -> UserRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UserRepository

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

Formats the value using the given formatter.