From 0adf5a093494bdb7f5d5c0f12913133e333ddfad Mon Sep 17 00:00:00 2001
From: Joris
Date: Fri, 31 Jan 2025 22:28:53 +0100
Subject: Migrate to tokio_rusqlite

---
 src/controller/payments.rs | 30 +++++++++++++++---------------
 1 file changed, 15 insertions(+), 15 deletions(-)

(limited to 'src/controller/payments.rs')

diff --git a/src/controller/payments.rs b/src/controller/payments.rs
index b5c0256..1ffa09f 100644
--- a/src/controller/payments.rs
+++ b/src/controller/payments.rs
@@ -19,12 +19,12 @@ pub async fn table(
     query: queries::Payments,
 ) -> Response<Full<Bytes>> {
     let page = query.page.unwrap_or(1);
-    let count = db::payments::count(&wallet.pool, &query).await;
+    let count = db::payments::count(&wallet.db_conn, &query).await;
     let payments =
-        db::payments::list_for_table(&wallet.pool, &query, PER_PAGE).await;
+        db::payments::list_for_table(&wallet.db_conn, &query, PER_PAGE).await;
     let max_page = (count.count as f32 / PER_PAGE as f32).ceil() as i64;
-    let users = db::users::list(&wallet.pool).await;
-    let categories = db::categories::list(&wallet.pool).await;
+    let users = db::users::list(&wallet.db_conn).await;
+    let categories = db::categories::list(&wallet.db_conn).await;
 
     let context = minijinja::context!(
         header => templates::Header::Payments,
@@ -60,8 +60,8 @@ async fn create_form_feedback(
     form: HashMap<String, String>,
     error: Option<String>,
 ) -> Response<Full<Bytes>> {
-    let users = db::users::list(&wallet.pool).await;
-    let categories = db::categories::list(&wallet.pool).await;
+    let users = db::users::list(&wallet.db_conn).await;
+    let categories = db::categories::list(&wallet.db_conn).await;
 
     let context = minijinja::context!(
         header => templates::Header::Payments,
@@ -92,10 +92,10 @@ pub async fn create(
 
     match validation::payment::create(&form) {
         Some(create_payment) => {
-            match db::payments::create(&wallet.pool, &create_payment).await {
+            match db::payments::create(&wallet.db_conn, create_payment.clone()).await {
                 Some(id) => {
                     let row = db::payments::get_row(
-                        &wallet.pool,
+                        &wallet.db_conn,
                         id,
                         create_payment.frequency,
                     )
@@ -139,9 +139,9 @@ async fn update_form_feedback(
     form: HashMap<String, String>,
     error: Option<String>,
 ) -> Response<Full<Bytes>> {
-    let payment = db::payments::get_for_form(&wallet.pool, id).await;
-    let users = db::users::list(&wallet.pool).await;
-    let categories = db::categories::list(&wallet.pool).await;
+    let payment = db::payments::get_for_form(&wallet.db_conn, id).await;
+    let users = db::users::list(&wallet.db_conn).await;
+    let categories = db::categories::list(&wallet.db_conn).await;
 
     let context = minijinja::context!(
         header => templates::Header::Payments,
@@ -181,10 +181,10 @@ pub async fn update(
 
     match validation::payment::update(&form) {
         Some(update_payment) => {
-            if db::payments::update(&wallet.pool, id, &update_payment).await {
+            if db::payments::update(&wallet.db_conn, id, update_payment).await {
                 let frequency = query.frequency.unwrap_or(Frequency::Punctual);
                 let row =
-                    db::payments::get_row(&wallet.pool, id, frequency).await;
+                    db::payments::get_row(&wallet.db_conn, id, frequency).await;
                 let page = (row - 1) / PER_PAGE + 1;
                 // TODO: keep name, cost, user and category when updating a line
                 let query = queries::Payments {
@@ -212,7 +212,7 @@ pub async fn delete(
     wallet: &Wallet,
     query: queries::Payments,
 ) -> Response<Full<Bytes>> {
-    if db::payments::delete(&wallet.pool, id).await {
+    if db::payments::delete(&wallet.db_conn, id).await {
         let query = queries::Payments {
             highlight: None,
             ..query
@@ -234,7 +234,7 @@ pub async fn search_category(
     wallet: &Wallet,
     query: queries::PaymentCategory,
 ) -> Response<Full<Bytes>> {
-    match db::payments::search_category(&wallet.pool, query.payment_name).await
+    match db::payments::search_category(&wallet.db_conn, query.payment_name).await
     {
         Some(category_id) => utils::with_headers(
             Response::new(format!("{}", category_id).into()),
-- 
cgit v1.2.3