systemprompt-cli 0.17.0

Unified CLI for systemprompt.io AI governance: agent orchestration, MCP governance, analytics, profiles, cloud deploy, and self-hosted operations.
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

//! Session analytics: aggregate stats, trends, and a real-time live view.
//!
//! Defines the [`SessionsCommands`] subcommand tree and the typed output shapes
//! ([`SessionStatsOutput`], [`SessionTrendsOutput`], [`LiveSessionsOutput`])
//! rendered by the `analytics sessions` commands.

mod live;
mod stats;
mod trends;

use anyhow::Result;
use clap::Subcommand;
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};

use crate::context::CommandContext;
use crate::shared::render_result;

#[derive(Debug, Subcommand)]
pub enum SessionsCommands {
    #[command(about = "Session statistics", alias = "list")]
    Stats(stats::StatsArgs),

    #[command(about = "Session trends over time")]
    Trends(trends::TrendsArgs),

    #[command(about = "Real-time active sessions")]
    Live(live::LiveArgs),
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct SessionStatsOutput {
    pub period: String,
    #[serde(rename = "sessions_created_in_period")]
    pub total_sessions: i64,
    #[serde(rename = "sessions_currently_active")]
    pub active_sessions: i64,
    pub unique_users: i64,
    pub avg_duration_seconds: i64,
    pub avg_requests_per_session: f64,
    pub conversion_rate: f64,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct SessionTrendPoint {
    pub timestamp: String,
    pub session_count: i64,
    pub active_users: i64,
    pub avg_duration_seconds: i64,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct SessionTrendsOutput {
    pub period: String,
    pub group_by: String,
    pub points: Vec<SessionTrendPoint>,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct ActiveSessionRow {
    #[serde(rename = "session_id")]
    pub session: String,
    pub user_type: String,
    pub started_at: String,
    pub duration_seconds: i64,
    pub request_count: i64,
    pub last_activity: String,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct LiveSessionsOutput {
    pub active_count: i64,
    pub sessions: Vec<ActiveSessionRow>,
    pub timestamp: String,
}

pub async fn execute(command: SessionsCommands, ctx: &CommandContext) -> Result<()> {
    let db_ctx = ctx.database().await?;
    match command {
        SessionsCommands::Stats(args) => {
            let result = stats::execute_with_pool(args, &db_ctx, &ctx.cli).await?;
            render_result(&result, &ctx.cli);
            Ok(())
        },
        SessionsCommands::Trends(args) => {
            let result = trends::execute_with_pool(args, &db_ctx, &ctx.cli).await?;
            render_result(&result, &ctx.cli);
            Ok(())
        },
        SessionsCommands::Live(mut args) => {
            if ctx.is_database_scoped() {
                args.no_refresh = true;
            }
            let result = live::execute_with_pool(args, &db_ctx, &ctx.cli).await?;
            render_result(&result, &ctx.cli);
            Ok(())
        },
    }
}