Moves rust workspace to root

6 files changed, 93 insertions, 0 deletions

diff --git a/actualbudget_queries/src/actualbudget_accounts.rs b/actualbudget_queries/src/actualbudget_accounts.rs
new file mode 100644
index 0000000..d499208
--- /dev/null
+++ b/actualbudget_queries/src/actualbudget_accounts.rs
@@ -0,0 +1,25 @@
+use actualbudget_models::ActualbudgetAccount;
+use actualbudget_schema::actualbudget_schema::accounts::{
+    self as accounts_schema,
+    dsl::accounts as accounts_table,
+};
+use anyhow::{Context, Result};
+use diesel::{ExpressionMethods, OptionalExtension, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
+
+pub fn get_all_actualbudget_accounts(connection: &mut SqliteConnection) -> Result<Vec<ActualbudgetAccount>> {
+    let actualbudget_accounts = accounts_table
+        .select(ActualbudgetAccount::as_select())
+        .load(connection)
+        .with_context(|| "failed to get all Actualbudget accounts")?;
+    Ok(actualbudget_accounts)
+}
+
+pub fn get_category_transfers_account(connection: &mut SqliteConnection) -> Result<Option<ActualbudgetAccount>> {
+    let category_transfers_account = accounts_table
+        .filter(accounts_schema::name.eq("Category transfers"))
+        .select(ActualbudgetAccount::as_select())
+        .first(connection)
+        .optional()
+        .with_context(|| "failed to get Category Transfers account")?;
+    Ok(category_transfers_account)
+}
diff --git a/actualbudget_queries/src/actualbudget_categories.rs b/actualbudget_queries/src/actualbudget_categories.rs
new file mode 100644
index 0000000..846faf5
--- /dev/null
+++ b/actualbudget_queries/src/actualbudget_categories.rs
@@ -0,0 +1,7 @@
+use actualbudget_models::ActualbudgetCategory;
+use actualbudget_schema::actualbudget_schema::categories::dsl::categories;
+use diesel::{result::Error, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
+
+pub fn get_all_actualbudget_categories(connection: &mut SqliteConnection) -> Result<Vec<ActualbudgetCategory>, Error> {
+    categories.select(ActualbudgetCategory::as_select()).load(connection)
+}
diff --git a/actualbudget_queries/src/actualbudget_payees.rs b/actualbudget_queries/src/actualbudget_payees.rs
new file mode 100644
index 0000000..d5b0c5f
--- /dev/null
+++ b/actualbudget_queries/src/actualbudget_payees.rs
@@ -0,0 +1,13 @@
+use actualbudget_models::ActualbudgetPayee;
+use actualbudget_schema::actualbudget_schema::payees::dsl::payees;
+use anyhow::{Result, Context};
+use diesel::{QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
+
+pub fn get_all_actualbudget_payees(
+    connection: &mut SqliteConnection,
+) -> Result<Vec<ActualbudgetPayee>> {
+    payees
+        .select(ActualbudgetPayee::as_select())
+        .load(connection)
+        .with_context(|| "failed to get actualbudget payees")
+}
diff --git a/actualbudget_queries/src/actualbudget_transactions.rs b/actualbudget_queries/src/actualbudget_transactions.rs
new file mode 100644
index 0000000..4dc38e8
--- /dev/null
+++ b/actualbudget_queries/src/actualbudget_transactions.rs
@@ -0,0 +1,23 @@
+use actualbudget_models::{ActualbudgetDate, ActualbudgetTransaction};
+use actualbudget_schema::actualbudget_schema::v_transactions::{
+    self as transactions_schema,
+    dsl::v_transactions as transactions_table,
+};
+use anyhow::{Context, Result};
+use diesel::{dsl::min, result::Error, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
+
+pub fn get_all_actualbudget_transactions(connection: &mut SqliteConnection) -> Result<Vec<ActualbudgetTransaction>> {
+    let actualbudget_transactions = transactions_table
+        .select(ActualbudgetTransaction::as_select())
+        .load(connection)
+        .with_context(|| "failed to get all Actualbudget transactions")?;
+    Ok(actualbudget_transactions)
+}
+
+pub fn get_first_actualbudget_transaction_date(connection: &mut SqliteConnection) -> Result<ActualbudgetDate> {
+    let date_as_int = transactions_table
+        .select(min(transactions_schema::date))
+        .first::<Option<i32>>(connection)
+        .map_or_else(|e| Err(e), |o| o.map_or_else(|| Err(Error::NotFound), |i| Ok(i)))?;
+    Ok(ActualbudgetDate::from_i32(date_as_int))
+}
diff --git a/actualbudget_queries/src/actualbudget_zero_budgets.rs b/actualbudget_queries/src/actualbudget_zero_budgets.rs
new file mode 100644
index 0000000..5ae4055
--- /dev/null
+++ b/actualbudget_queries/src/actualbudget_zero_budgets.rs
@@ -0,0 +1,20 @@
+use anyhow::{Context, Result};
+use actualbudget_models::{actualbudget_schema::zero_budgets as zero_budgets_schema, ActualbudgetDate, ActualbudgetZeroBudget};
+use actualbudget_schema::actualbudget_schema::zero_budgets::dsl::zero_budgets as zero_budgets_table;
+use diesel::{dsl::min, result::Error, QueryDsl, RunQueryDsl, SelectableHelper, SqliteConnection};
+
+pub fn get_all_actualbudget_zero_budgets(connection: &mut SqliteConnection) -> Result<Vec<ActualbudgetZeroBudget>> {
+    let zero_budgets = zero_budgets_table
+        .select(ActualbudgetZeroBudget::as_select())
+        .load(connection)
+        .with_context(|| "failed to get all Actualbudget zero budgets")?;
+    Ok(zero_budgets)
+}
+
+pub fn get_first_zero_budget_date(connection: &mut SqliteConnection) -> Result<ActualbudgetDate> {
+    let date_as_int = zero_budgets_table
+        .select(min(zero_budgets_schema::month))
+        .first::<Option<i32>>(connection)
+        .map_or_else(|e| Err(e), |o| o.map_or_else(|| Err(Error::NotFound), |i| Ok(i)))?;
+    Ok(ActualbudgetDate::from_i32(date_as_int))
+}
diff --git a/actualbudget_queries/src/lib.rs b/actualbudget_queries/src/lib.rs
new file mode 100644
index 0000000..ca3f6ea
--- /dev/null
+++ b/actualbudget_queries/src/lib.rs
@@ -0,0 +1,5 @@
+pub mod actualbudget_accounts;
+pub mod actualbudget_categories;
+pub mod actualbudget_payees;
+pub mod actualbudget_transactions;
+pub mod actualbudget_zero_budgets;