From a25069002d9933aa40a3172673d01c3ce9d3e8d3 Mon Sep 17 00:00:00 2001
From: uvok
Date: Thu, 17 Apr 2025 18:48:35 +0200
Subject: Add trade directly

---
 bla.py | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

(limited to 'bla.py')

diff --git a/bla.py b/bla.py
index a915102..309a0b0 100644
--- a/bla.py
+++ b/bla.py
@@ -76,13 +76,14 @@ def process_trade(refid: str, trades: List[LedgerAction]):
             if eur_amount < 0:  # Purchase of cryptocurrency
                 stake_amount = -eur_amount - eur_fee  # Account for EUR fees
                 crypto_amount -= crypto_fee  # Adjust for crypto fees
-                fifo_queues[crypto_asset].add(crypto_amount, stake_amount, date_sold)
+                fifo_queues[crypto_asset].add_trade(Trade(crypto_amount, stake_amount, date_sold, refid=refid))
             elif eur_amount > 0:  # Sale of cryptocurrency
-                proceeds = eur_amount - eur_fee  # Account for EUR fees
-                sale_entries = fifo_queues[crypto_asset].remove_coins(-crypto_amount)
-                report.extend(
-                    generate_report(sale_entries, proceeds, crypto_asset, date_sold)
-                )
+                proceeds = eur_amount - eur_fee
+                fifo_queues[crypto_asset].add_trade(Trade(crypto_amount, -proceeds, date_sold, refid=refid))
+                # sale_entries = fifo_queues[crypto_asset].remove_coins(-crypto_amount)
+                # report.extend(
+                #     generate_report(sale_entries, proceeds, crypto_asset, date_sold)
+                # )
         else:
             raise ValueError(f"Unexpected trade grouping for refid {refid}")
     else:
-- 
cgit v1.2.3