src/jobs/mod.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use tokio::time::{sleep, Duration};
use tokio_rusqlite::Connection;

use crate::db;
use crate::model::job::Job;

pub async fn start(db_conn: Connection) {
    loop {
        if db::jobs::should_run(&db_conn, Job::MonthlyPayment).await {
            log::info!("Starting monthly payment job");
            db::payments::create_monthly_payments(&db_conn).await;
            db::jobs::actualize_last_execution(&db_conn, Job::MonthlyPayment)
                .await;
        }
        // Sleeping 8 hours
        sleep(Duration::from_secs(8 * 60 * 60)).await;
    }
}