From 2361adeb0ca77904138e3466d51c2f44cf6df613 Mon Sep 17 00:00:00 2001 From: Joe Carstairs Date: Mon, 28 Jul 2025 13:22:53 +0100 Subject: Tidier folders --- schist_queries/src/account_transfers.rs | 40 --------------------------------- 1 file changed, 40 deletions(-) delete mode 100644 schist_queries/src/account_transfers.rs (limited to 'schist_queries/src/account_transfers.rs') diff --git a/schist_queries/src/account_transfers.rs b/schist_queries/src/account_transfers.rs deleted file mode 100644 index 070bdc3..0000000 --- a/schist_queries/src/account_transfers.rs +++ /dev/null @@ -1,40 +0,0 @@ -use anyhow::{Context, Result}; -use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::account_transfer::AccountTransfer; -use schist_schema::schema::account_transfers::dsl::account_transfers as account_transfers_table; - -pub fn delete_all_account_transfers(connection: &mut SqliteConnection) -> Result { - let num_rows_deleted = diesel::delete(account_transfers_table) - .execute(connection) - .with_context(|| "failed to delete all account_transfers")?; - Ok(num_rows_deleted) -} - -pub fn get_all_account_transfers(connection: &mut SqliteConnection) -> Result> { - let all_account_transfers = account_transfers_table.select(AccountTransfer::as_select()) - .load(connection) - .with_context(|| "failed to get all account transfers")?; - Ok(all_account_transfers) -} - -pub fn insert_account_transfers( - account_transfers: &[AccountTransfer], - connection: &mut SqliteConnection, -) -> Result { - let num_account_transfers_inserted = diesel::insert_into(account_transfers_table) - .values(account_transfers) - .execute(connection) - .with_context(|| insert_err_msg(account_transfers))?; - Ok(num_account_transfers_inserted) -} - -fn insert_err_msg(account_transfers: &[AccountTransfer]) -> String { - format!( - "failed to insert account transfers: [{}]", - account_transfers - .iter() - .map(|a| a.id.to_string()) - .collect::>() - .join(", ") - ) -} -- cgit v1.2.3