use anyhow::Result;
use crate::cli::types::PendingAction;
use crate::db;
pub(in crate::cli) fn run_pending(action: PendingAction) -> Result<()> {
let conn = db::open_db()?;
match action {
PendingAction::ListFailed { project, limit } => {
let rows = db::pending::admin::list_failed(&conn, project.as_deref(), limit)?;
if rows.is_empty() {
println!("No failed pending observations.");
return Ok(());
}
println!("Failed pending observations ({}):", rows.len());
for row in rows {
let ts = chrono::DateTime::from_timestamp(row.updated_at_epoch, 0)
.map(|dt| dt.format("%Y-%m-%d %H:%M").to_string())
.unwrap_or_default();
let err = row
.last_error
.as_deref()
.map(|message| db::truncate_str(message, 120).to_string())
.unwrap_or_default();
println!(
" [{}] {} | {} | {} | attempt={} | {}",
row.id, row.project, row.session_id, row.tool_name, row.attempt_count, ts
);
if !err.is_empty() {
println!(" error: {}", err);
}
}
}
PendingAction::RetryFailed {
project,
limit,
dry_run,
} => {
if dry_run {
let count = db::pending::admin::count_failed_retry_candidates(
&conn,
project.as_deref(),
limit,
)?;
println!("Would move {} failed rows back to pending.", count);
} else {
let count = db::pending::admin::retry_failed(&conn, project.as_deref(), limit)?;
println!("Moved {} failed rows back to pending.", count);
}
}
PendingAction::PurgeFailed {
project,
older_than_days,
dry_run,
} => {
if dry_run {
let count = db::pending::admin::count_failed_purge_candidates(
&conn,
project.as_deref(),
older_than_days,
)?;
println!(
"Would purge {} failed rows older than {} day(s).",
count, older_than_days
);
} else {
let count =
db::pending::admin::purge_failed(&conn, project.as_deref(), older_than_days)?;
println!(
"Purged {} failed rows older than {} day(s).",
count, older_than_days
);
}
}
}
Ok(())
}