opencrabs 0.3.58

//! Schedule data service — surfaces every cron job (enabled or paused)
//! as a uniform `Vec<McScheduleItem>` for the schedule panel.
//!
//! Pending-approval rows aren't yet wired here; they'll join when the
//! approval queue grows a global accessor (today it's session-scoped
//! state inside the agent loop). The `McScheduleKind::PendingApproval`
//! variant on the type side is ready for that data the moment it lands.
//!
//! `list` is async because the cron registry lives in the SQLite DB —
//! the renderer pre-fetches once on `actions::open` rather than calling
//! during each `draw`, so the per-frame cost is just a `Vec::clone`.

use super::types::{McScheduleItem, McScheduleKind};
use crate::db::Pool;
use crate::db::models::{CronJob, CronJobRun};
use crate::db::repository::{CronJobRepository, CronJobRunRepository};

/// Read every cron job (enabled + paused), sorted by name. Returns an
/// empty list on DB error so a transient SQLite blip doesn't bring
/// the whole MC down.
///
/// Also fetches the most recent run for each job so the detail popup
/// can show status, cost, and duration.
pub async fn list(pool: Pool) -> Vec<McScheduleItem> {
    let repo = CronJobRepository::new(pool.clone());
    let run_repo = CronJobRunRepository::new(pool);
    let jobs = match repo.list_all().await {
        Ok(j) => j,
        Err(e) => {
            // `{e:#}` walks the full anyhow chain (top context →
            // interact_err → underlying rusqlite::Error). Without this
            // alternate flag we only see "Failed to list cron jobs"
            // and lose the actual SQL-side cause — which is exactly the
            // blind spot that hid the 2026-05-17 MC empty-schedule bug
            // until it was investigated row-by-row.
            tracing::warn!("schedule_service: failed to list cron jobs: {e:#}");
            return Vec::new();
        }
    };

    // Fetch recent runs (last 100) and group by job_id to get the
    // latest run for each job. This avoids N+1 queries.
    let recent_runs = run_repo.list_recent(100).await.unwrap_or_default();
    let mut last_runs: std::collections::HashMap<String, &CronJobRun> =
        std::collections::HashMap::new();
    for run in &recent_runs {
        let job_id = run.job_id.to_string();
        // Keep only the most recent run per job (list_recent is
        // ordered by created_at DESC, so first seen = most recent).
        last_runs.entry(job_id).or_insert(run);
    }

    jobs.into_iter()
        .map(|job| item_from_cron(job, &last_runs))
        .collect()
}

fn item_from_cron(
    job: CronJob,
    last_runs: &std::collections::HashMap<String, &CronJobRun>,
) -> McScheduleItem {
    let schedule = format_cron_schedule(&job);
    let job_id_str = job.id.to_string();
    let last_run = last_runs.get(&job_id_str);

    let last_run_status = last_run.map(|r| r.status.clone());
    let last_run_cost = last_run.map(|r| r.cost);
    let last_run_duration_secs =
        last_run.and_then(|r| r.completed_at.map(|c| (c - r.started_at).num_seconds()));

    McScheduleItem {
        id: job_id_str,
        label: job.name,
        schedule,
        kind: McScheduleKind::Cron,
        // Disabled cron jobs stay visible so the user can re-enable
        // them from the UI later, but they're flagged as "awaiting
        // user" so the renderer can dim or badge them differently.
        awaiting_user: !job.enabled,
        prompt: job.prompt,
        deliver_to: job.deliver_to,
        last_run_at: job.last_run_at,
        next_run_at: job.next_run_at,
        created_at: job.created_at,
        enabled: job.enabled,
        profile_name: job.profile_name,
        last_run_status,
        last_run_cost,
        last_run_duration_secs,
    }
}

/// Compose a human-friendly schedule string. Examples:
///   `0 9 * * *` (UTC)
///   `*/5 * * * *` (Europe/London) — paused, last 14:23
fn format_cron_schedule(job: &CronJob) -> String {
    let mut parts: Vec<String> = vec![job.cron_expr.clone()];
    if !job.timezone.is_empty() && job.timezone != "UTC" {
        parts.push(format!("({})", job.timezone));
    }
    if !job.enabled {
        parts.push("paused".to_string());
    } else if let Some(next) = job.next_run_at {
        parts.push(format!("next {}", next.format("%Y-%m-%d %H:%M")));
    }
    parts.join(" ")
}