From 5fd5a6799596fb9a37a06238ce9e9c21fcf02a9e Mon Sep 17 00:00:00 2001
From: Lukas Pierchalla <git@l.pierchalla.de>
Date: Sun, 20 Sep 2026 12:46:14 +0200
Subject: [PATCH] update scalable_sync.py to enhance transaction mapping logic
 and improve handling of cash transactions

---
 scalable_sync.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/scalable_sync.py b/scalable_sync.py
index bb57dd0..7fb3f45 100644
--- a/scalable_sync.py
+++ b/scalable_sync.py
@@ -222,6 +222,8 @@ def map_to_wealthfolio(tx: dict) -> list[WealthfolioActivity]:
             "FEE": "FEE",
             "TAX": "TAX",
             "TAX_RETURN": "CREDIT",
+            "CASH_TRANSFER_IN": "DEPOSIT",  # neu
+            "CASH_TRANSFER_OUT": "WITHDRAWAL",  # neu
         }.get(cash_type)
 
         if not wf_type:
@@ -373,6 +375,7 @@ def sync_once(dry_run=False):
                     f"{a.activity_type} {a.symbol} qty={a.quantity} amt={a.amount}" for a in activities
                 ])
                 audit("dry_run", {"tx_id": tx_id, "activities": [asdict(a) for a in activities]})
+                stats["new"] += len(activities)  # ← diese Zeile fehlt noch
             else:
                 try:
                     result = mcp.record_activities(activities)