From 459016e70dd4933a8082d27748097de81a3e53ff Mon Sep 17 00:00:00 2001 From: Joris Date: Mon, 17 Apr 2023 21:10:48 +0200 Subject: Follow clippy indications --- src/jobs/jobs.rs | 28 ---------------------------- src/jobs/mod.rs | 29 ++++++++++++++++++++++++++++- 2 files changed, 28 insertions(+), 29 deletions(-) delete mode 100644 src/jobs/jobs.rs (limited to 'src/jobs') diff --git a/src/jobs/jobs.rs b/src/jobs/jobs.rs deleted file mode 100644 index 536ff97..0000000 --- a/src/jobs/jobs.rs +++ /dev/null @@ -1,28 +0,0 @@ -use sqlx::sqlite::SqlitePool; -use tera::Tera; -use tokio::time::{sleep, Duration}; - -use crate::db; -use crate::jobs::weekly_report; -use crate::model::config::Config; -use crate::model::job::Job; - -pub async fn start(config: Config, pool: SqlitePool, templates: Tera) -> () { - loop { - if db::jobs::should_run(&pool, Job::WeeklyReport).await { - info!("Starting weekly report job"); - if weekly_report::send(&config, &pool, &templates).await { - db::jobs::actualize_last_execution(&pool, Job::WeeklyReport) - .await; - } - } - if db::jobs::should_run(&pool, Job::MonthlyPayment).await { - info!("Starting monthly payment job"); - db::payments::create_monthly_payments(&pool).await; - db::jobs::actualize_last_execution(&pool, Job::MonthlyPayment) - .await; - } - // Sleeping 8 hours - sleep(Duration::from_secs(8 * 60 * 60)).await; - } -} diff --git a/src/jobs/mod.rs b/src/jobs/mod.rs index be2ddac..5f95597 100644 --- a/src/jobs/mod.rs +++ b/src/jobs/mod.rs @@ -1,2 +1,29 @@ -pub mod jobs; mod weekly_report; + +use sqlx::sqlite::SqlitePool; +use tera::Tera; +use tokio::time::{sleep, Duration}; + +use crate::db; +use crate::model::config::Config; +use crate::model::job::Job; + +pub async fn start(config: Config, pool: SqlitePool, templates: Tera) { + loop { + if db::jobs::should_run(&pool, Job::WeeklyReport).await { + info!("Starting weekly report job"); + if weekly_report::send(&config, &pool, &templates).await { + db::jobs::actualize_last_execution(&pool, Job::WeeklyReport) + .await; + } + } + if db::jobs::should_run(&pool, Job::MonthlyPayment).await { + info!("Starting monthly payment job"); + db::payments::create_monthly_payments(&pool).await; + db::jobs::actualize_last_execution(&pool, Job::MonthlyPayment) + .await; + } + // Sleeping 8 hours + sleep(Duration::from_secs(8 * 60 * 60)).await; + } +} -- cgit v1.2.3