systemprompt-cli 0.1.22

systemprompt.io OS - CLI for agent orchestration, AI operations, and system management
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

pub mod agents;
pub mod content;
pub mod conversations;
pub mod costs;
pub mod overview;
pub mod requests;
pub mod sessions;
pub mod shared;
pub mod tools;
pub mod traffic;

use anyhow::Result;
use clap::Subcommand;
use systemprompt_runtime::DatabaseContext;

use crate::CliConfig;
use crate::shared::render_result;

#[derive(Debug, Subcommand)]
pub enum AnalyticsCommands {
    #[command(about = "Dashboard overview of all analytics")]
    Overview(overview::OverviewArgs),

    #[command(subcommand, about = "Conversation analytics")]
    Conversations(conversations::ConversationsCommands),

    #[command(subcommand, about = "Agent performance analytics")]
    Agents(agents::AgentsCommands),

    #[command(subcommand, about = "Tool usage analytics")]
    Tools(tools::ToolsCommands),

    #[command(subcommand, about = "AI request analytics")]
    Requests(requests::RequestsCommands),

    #[command(subcommand, about = "Session analytics")]
    Sessions(sessions::SessionsCommands),

    #[command(subcommand, about = "Content performance analytics")]
    Content(content::ContentCommands),

    #[command(subcommand, about = "Traffic analytics")]
    Traffic(traffic::TrafficCommands),

    #[command(subcommand, about = "Cost analytics")]
    Costs(costs::CostsCommands),
}

pub async fn execute(command: AnalyticsCommands, config: &CliConfig) -> Result<()> {
    match command {
        AnalyticsCommands::Overview(args) => {
            let result = overview::execute(args, config).await?;
            render_result(&result);
            Ok(())
        },
        AnalyticsCommands::Conversations(cmd) => conversations::execute(cmd, config).await,
        AnalyticsCommands::Agents(cmd) => agents::execute(cmd, config).await,
        AnalyticsCommands::Tools(cmd) => tools::execute(cmd, config).await,
        AnalyticsCommands::Requests(cmd) => requests::execute(cmd, config).await,
        AnalyticsCommands::Sessions(cmd) => sessions::execute(cmd, config).await,
        AnalyticsCommands::Content(cmd) => content::execute(cmd, config).await,
        AnalyticsCommands::Traffic(cmd) => traffic::execute(cmd, config).await,
        AnalyticsCommands::Costs(cmd) => costs::execute(cmd, config).await,
    }
}

pub async fn execute_with_db(
    command: AnalyticsCommands,
    db_ctx: &DatabaseContext,
    config: &CliConfig,
) -> Result<()> {
    match command {
        AnalyticsCommands::Overview(args) => {
            let result = overview::execute_with_pool(args, db_ctx, config).await?;
            render_result(&result);
            Ok(())
        },
        AnalyticsCommands::Conversations(cmd) => {
            conversations::execute_with_pool(cmd, db_ctx, config).await
        },
        AnalyticsCommands::Agents(cmd) => agents::execute_with_pool(cmd, db_ctx, config).await,
        AnalyticsCommands::Tools(cmd) => tools::execute_with_pool(cmd, db_ctx, config).await,
        AnalyticsCommands::Requests(cmd) => requests::execute_with_pool(cmd, db_ctx, config).await,
        AnalyticsCommands::Sessions(cmd) => sessions::execute_with_pool(cmd, db_ctx, config).await,
        AnalyticsCommands::Content(cmd) => content::execute_with_pool(cmd, db_ctx, config).await,
        AnalyticsCommands::Traffic(cmd) => traffic::execute_with_pool(cmd, db_ctx, config).await,
        AnalyticsCommands::Costs(cmd) => costs::execute_with_pool(cmd, db_ctx, config).await,
    }
}