diff options
| author | Joe Carstairs <me@joeac.net> | 2025-08-16 07:46:21 +0100 |
|---|---|---|
| committer | Joe Carstairs <me@joeac.net> | 2025-08-16 18:22:47 +0100 |
| commit | d082a30de6a0cbd1fbe2ab5a4316db0891004129 (patch) | |
| tree | c097414625e1948116383406d894842fccc98227 /schist_core/schist_queries/src | |
| parent | 9c0bc43bf0b83828d9bdf8005fcccbc33dcf4171 (diff) | |
refactor models and traits with pub use
Diffstat (limited to 'schist_core/schist_queries/src')
9 files changed, 15 insertions, 15 deletions
diff --git a/schist_core/schist_queries/src/account_transfers.rs b/schist_core/schist_queries/src/account_transfers.rs index 070bdc3..798344b 100644 --- a/schist_core/schist_queries/src/account_transfers.rs +++ b/schist_core/schist_queries/src/account_transfers.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::account_transfer::AccountTransfer; +use schist_models::AccountTransfer; use schist_schema::schema::account_transfers::dsl::account_transfers as account_transfers_table; pub fn delete_all_account_transfers(connection: &mut SqliteConnection) -> Result<usize> { @@ -10,8 +10,11 @@ pub fn delete_all_account_transfers(connection: &mut SqliteConnection) -> Result Ok(num_rows_deleted) } -pub fn get_all_account_transfers(connection: &mut SqliteConnection) -> Result<Vec<AccountTransfer>> { - let all_account_transfers = account_transfers_table.select(AccountTransfer::as_select()) +pub fn get_all_account_transfers( + connection: &mut SqliteConnection, +) -> Result<Vec<AccountTransfer>> { + 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) diff --git a/schist_core/schist_queries/src/accounts.rs b/schist_core/schist_queries/src/accounts.rs index 289faf6..7b9b834 100644 --- a/schist_core/schist_queries/src/accounts.rs +++ b/schist_core/schist_queries/src/accounts.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::account::Account; +use schist_models::Account; use schist_schema::schema::accounts::dsl::accounts as accounts_table; pub fn delete_all_accounts(connection: &mut SqliteConnection) -> Result<usize> { diff --git a/schist_core/schist_queries/src/bucket_transfers.rs b/schist_core/schist_queries/src/bucket_transfers.rs index 923867f..652c8e0 100644 --- a/schist_core/schist_queries/src/bucket_transfers.rs +++ b/schist_core/schist_queries/src/bucket_transfers.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{dsl::sum, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::bucket_transfer::BucketTransfer; +use schist_models::BucketTransfer; use schist_schema::schema::bucket_transfers::{ self as bucket_transfers_schema, dsl::bucket_transfers as bucket_transfers_table, }; diff --git a/schist_core/schist_queries/src/buckets.rs b/schist_core/schist_queries/src/buckets.rs index 29270af..aedfd10 100644 --- a/schist_core/schist_queries/src/buckets.rs +++ b/schist_core/schist_queries/src/buckets.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::bucket::Bucket; +use schist_models::Bucket; use schist_schema::schema::buckets::{self as buckets_schema, dsl::buckets as buckets_table}; pub fn delete_all_buckets(connection: &mut SqliteConnection) -> Result<usize> { diff --git a/schist_core/schist_queries/src/drips.rs b/schist_core/schist_queries/src/drips.rs index d9e33a8..e87491f 100644 --- a/schist_core/schist_queries/src/drips.rs +++ b/schist_core/schist_queries/src/drips.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::drip::Drip; +use schist_models::Drip; use schist_schema::schema::drips::dsl::drips as drips_table; pub fn delete_all_drips(connection: &mut SqliteConnection) -> Result<usize> { diff --git a/schist_core/schist_queries/src/pipes.rs b/schist_core/schist_queries/src/pipes.rs index 188d193..b471a42 100644 --- a/schist_core/schist_queries/src/pipes.rs +++ b/schist_core/schist_queries/src/pipes.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{dsl::sum, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::pipe::Pipe; +use schist_models::Pipe; use schist_schema::schema::pipes::{self as pipes_schema, dsl::pipes as pipes_table}; pub fn delete_all_pipes(connection: &mut SqliteConnection) -> Result<usize> { @@ -18,10 +18,7 @@ pub fn get_all_pipes(connection: &mut SqliteConnection) -> Result<Vec<Pipe>> { Ok(all_pipes) } -pub fn insert_pipes( - pipes: &[Pipe], - connection: &mut SqliteConnection, -) -> Result<usize> { +pub fn insert_pipes(pipes: &[Pipe], connection: &mut SqliteConnection) -> Result<usize> { let num_rows_inserted = diesel::insert_into(pipes_table) .values(pipes) .execute(connection) diff --git a/schist_core/schist_queries/src/transactions.rs b/schist_core/schist_queries/src/transactions.rs index 3abacfb..c4c060a 100644 --- a/schist_core/schist_queries/src/transactions.rs +++ b/schist_core/schist_queries/src/transactions.rs @@ -1,6 +1,6 @@ use anyhow::{Context, Result}; use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection}; -use schist_models::transaction::Transaction; +use schist_models::Transaction; use schist_schema::schema::transactions::dsl::transactions as transactions_table; pub fn delete_all_transactions(connection: &mut SqliteConnection) -> Result<usize> { diff --git a/schist_core/schist_queries/src/utils/calculate_bucket_balance.rs b/schist_core/schist_queries/src/utils/calculate_bucket_balance.rs index e238613..e76a919 100644 --- a/schist_core/schist_queries/src/utils/calculate_bucket_balance.rs +++ b/schist_core/schist_queries/src/utils/calculate_bucket_balance.rs @@ -1,5 +1,5 @@ use anyhow::Result; -use schist_models::{bucket::Bucket, drip::Drip}; +use schist_models::{Bucket, Drip}; use super::{find_by_id_or, sum_drips_for_bucket}; diff --git a/schist_core/schist_queries/src/utils/sum_drips_for_bucket.rs b/schist_core/schist_queries/src/utils/sum_drips_for_bucket.rs index 76f7988..20d05a0 100644 --- a/schist_core/schist_queries/src/utils/sum_drips_for_bucket.rs +++ b/schist_core/schist_queries/src/utils/sum_drips_for_bucket.rs @@ -1,5 +1,5 @@ use anyhow::Result; -use schist_models::{bucket::Bucket, drip::Drip}; +use schist_models::{Bucket, Drip}; pub fn sum_drips_for_bucket(bucket: &Bucket, budget_drips: &[Drip]) -> Result<i64> { Ok(budget_drips |
