diff options
Diffstat (limited to 'src/jobs/weekly_report.rs')
| -rw-r--r-- | src/jobs/weekly_report.rs | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/src/jobs/weekly_report.rs b/src/jobs/weekly_report.rs index 5058c52..a91a3fb 100644 --- a/src/jobs/weekly_report.rs +++ b/src/jobs/weekly_report.rs @@ -1,5 +1,5 @@ -use sqlx::sqlite::SqlitePool; use std::collections::HashMap; +use tokio_rusqlite::Connection; use crate::db; use crate::mail; @@ -8,12 +8,12 @@ use crate::payer; pub async fn send( config: &Config, - pool: &SqlitePool, + db_conn: &Connection, env: &minijinja::Environment<'_>, ) -> bool { - match get_weekly_report(pool, env).await { + match get_weekly_report(db_conn, env).await { Ok(report) => { - let users = db::users::list(pool).await; + let users = db::users::list(db_conn).await; mail::send( config, users @@ -39,21 +39,21 @@ pub async fn send( } async fn get_weekly_report( - pool: &SqlitePool, + db_conn: &Connection, env: &minijinja::Environment<'_>, ) -> Result<String, minijinja::Error> { - let users = db::users::list(pool).await; - let incomes_from = db::incomes::defined_for_all(pool).await; + let users = db::users::list(db_conn).await; + let incomes_from = db::incomes::defined_for_all(db_conn).await; let user_incomes = match incomes_from { - Some(from) => db::incomes::cumulative(pool, from).await, + Some(from) => db::incomes::cumulative(db_conn, from).await, None => HashMap::new(), }; - let user_payments = db::payments::repartition(pool).await; + let user_payments = db::payments::repartition(db_conn).await; let exceeding_payers = payer::exceeding(&users, &user_incomes, &user_payments); - let last_week_payments = db::payments::last_week(pool).await; - let last_week_incomes = db::incomes::last_week(pool).await; + let last_week_payments = db::payments::last_week(db_conn).await; + let last_week_incomes = db::incomes::last_week(db_conn).await; let template = env.get_template("report/report.j2")?; template.render(minijinja::context!( |