diff options
Diffstat (limited to 'src/jobs/mod.rs')
| -rw-r--r-- | src/jobs/mod.rs | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/jobs/mod.rs b/src/jobs/mod.rs index a718d93..3bfca71 100644 --- a/src/jobs/mod.rs +++ b/src/jobs/mod.rs @@ -1,7 +1,7 @@ mod weekly_report; -use sqlx::sqlite::SqlitePool; use tokio::time::{sleep, Duration}; +use tokio_rusqlite::Connection; use crate::db; use crate::model::config::Config; @@ -9,21 +9,21 @@ use crate::model::job::Job; pub async fn start( config: Config, - pool: SqlitePool, + db_conn: Connection, templates: minijinja::Environment<'_>, ) { loop { - if db::jobs::should_run(&pool, Job::WeeklyReport).await { + if db::jobs::should_run(&db_conn, Job::WeeklyReport).await { log::info!("Starting weekly report job"); - if weekly_report::send(&config, &pool, &templates).await { - db::jobs::actualize_last_execution(&pool, Job::WeeklyReport) + if weekly_report::send(&config, &db_conn, &templates).await { + db::jobs::actualize_last_execution(&db_conn, Job::WeeklyReport) .await; } } - if db::jobs::should_run(&pool, Job::MonthlyPayment).await { + if db::jobs::should_run(&db_conn, Job::MonthlyPayment).await { log::info!("Starting monthly payment job"); - db::payments::create_monthly_payments(&pool).await; - db::jobs::actualize_last_execution(&pool, Job::MonthlyPayment) + db::payments::create_monthly_payments(&db_conn).await; + db::jobs::actualize_last_execution(&db_conn, Job::MonthlyPayment) .await; } // Sleeping 8 hours |