Struct SessionRepository 

pub struct SessionRepository { /* private fields */ }

Implementations

impl SessionRepository

pub const fn new(pool: DbPool) -> Self

pub async fn find_by_id( &self, session_id: &SessionId, ) -> Result<Option<AnalyticsSession>>

pub async fn find_by_fingerprint( &self, fingerprint_hash: &str, user_id: &UserId, ) -> Result<Option<AnalyticsSession>>

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

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

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

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

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

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

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

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

pub async fn mark_as_behavioral_bot( &self, session_id: &SessionId, reason: &str, ) -> Result<()>

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

pub async fn cleanup_inactive(&self, inactive_hours: i32) -> Result<u64>

pub async fn migrate_user_sessions( &self, old_user_id: &UserId, new_user_id: &UserId, ) -> Result<u64>

pub async fn create_session( &self, params: &CreateSessionParams<'_>, ) -> Result<()>

pub async fn find_recent_by_fingerprint( &self, fingerprint_hash: &str, max_age_seconds: i64, ) -> Result<Option<SessionRecord>>

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

pub async fn increment_ai_usage( &self, session_id: &SessionId, tokens: i32, cost_microdollars: i64, ) -> Result<()>

pub async fn update_behavioral_detection( &self, session_id: &SessionId, score: i32, is_behavioral_bot: bool, reason: Option<&str>, ) -> Result<()>

pub async fn escalate_throttle( &self, session_id: &SessionId, new_level: i32, ) -> Result<()>

pub async fn get_throttle_level(&self, session_id: &SessionId) -> Result<i32>

pub async fn count_sessions_by_fingerprint( &self, fingerprint_hash: &str, window_hours: i64, ) -> Result<i64>

pub async fn get_endpoint_sequence( &self, session_id: &SessionId, ) -> Result<Vec<String>>

pub async fn get_request_timestamps( &self, session_id: &SessionId, ) -> Result<Vec<DateTime<Utc>>>

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

pub async fn get_session_for_behavioral_analysis( &self, session_id: &SessionId, ) -> Result<Option<SessionBehavioralData>>

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

pub async fn get_session_velocity( &self, session_id: &SessionId, ) -> Result<(Option<i64>, Option<i64>)>

Trait Implementations

impl Clone for SessionRepository

fn clone(&self) -> SessionRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionRepository

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

Formats the value using the given formatter.

impl SessionAnalyticsProvider for SessionRepository

fn increment_task_count<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionAnalyticsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn increment_message_count<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionAnalyticsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,