use anyhow::Result;
use clap::Args;
use std::collections::HashMap;
use std::path::PathBuf;
use systemprompt_analytics::ConversationAnalyticsRepository;
use systemprompt_logging::CliService;
use systemprompt_runtime::{AppContext, DatabaseContext};
use super::{ConversationTrendPoint, ConversationTrendsOutput};
use crate::CliConfig;
use crate::commands::analytics::shared::{
export_to_csv, format_date_range, format_period_label, parse_time_range, resolve_export_path,
truncate_to_period,
};
use crate::shared::{ChartType, CommandResult};
#[derive(Debug, Args)]
pub struct TrendsArgs {
#[arg(long, alias = "from", default_value = "7d", help = "Time range")]
pub since: Option<String>,
#[arg(long, alias = "to", help = "End time for range")]
pub until: Option<String>,
#[arg(long, default_value = "day", help = "Group by period")]
pub group_by: String,
#[arg(long, help = "Export results to CSV file")]
pub export: Option<PathBuf>,
}
pub async fn execute(
args: TrendsArgs,
_config: &CliConfig,
) -> Result<CommandResult<ConversationTrendsOutput>> {
let ctx = AppContext::new().await?;
let repo = ConversationAnalyticsRepository::new(ctx.db_pool())?;
execute_internal(args, &repo).await
}
pub async fn execute_with_pool(
args: TrendsArgs,
db_ctx: &DatabaseContext,
_config: &CliConfig,
) -> Result<CommandResult<ConversationTrendsOutput>> {
let repo = ConversationAnalyticsRepository::new(db_ctx.db_pool())?;
execute_internal(args, &repo).await
}
async fn execute_internal(
args: TrendsArgs,
repo: &ConversationAnalyticsRepository,
) -> Result<CommandResult<ConversationTrendsOutput>> {
let (start, end) = parse_time_range(args.since.as_ref(), args.until.as_ref())?;
let context_rows = repo.get_context_timestamps(start, end).await?;
let task_rows = repo.get_task_timestamps(start, end).await?;
let message_rows = repo.get_message_timestamps(start, end).await?;
let mut buckets: HashMap<String, (i64, i64, i64)> = HashMap::new();
for row in context_rows {
let key = format_period_label(
truncate_to_period(row.timestamp, &args.group_by),
&args.group_by,
);
buckets.entry(key).or_insert((0, 0, 0)).0 += 1;
}
for row in task_rows {
let key = format_period_label(
truncate_to_period(row.timestamp, &args.group_by),
&args.group_by,
);
buckets.entry(key).or_insert((0, 0, 0)).1 += 1;
}
for row in message_rows {
let key = format_period_label(
truncate_to_period(row.timestamp, &args.group_by),
&args.group_by,
);
buckets.entry(key).or_insert((0, 0, 0)).2 += 1;
}
let mut points: Vec<ConversationTrendPoint> = buckets
.into_iter()
.map(
|(timestamp, (contexts, tasks, messages))| ConversationTrendPoint {
timestamp,
context_count: contexts,
task_count: tasks,
message_count: messages,
},
)
.collect();
points.sort_by(|a, b| a.timestamp.cmp(&b.timestamp));
let output = ConversationTrendsOutput {
period: format_date_range(start, end),
group_by: args.group_by.clone(),
points,
};
if let Some(ref path) = args.export {
let resolved_path = resolve_export_path(path)?;
export_to_csv(&output.points, &resolved_path)?;
CliService::success(&format!("Exported to {}", resolved_path.display()));
return Ok(CommandResult::chart(output, ChartType::Line).with_skip_render());
}
if output.points.is_empty() {
CliService::warning("No data found");
return Ok(CommandResult::chart(output, ChartType::Line).with_skip_render());
}
Ok(CommandResult::chart(output, ChartType::Line).with_title("Conversation Trends"))
}