rustploy 0.1.14

//! Ticker de agendamento dos jobs one-shot — mesmo formato de `metrics.rs`/
//! `env_backup.rs`: `tokio::time::interval`, a cada tick busca os jobs
//! vencidos e dispara cada um em background (não bloqueia o próprio ticker).

use crate::features::jobs::JobsContext;
use crate::store;
use std::time::Duration;
use tokio::time::MissedTickBehavior;
use tracing::{debug, warn};

const TICK_SECS: u64 = 30;

pub async fn scheduler_loop(state: JobsContext) {
    let mut ticker = tokio::time::interval(Duration::from_secs(TICK_SECS));
    ticker.set_missed_tick_behavior(MissedTickBehavior::Skip);
    loop {
        ticker.tick().await;
        let due = match store::job::list_due(&state.db, chrono::Utc::now()).await {
            Ok(jobs) => jobs,
            Err(e) => {
                warn!(error = %e, "scheduler_loop: falha ao listar jobs vencidos");
                continue;
            }
        };
        for job in due {
            let job_id = job.id.clone();
            // Já há uma execução deste job esperando a vez ou rodando (por
            // exemplo, um job mais longo que o intervalo dele, ou preso atrás de
            // um deploy demorado): não empilha outra. O `next_run_at` só volta a
            // andar quando aquela terminar.
            match store::job_run::has_unfinished(&state.db, &job_id).await {
                Ok(true) => {
                    debug!(job_id = %job_id, "scheduler_loop: job vencido, mas já tem execução em andamento — pulando");
                    continue;
                }
                Ok(false) => {}
                Err(e) => {
                    warn!(job_id = %job_id, error = %e, "scheduler_loop: falha ao checar execuções em andamento");
                    continue;
                }
            }
            if let Err(e) = super::runner::spawn(&state, job).await {
                warn!(job_id = %job_id, error = %e, "scheduler_loop: falha ao disparar job agendado");
            }
        }
    }
}