systemprompt-analytics 0.35.0

Analytics for systemprompt.io AI governance infrastructure. Session, agent, tool, and microdollar-precision cost attribution across the MCP governance pipeline.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

//! Repository layer.
//!
//! Typed `*Repository` structs that wrap `DbPool` and expose compile-time-
//! verified `sqlx::query!` calls for every analytics aggregation, mutation,
//! and lookup. Public re-exports below form the only supported entry points;
//! internal submodules are private to the crate.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

mod agents;
mod cli_sessions;
mod content_analytics;
mod conversations;
mod core_stats;
mod costs;
mod engagement;
mod events;
mod fingerprint;
mod funnel;
mod overview;
mod queries;
mod requests;
mod session;
mod tools;
mod traffic;

pub use agents::AgentAnalyticsRepository;
pub use cli_sessions::CliSessionAnalyticsRepository;
pub use content_analytics::ContentAnalyticsRepository;
pub use conversations::ConversationAnalyticsRepository;
pub use core_stats::CoreStatsRepository;
pub use costs::CostAnalyticsRepository;
pub use engagement::{EngagementRepository, SessionEngagementSummary};
pub use events::{AnalyticsEventsRepository, StoredAnalyticsEvent};
pub use fingerprint::{
    ABUSE_THRESHOLD_FOR_BAN, FingerprintRepository, HIGH_REQUEST_THRESHOLD, HIGH_VELOCITY_RPM,
    MAX_SESSIONS_PER_FINGERPRINT, SUSTAINED_VELOCITY_MINUTES,
};
pub use funnel::FunnelRepository;
pub use overview::OverviewAnalyticsRepository;
pub use queries::{AnalyticsQueryRepository, ProviderUsage};
pub use requests::RequestAnalyticsRepository;
pub use session::{
    CreateSessionParams, SessionBehavioralData, SessionMigrationResult, SessionRecord,
    SessionRepository,
};
pub use tools::ToolAnalyticsRepository;
pub use tools::list_queries::ToolListParams;
pub use traffic::{NavigationQuery, PageQuery, TrafficAnalyticsRepository};

use crate::error::Result;
use systemprompt_database::DbPool;

#[derive(Debug, Clone)]
pub struct AnalyticsRepositories {
    pub sessions: SessionRepository,
    pub costs: CostAnalyticsRepository,
    pub engagement: EngagementRepository,
    pub events: AnalyticsEventsRepository,
}

impl AnalyticsRepositories {
    pub fn new(db: &DbPool) -> Result<Self> {
        Ok(Self {
            sessions: SessionRepository::new(db)?,
            costs: CostAnalyticsRepository::new(db)?,
            engagement: EngagementRepository::new(db)?,
            events: AnalyticsEventsRepository::new(db)?,
        })
    }
}