summaryrefslogtreecommitdiff
path: root/bla.py
diff options
context:
space:
mode:
Diffstat (limited to 'bla.py')
-rw-r--r--bla.py13
1 files changed, 7 insertions, 6 deletions
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: