systemprompt-cli 0.1.22

systemprompt.io OS - CLI for agent orchestration, AI operations, and system management
Documentation
mod stats;
mod top;
mod trends;

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

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

#[derive(Debug, Subcommand)]
pub enum ContentCommands {
    #[command(about = "Content engagement statistics")]
    Stats(stats::StatsArgs),

    #[command(about = "Top performing content")]
    Top(top::TopArgs),

    #[command(about = "Top performing content", hide = true)]
    Popular(top::TopArgs),

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

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct ContentStatsOutput {
    pub period: String,
    pub total_views: i64,
    pub unique_visitors: i64,
    pub avg_time_on_page_seconds: i64,
    pub avg_scroll_depth: f64,
    pub total_clicks: i64,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct TopContentRow {
    pub content_id: String,
    pub slug: String,
    pub title: String,
    pub source: String,
    pub views: i64,
    pub unique_visitors: i64,
    pub avg_time_seconds: i64,
    pub trend: String,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct TopContentOutput {
    pub period: String,
    pub content: Vec<TopContentRow>,
}

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct ContentTrendPoint {
    pub timestamp: String,
    pub views: i64,
    pub unique_visitors: i64,
}

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

pub async fn execute(command: ContentCommands, config: &CliConfig) -> Result<()> {
    match command {
        ContentCommands::Stats(args) => {
            let result = stats::execute(args, config).await?;
            render_result(&result);
            Ok(())
        },
        ContentCommands::Top(args) | ContentCommands::Popular(args) => {
            let result = top::execute(args, config).await?;
            render_result(&result);
            Ok(())
        },
        ContentCommands::Trends(args) => {
            let result = trends::execute(args, config).await?;
            render_result(&result);
            Ok(())
        },
    }
}

pub async fn execute_with_pool(
    command: ContentCommands,
    db_ctx: &DatabaseContext,
    config: &CliConfig,
) -> Result<()> {
    match command {
        ContentCommands::Stats(args) => {
            let result = stats::execute_with_pool(args, db_ctx, config).await?;
            render_result(&result);
            Ok(())
        },
        ContentCommands::Top(args) | ContentCommands::Popular(args) => {
            let result = top::execute_with_pool(args, db_ctx, config).await?;
            render_result(&result);
            Ok(())
        },
        ContentCommands::Trends(args) => {
            let result = trends::execute_with_pool(args, db_ctx, config).await?;
            render_result(&result);
            Ok(())
        },
    }
}