Merge pull request 'random-stuff' (#4) from random-stuff into main

Reviewed-on: https://git.joeac.net/joeac/schist/pulls/4

20 files changed, 280 insertions, 326 deletions

diff --git a/schist_core/schist_fakes/src/bucket_transaction.rs b/schist_core/schist_fakes/src/bucket_transaction.rs
new file mode 100644
index 0000000..45aa39c
--- /dev/null
+++ b/schist_core/schist_fakes/src/bucket_transaction.rs
@@ -0,0 +1,16 @@
+use schist_models::{BucketTransaction, BucketTransactionBuilder, DateUtc};
+
+pub fn make_fake_bucket_transaction(id: i32) -> BucketTransaction {
+    make_fake_bucket_transaction_builder(id).build().unwrap()
+}
+
+pub fn make_fake_bucket_transaction_builder(id: i32) -> BucketTransactionBuilder {
+    let mut builder = BucketTransactionBuilder::default();
+    builder
+        .id(id)
+        .description(String::from("Fake bucket transaction"))
+        .amount(0)
+        .date(DateUtc::from_ymd(1970, 1, 1).unwrap())
+        .bucket_id(1);
+    builder
+}
diff --git a/schist_core/schist_fakes/src/bucket_transfer.rs b/schist_core/schist_fakes/src/bucket_transfer.rs
deleted file mode 100644
index 1342ca2..0000000
--- a/schist_core/schist_fakes/src/bucket_transfer.rs
+++ /dev/null
@@ -1,16 +0,0 @@
-use schist_models::{BucketTransfer, BucketTransferBuilder};
-
-pub fn make_fake_bucket_transfer(id: i32) -> BucketTransfer {
-    make_fake_bucket_transfer_builder(id).build().unwrap()
-}
-
-pub fn make_fake_bucket_transfer_builder(id: i32) -> BucketTransferBuilder {
-    let mut builder = BucketTransferBuilder::default();
-    builder
-        .id(id)
-        .description(String::from("Fake bucket transfer"))
-        .amount(0)
-        .from_bucket_id(0)
-        .to_bucket_id(1);
-    builder
-}
diff --git a/schist_core/schist_fakes/src/lib.rs b/schist_core/schist_fakes/src/lib.rs
index 0e4cbb4..7ac98fa 100644
--- a/schist_core/schist_fakes/src/lib.rs
+++ b/schist_core/schist_fakes/src/lib.rs
@@ -1,7 +1,7 @@
 pub mod account;
 pub mod account_transfer;
 pub mod bucket;
-pub mod bucket_transfer;
+pub mod bucket_transaction;
 pub mod drip;
 pub mod pipe;
 pub mod transaction;
diff --git a/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/down.sql b/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/down.sql
index 3b2c73e..f6ead07 100644
--- a/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/down.sql
+++ b/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/down.sql
@@ -1,7 +1,7 @@
 DROP TABLE accounts;
 DROP TABLE account_transfers;
 DROP TABLE buckets;
-DROP TABLE bucket_transfers;
+DROP TABLE bucket_transactions;
 DROP TABLE drips;
 DROP TABLE pipes;
 DROP TABLE transactions;
diff --git a/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/up.sql b/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/up.sql
index b37c626..da85b33 100644
--- a/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/up.sql
+++ b/schist_core/schist_models/migrations/2024-08-31-084439_initial_setup/up.sql
@@ -32,17 +32,13 @@ CREATE TABLE buckets(
     name TEXT NOT NULL
 );
 
-CREATE TABLE bucket_transfers(
+CREATE TABLE bucket_transactions(
     id INTEGER NOT NULL PRIMARY KEY,
     amount INTEGER NOT NULL,
+    bucket_id INTEGER NOT NULL,
+    date TEXT NOT NULL,
     description TEXT NOT NULL,
-    from_bucket_id INTEGER NOT NULL,
-    to_bucket_id INTEGER NOT NULL,
-    FOREIGN KEY (from_bucket_id)
-        REFERENCES buckets (id)
-        ON UPDATE CASCADE
-        ON DELETE RESTRICT,
-    FOREIGN KEY (to_bucket_id)
+    FOREIGN KEY (bucket_id)
         REFERENCES buckets (id)
         ON UPDATE CASCADE
         ON DELETE RESTRICT
diff --git a/schist_core/schist_models/src/bucket.rs b/schist_core/schist_models/src/bucket.rs
index a28aa8f..debbab7 100644
--- a/schist_core/schist_models/src/bucket.rs
+++ b/schist_core/schist_models/src/bucket.rs
@@ -1,3 +1,5 @@
+use std::ops::Div;
+
 use derive_builder::Builder;
 use diesel::prelude::*;
 use serde::{Deserialize, Serialize};
@@ -33,4 +35,13 @@ impl Bucket {
                 .iter()
                 .all(|t| t.bucket_id.is_none_or(|id| id != self.id))
     }
+
+    pub fn pretty_balance_per_100(&self) -> String {
+        let abs_balance_per_100 = self.balance.unwrap_or(0).div(100).abs();
+        if self.balance.is_none_or(|balance| balance >= 0) {
+            abs_balance_per_100.to_string()
+        } else {
+            format!("({abs_balance_per_100})")
+        }
+    }
 }
diff --git a/schist_core/schist_models/src/bucket_transfer.rs b/schist_core/schist_models/src/bucket_transaction.rs
index 7c3a9d2..a956d0b 100644
--- a/schist_core/schist_models/src/bucket_transfer.rs
+++ b/schist_core/schist_models/src/bucket_transaction.rs
@@ -1,12 +1,14 @@
 use derive_builder::Builder;
 use diesel::prelude::*;
 
+use crate::date_utc::DateUtc;
+
 #[derive(Builder, Queryable, Identifiable, Selectable, Debug, PartialEq, Insertable)]
-#[diesel(table_name = crate::schema::bucket_transfers)]
-pub struct BucketTransfer {
+#[diesel(table_name = crate::schema::bucket_transactions)]
+pub struct BucketTransaction {
     pub id: i32,
     pub amount: i32,
+    pub bucket_id: i32,
+    pub date: DateUtc,
     pub description: String,
-    pub from_bucket_id: i32,
-    pub to_bucket_id: i32,
 }
diff --git a/schist_core/schist_models/src/date_utc.rs b/schist_core/schist_models/src/date_utc.rs
index 18a894b..927644c 100644
--- a/schist_core/schist_models/src/date_utc.rs
+++ b/schist_core/schist_models/src/date_utc.rs
@@ -105,7 +105,7 @@ impl DateUtc {
         return true;
     }
 
-    fn first_day_in_next_month(&self) -> Self {
+    pub fn first_day_in_next_month(&self) -> Self {
         let month = self.month();
         let mut curr_guess: Option<DateTime<Utc>> = None;
         let mut curr_add = 1;
@@ -120,7 +120,7 @@ impl DateUtc {
         };
     }
 
-    fn first_day_in_month(&self) -> Self {
+    pub fn first_day_in_month(&self) -> Self {
         let month = self.month();
         let mut prev_guess = self.clone();
         let mut curr_guess = self.clone();
diff --git a/schist_core/schist_models/src/lib.rs b/schist_core/schist_models/src/lib.rs
index 3aa4733..2a119cb 100644
--- a/schist_core/schist_models/src/lib.rs
+++ b/schist_core/schist_models/src/lib.rs
@@ -1,7 +1,7 @@
 mod account;
 mod account_transfer;
 mod bucket;
-mod bucket_transfer;
+mod bucket_transaction;
 mod budget_period_unit;
 mod date_utc;
 mod datetime_utc;
@@ -15,7 +15,7 @@ pub mod schema;
 pub use account::Account;
 pub use account_transfer::{AccountTransfer, AccountTransferBuilder};
 pub use bucket::{Bucket, BucketBuilder};
-pub use bucket_transfer::{BucketTransfer, BucketTransferBuilder};
+pub use bucket_transaction::{BucketTransaction, BucketTransactionBuilder};
 pub use budget_period_unit::BudgetPeriodUnit;
 pub use date_utc::DateUtc;
 pub use datetime_utc::DatetimeUtc;
diff --git a/schist_core/schist_models/src/schema.rs b/schist_core/schist_models/src/schema.rs
index d16e636..9579e5c 100644
--- a/schist_core/schist_models/src/schema.rs
+++ b/schist_core/schist_models/src/schema.rs
@@ -21,12 +21,12 @@ diesel::table! {
 }
 
 diesel::table! {
-    bucket_transfers (id) {
+    bucket_transactions (id) {
         id -> Integer,
         amount -> Integer,
+        bucket_id -> Integer,
+        date -> Text,
         description -> Text,
-        from_bucket_id -> Integer,
-        to_bucket_id -> Integer,
     }
 }
 
@@ -74,6 +74,7 @@ diesel::table! {
     }
 }
 
+diesel::joinable!(bucket_transactions -> buckets (bucket_id));
 diesel::joinable!(drips -> buckets (bucket_id));
 diesel::joinable!(pipes -> buckets (bucket_id));
 diesel::joinable!(transactions -> accounts (account_id));
@@ -81,7 +82,7 @@ diesel::joinable!(transactions -> accounts (account_id));
 diesel::allow_tables_to_appear_in_same_query!(
     account_transfers,
     accounts,
-    bucket_transfers,
+    bucket_transactions,
     buckets,
     drips,
     pipes,
diff --git a/schist_core/schist_models/user_data.sqlite b/schist_core/schist_models/user_data.sqlite
deleted file mode 100644
index 175ce60..0000000
--- a/schist_core/schist_models/user_data.sqlite
+++ /dev/null
diff --git a/schist_core/schist_queries/src/bucket_transactions.rs b/schist_core/schist_queries/src/bucket_transactions.rs
new file mode 100644
index 0000000..da06341
--- /dev/null
+++ b/schist_core/schist_queries/src/bucket_transactions.rs
@@ -0,0 +1,65 @@
+use anyhow::{Context, Result};
+use diesel::{dsl::sum, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
+use schist_models::BucketTransaction;
+use schist_schema::schema::bucket_transactions::{
+    self as bucket_transactions_schema, dsl::bucket_transactions as bucket_transactions_table,
+};
+
+pub fn delete_all_bucket_transactions(connection: &mut SqliteConnection) -> Result<usize> {
+    let num_rows_deleted = diesel::delete(bucket_transactions_table)
+        .execute(connection)
+        .with_context(|| "failed to delete all bucket transactions")?;
+    Ok(num_rows_deleted)
+}
+
+pub fn get_all_bucket_transactions(
+    connection: &mut SqliteConnection,
+) -> Result<Vec<BucketTransaction>> {
+    let all_bucket_transactions = bucket_transactions_table
+        .select(BucketTransaction::as_select())
+        .load(connection)
+        .with_context(|| "failed to get all bucket transactions")?;
+    Ok(all_bucket_transactions)
+}
+
+pub fn insert_bucket_transactions(
+    bucket_transactions: &[BucketTransaction],
+    connection: &mut SqliteConnection,
+) -> Result<usize> {
+    let num_rows_inserted = diesel::insert_into(bucket_transactions_table)
+        .values(bucket_transactions)
+        .execute(connection)
+        .with_context(|| insert_err_msg(&bucket_transactions))?;
+    Ok(num_rows_inserted)
+}
+
+fn insert_err_msg(bucket_transactions: &[BucketTransaction]) -> String {
+    format!(
+        "failed to insert bucket transactions: [{}]",
+        bucket_transactions
+            .iter()
+            .map(|ct| ct.id.to_string())
+            .collect::<Vec<String>>()
+            .join(", ")
+    )
+}
+
+pub fn sum_bucket_transaction_amount_per_bucket_id(
+    connection: &mut SqliteConnection,
+) -> Result<Vec<(i32, i64)>> {
+    let sum = bucket_transactions_table
+        .group_by(bucket_transactions_schema::bucket_id)
+        .select((
+            bucket_transactions_schema::bucket_id,
+            sum(bucket_transactions_schema::amount),
+        ))
+        .load::<(i32, Option<i64>)>(connection)
+        .map(|result| {
+            result
+                .iter()
+                .map(|sum| (sum.0, sum.1.unwrap_or(0)))
+                .collect()
+        })
+        .with_context(|| "failed to sum bucket transaction amount per bucket ID")?;
+    Ok(sum)
+}
diff --git a/schist_core/schist_queries/src/bucket_transfers.rs b/schist_core/schist_queries/src/bucket_transfers.rs
deleted file mode 100644
index 652c8e0..0000000
--- a/schist_core/schist_queries/src/bucket_transfers.rs
+++ /dev/null
@@ -1,82 +0,0 @@
-use anyhow::{Context, Result};
-use diesel::{dsl::sum, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
-use schist_models::BucketTransfer;
-use schist_schema::schema::bucket_transfers::{
-    self as bucket_transfers_schema, dsl::bucket_transfers as bucket_transfers_table,
-};
-
-pub fn delete_all_bucket_transfers(connection: &mut SqliteConnection) -> Result<usize> {
-    let num_rows_deleted = diesel::delete(bucket_transfers_table)
-        .execute(connection)
-        .with_context(|| "failed to delete all bucket transfers")?;
-    Ok(num_rows_deleted)
-}
-
-pub fn get_all_bucket_transfers(connection: &mut SqliteConnection) -> Result<Vec<BucketTransfer>> {
-    let all_bucket_transfers = bucket_transfers_table
-        .select(BucketTransfer::as_select())
-        .load(connection)
-        .with_context(|| "failed to get all bucket transfers")?;
-    Ok(all_bucket_transfers)
-}
-
-pub fn insert_bucket_transfers(
-    bucket_transfers: &[BucketTransfer],
-    connection: &mut SqliteConnection,
-) -> Result<usize> {
-    let num_rows_inserted = diesel::insert_into(bucket_transfers_table)
-        .values(bucket_transfers)
-        .execute(connection)
-        .with_context(|| insert_err_msg(&bucket_transfers))?;
-    Ok(num_rows_inserted)
-}
-
-fn insert_err_msg(bucket_transfers: &[BucketTransfer]) -> String {
-    format!(
-        "failed to insert bucket transfers: [{}]",
-        bucket_transfers
-            .iter()
-            .map(|ct| ct.id.to_string())
-            .collect::<Vec<String>>()
-            .join(", ")
-    )
-}
-
-pub fn sum_bucket_transfer_quantity_per_from_bucket_id(
-    connection: &mut SqliteConnection,
-) -> Result<Vec<(i32, i64)>> {
-    let sum = bucket_transfers_table
-        .group_by(bucket_transfers_schema::from_bucket_id)
-        .select((
-            bucket_transfers_schema::from_bucket_id,
-            sum(bucket_transfers_schema::amount),
-        ))
-        .load::<(i32, Option<i64>)>(connection)
-        .map(|result| {
-            result
-                .iter()
-                .map(|sum| (sum.0, sum.1.unwrap_or(0)))
-                .collect()
-        })
-        .with_context(|| "failed to sum bucket transfer quantity per from bucket ID")?;
-    Ok(sum)
-}
-
-pub fn sum_bucket_transfer_quantity_per_to_bucket_id(
-    connection: &mut SqliteConnection,
-) -> Result<Vec<(i32, i64)>> {
-    let sum = bucket_transfers_table
-        .group_by(bucket_transfers_schema::to_bucket_id)
-        .select((
-            bucket_transfers_schema::to_bucket_id,
-            sum(bucket_transfers_schema::amount),
-        ))
-        .load::<(i32, Option<i64>)>(connection)
-        .map(|vec| {
-            vec.iter()
-                .map(|(id, sum)| (*id, sum.unwrap_or(0)))
-                .collect()
-        })
-        .with_context(|| "failed to sum bucket transfer quantity per to bucket ID")?;
-    Ok(sum)
-}
diff --git a/schist_core/schist_queries/src/clear.rs b/schist_core/schist_queries/src/clear.rs
index a5a82f3..845e109 100644
--- a/schist_core/schist_queries/src/clear.rs
+++ b/schist_core/schist_queries/src/clear.rs
@@ -2,7 +2,9 @@ use anyhow::Result;
 use diesel::SqliteConnection;
 
 use crate::{
-    account_transfers::delete_all_account_transfers, accounts::delete_all_accounts, bucket_transfers::delete_all_bucket_transfers, buckets::delete_all_buckets, drips::delete_all_drips, pipes::delete_all_pipes, transactions::delete_all_transactions
+    account_transfers::delete_all_account_transfers, accounts::delete_all_accounts,
+    bucket_transactions::delete_all_bucket_transactions, buckets::delete_all_buckets,
+    drips::delete_all_drips, pipes::delete_all_pipes, transactions::delete_all_transactions,
 };
 
 pub fn clear(connection: &mut SqliteConnection) -> Result<()> {
@@ -11,7 +13,7 @@ pub fn clear(connection: &mut SqliteConnection) -> Result<()> {
     delete_all_pipes(connection)?;
     delete_all_transactions(connection)?;
     delete_all_accounts(connection)?;
-    delete_all_bucket_transfers(connection)?;
+    delete_all_bucket_transactions(connection)?;
     delete_all_buckets(connection)?;
     Ok(())
 }
diff --git a/schist_core/schist_queries/src/lib.rs b/schist_core/schist_queries/src/lib.rs
index ccd558d..ee74d6b 100644
--- a/schist_core/schist_queries/src/lib.rs
+++ b/schist_core/schist_queries/src/lib.rs
@@ -1,6 +1,6 @@
 pub mod account_transfers;
 pub mod accounts;
-pub mod bucket_transfers;
+pub mod bucket_transactions;
 pub mod buckets;
 pub mod clear;
 pub mod drips;
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 20d05a0..27f6036 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
@@ -42,7 +42,7 @@ mod test {
     }
 
     #[test]
-    fn when_one_budget_drip_then_return_quantity() {
+    fn when_one_budget_drip_then_return_amount() {
         let bucket = make_fake_bucket(0);
         let budget_drips = [make_fake_drip_builder(0)
             .amount(100)
diff --git a/schist_core/schist_queries/tests/bucket_transactions.rs b/schist_core/schist_queries/tests/bucket_transactions.rs
new file mode 100644
index 0000000..0b63458
--- /dev/null
+++ b/schist_core/schist_queries/tests/bucket_transactions.rs
@@ -0,0 +1,160 @@
+mod common;
+
+use common::test_context::TestContext;
+use diesel::{Connection, SqliteConnection};
+use schist_fakes::{
+    bucket::make_fake_bucket, bucket_transaction::make_fake_bucket_transaction_builder,
+};
+use schist_queries as queries;
+
+#[test]
+fn when_insert_bucket_transactions_then_returns_num_bucket_transactions() {
+    let context = TestContext::new();
+    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
+    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
+    let bucket_transactions = [
+        make_fake_bucket_transaction_builder(0)
+            .bucket_id(0)
+            .build()
+            .unwrap(),
+        make_fake_bucket_transaction_builder(1)
+            .bucket_id(1)
+            .build()
+            .unwrap(),
+    ];
+    let _ = queries::buckets::insert_buckets(&buckets, connection);
+
+    let num_bucket_transactions_inserted =
+        queries::bucket_transactions::insert_bucket_transactions(&bucket_transactions, connection)
+            .unwrap();
+
+    assert_eq!(num_bucket_transactions_inserted, 2);
+}
+
+#[test]
+fn given_bucket_transactions_when_get_all_bucket_transactions_then_return_bucket_transactions() {
+    let context = TestContext::new();
+    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
+    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
+    let bucket_transactions = [
+        make_fake_bucket_transaction_builder(0)
+            .bucket_id(0)
+            .build()
+            .unwrap(),
+        make_fake_bucket_transaction_builder(1)
+            .bucket_id(1)
+            .build()
+            .unwrap(),
+    ];
+    let _ = queries::buckets::insert_buckets(&buckets, connection);
+    let _ =
+        queries::bucket_transactions::insert_bucket_transactions(&bucket_transactions, connection)
+            .unwrap();
+
+    let bucket_transactions_in_db =
+        queries::bucket_transactions::get_all_bucket_transactions(connection).unwrap();
+
+    assert_eq!(bucket_transactions_in_db.len(), bucket_transactions.len());
+    for bucket_transaction in &bucket_transactions {
+        assert!(bucket_transactions_in_db
+            .iter()
+            .any(|bucket_transaction_in_db| bucket_transaction_in_db.eq(&bucket_transaction)));
+    }
+    for bucket_transaction_in_db in bucket_transactions_in_db {
+        assert!(bucket_transactions
+            .iter()
+            .any(|bucket_transaction| bucket_transaction.eq(&bucket_transaction_in_db)));
+    }
+}
+
+#[test]
+fn given_bucket_transactions_when_delete_all_bucket_transactions_then_return_num_of_bucket_transactions(
+) {
+    let context = TestContext::new();
+    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
+    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
+    let bucket_transactions = [
+        make_fake_bucket_transaction_builder(0)
+            .bucket_id(0)
+            .build()
+            .unwrap(),
+        make_fake_bucket_transaction_builder(1)
+            .bucket_id(1)
+            .build()
+            .unwrap(),
+    ];
+    let _ = queries::buckets::insert_buckets(&buckets, connection);
+    let _ =
+        queries::bucket_transactions::insert_bucket_transactions(&bucket_transactions, connection)
+            .unwrap();
+
+    let num_bucket_transactions_deleted =
+        queries::bucket_transactions::delete_all_bucket_transactions(connection).unwrap();
+
+    assert_eq!(num_bucket_transactions_deleted, bucket_transactions.len());
+}
+
+#[test]
+fn given_deleted_bucket_transactions_when_get_all_bucket_transactions_then_return_empty() {
+    let context = TestContext::new();
+    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
+    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
+    let bucket_transactions = [
+        make_fake_bucket_transaction_builder(0)
+            .bucket_id(0)
+            .build()
+            .unwrap(),
+        make_fake_bucket_transaction_builder(1)
+            .bucket_id(1)
+            .build()
+            .unwrap(),
+    ];
+    let _ = queries::buckets::insert_buckets(&buckets, connection);
+    let _ =
+        queries::bucket_transactions::insert_bucket_transactions(&bucket_transactions, connection)
+            .unwrap();
+    let _ = queries::bucket_transactions::delete_all_bucket_transactions(connection).unwrap();
+
+    let bucket_transactions_returned =
+        queries::bucket_transactions::get_all_bucket_transactions(connection).unwrap();
+
+    assert_eq!(bucket_transactions_returned.len(), 0);
+}
+
+#[test]
+fn given_bucket_transactions_when_sum_amount_per_bucket_id_then_returns_sum_per_bucket_id() {
+    let context = TestContext::new();
+    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
+    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
+    let bucket_transactions = [
+        make_fake_bucket_transaction_builder(0)
+            .bucket_id(0)
+            .amount(1)
+            .build()
+            .unwrap(),
+        make_fake_bucket_transaction_builder(1)
+            .bucket_id(0)
+            .amount(2)
+            .build()
+            .unwrap(),
+        make_fake_bucket_transaction_builder(2)
+            .bucket_id(1)
+            .amount(4)
+            .build()
+            .unwrap(),
+    ];
+    let _ = queries::buckets::insert_buckets(&buckets, connection);
+    let _ =
+        queries::bucket_transactions::insert_bucket_transactions(&bucket_transactions, connection)
+            .unwrap();
+
+    let sums =
+        queries::bucket_transactions::sum_bucket_transaction_amount_per_bucket_id(connection);
+
+    assert!(sums.is_ok());
+    let mut sums = sums.unwrap();
+    sums.sort_by_key(|sum| sum.0);
+    assert_eq!(buckets.len(), sums.len());
+    assert_eq!(3, sums[0].1);
+    assert_eq!(4, sums[1].1);
+}
diff --git a/schist_core/schist_queries/tests/categories.rs b/schist_core/schist_queries/tests/buckets.rs
index 72dd4c7..72dd4c7 100644
--- a/schist_core/schist_queries/tests/categories.rs
+++ b/schist_core/schist_queries/tests/buckets.rs
diff --git a/schist_core/schist_queries/tests/category_transfers.rs b/schist_core/schist_queries/tests/category_transfers.rs
deleted file mode 100644
index f7c75a7..0000000
--- a/schist_core/schist_queries/tests/category_transfers.rs
+++ /dev/null
@@ -1,201 +0,0 @@
-mod common;
-
-use common::test_context::TestContext;
-use diesel::{Connection, SqliteConnection};
-use schist_fakes::{bucket::make_fake_bucket, bucket_transfer::make_fake_bucket_transfer_builder};
-use schist_queries as queries;
-
-#[test]
-fn when_insert_bucket_transfers_then_returns_num_bucket_transfers() {
-    let context = TestContext::new();
-    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
-    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
-    let bucket_transfers = [
-        make_fake_bucket_transfer_builder(0)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(1)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-    ];
-    let _ = queries::buckets::insert_buckets(&buckets, connection);
-
-    let num_bucket_transfers_inserted =
-        queries::bucket_transfers::insert_bucket_transfers(&bucket_transfers, connection).unwrap();
-
-    assert_eq!(num_bucket_transfers_inserted, 2);
-}
-
-#[test]
-fn given_bucket_transfers_when_get_all_bucket_transfers_then_return_bucket_transfers() {
-    let context = TestContext::new();
-    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
-    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
-    let bucket_transfers = [
-        make_fake_bucket_transfer_builder(0)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(1)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-    ];
-    let _ = queries::buckets::insert_buckets(&buckets, connection);
-    let _ =
-        queries::bucket_transfers::insert_bucket_transfers(&bucket_transfers, connection).unwrap();
-
-    let bucket_transfers_in_db =
-        queries::bucket_transfers::get_all_bucket_transfers(connection).unwrap();
-
-    assert_eq!(bucket_transfers_in_db.len(), bucket_transfers.len());
-    for bucket_transfer in &bucket_transfers {
-        assert!(bucket_transfers_in_db
-            .iter()
-            .any(|bucket_transfer_in_db| bucket_transfer_in_db.eq(&bucket_transfer)));
-    }
-    for bucket_transfer_in_db in bucket_transfers_in_db {
-        assert!(bucket_transfers
-            .iter()
-            .any(|bucket_transfer| bucket_transfer.eq(&bucket_transfer_in_db)));
-    }
-}
-
-#[test]
-fn given_bucket_transfers_when_delete_all_bucket_transfers_then_return_num_of_bucket_transfers() {
-    let context = TestContext::new();
-    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
-    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
-    let bucket_transfers = [
-        make_fake_bucket_transfer_builder(0)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(1)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-    ];
-    let _ = queries::buckets::insert_buckets(&buckets, connection);
-    let _ =
-        queries::bucket_transfers::insert_bucket_transfers(&bucket_transfers, connection).unwrap();
-
-    let num_bucket_transfers_deleted =
-        queries::bucket_transfers::delete_all_bucket_transfers(connection).unwrap();
-
-    assert_eq!(num_bucket_transfers_deleted, bucket_transfers.len());
-}
-
-#[test]
-fn given_deleted_bucket_transfers_when_get_all_bucket_transfers_then_return_empty() {
-    let context = TestContext::new();
-    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
-    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
-    let bucket_transfers = [
-        make_fake_bucket_transfer_builder(0)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(1)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .build()
-            .unwrap(),
-    ];
-    let _ = queries::buckets::insert_buckets(&buckets, connection);
-    let _ =
-        queries::bucket_transfers::insert_bucket_transfers(&bucket_transfers, connection).unwrap();
-    let _ = queries::bucket_transfers::delete_all_bucket_transfers(connection).unwrap();
-
-    let bucket_transfers_returned =
-        queries::bucket_transfers::get_all_bucket_transfers(connection).unwrap();
-
-    assert_eq!(bucket_transfers_returned.len(), 0);
-}
-
-#[test]
-fn given_bucket_transfers_when_sum_quantity_per_from_bucket_id_then_returns_sum_per_from_bucket_id()
-{
-    let context = TestContext::new();
-    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
-    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
-    let bucket_transfers = [
-        make_fake_bucket_transfer_builder(0)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .amount(1)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(1)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .amount(2)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(2)
-            .from_bucket_id(1)
-            .to_bucket_id(0)
-            .amount(4)
-            .build()
-            .unwrap(),
-    ];
-    let _ = queries::buckets::insert_buckets(&buckets, connection);
-    let _ =
-        queries::bucket_transfers::insert_bucket_transfers(&bucket_transfers, connection).unwrap();
-
-    let sums =
-        queries::bucket_transfers::sum_bucket_transfer_quantity_per_from_bucket_id(connection);
-
-    assert!(sums.is_ok());
-    let mut sums = sums.unwrap();
-    sums.sort_by_key(|sum| sum.0);
-    assert_eq!(buckets.len(), sums.len());
-    assert_eq!(3, sums[0].1);
-    assert_eq!(4, sums[1].1);
-}
-
-#[test]
-fn given_bucket_transfers_when_sum_quantity_per_to_bucket_id_then_returns_sum_per_to_bucket_id() {
-    let context = TestContext::new();
-    let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
-    let buckets = [make_fake_bucket(0), make_fake_bucket(1)];
-    let bucket_transfers = [
-        make_fake_bucket_transfer_builder(0)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .amount(1)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(1)
-            .from_bucket_id(0)
-            .to_bucket_id(1)
-            .amount(2)
-            .build()
-            .unwrap(),
-        make_fake_bucket_transfer_builder(2)
-            .from_bucket_id(1)
-            .to_bucket_id(0)
-            .amount(4)
-            .build()
-            .unwrap(),
-    ];
-    let _ = queries::buckets::insert_buckets(&buckets, connection);
-    let _ =
-        queries::bucket_transfers::insert_bucket_transfers(&bucket_transfers, connection).unwrap();
-
-    let sums = queries::bucket_transfers::sum_bucket_transfer_quantity_per_to_bucket_id(connection);
-
-    assert!(sums.is_ok());
-    let mut sums = sums.unwrap();
-    sums.sort_by_key(|sum| sum.0);
-    assert_eq!([(0, 4), (1, 3)], sums.as_slice());
-}
diff --git a/schist_core/schist_queries/tests/pipes.rs b/schist_core/schist_queries/tests/pipes.rs
index 9203aa3..f883fe6 100644
--- a/schist_core/schist_queries/tests/pipes.rs
+++ b/schist_core/schist_queries/tests/pipes.rs
@@ -115,7 +115,7 @@ fn given_deleted_pipes_when_get_all_pipes_then_return_empty() {
 }
 
 #[test]
-fn given_pipes_when_sum_quantity_per_bucket_id_then_returns_sum_quantity_per_bucket_id() {
+fn given_pipes_when_sum_amount_per_bucket_id_then_returns_sum_amount_per_bucket_id() {
     let context = TestContext::new();
     let connection = &mut SqliteConnection::establish(&context.db_url).unwrap();
     given_accounts(connection);