Only transforms non-zero budget drips

1 files changed, 10 insertions, 1 deletions

diff --git a/rust/actualbudget_to_schist_transformer/src/transform_state/transform_budget_drips.rs b/rust/actualbudget_to_schist_transformer/src/transform_state/transform_budget_drips.rs
index 7ec41af..1163e56 100644
--- a/rust/actualbudget_to_schist_transformer/src/transform_state/transform_budget_drips.rs
+++ b/rust/actualbudget_to_schist_transformer/src/transform_state/transform_budget_drips.rs
@@ -9,8 +9,15 @@ use schist_traits::dateable::Dateable;
 use super::{transform_date::transform_date, transform_id::transform_id};
 
 pub fn transform_budget_drips(actualbudget_zero_budgets: &[ActualbudgetZeroBudget]) -> Result<Vec<BudgetDrip>> {
-    let budget_drips = group_actualbudget_zero_budgets_by_category_id(actualbudget_zero_budgets)
+    let non_zero_actualbudget_zero_budgets: Vec<ActualbudgetZeroBudget> = actualbudget_zero_budgets
         .iter()
+        .filter(|zb| zb.amount != 0)
+        .cloned()
+        .collect();
+
+    let budget_drips = group_actualbudget_zero_budgets_by_category_id(
+            &non_zero_actualbudget_zero_budgets,
+        ).iter()
         .map(sort_actualbudget_zero_budgets_by_month)
         .flat_map(|sorted_actualbudget_zero_budgets| sorted_actualbudget_zero_budgets
             .iter()
@@ -18,7 +25,9 @@ pub fn transform_budget_drips(actualbudget_zero_budgets: &[ActualbudgetZeroBudge
             .collect::<Result<Vec<Vec<BudgetDrip>>>>()
         ).flatten()
         .flatten()
+        .filter(|bd| bd.quantity != 0)
         .collect();
+
     Ok(budget_drips)
 }