1 files changed, 28 insertions, 1 deletions
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;
+    }
+}