diff options
| author | uvok | 2025-04-17 18:48:35 +0200 |
|---|---|---|
| committer | uvok | 2025-04-17 18:48:35 +0200 |
| commit | a25069002d9933aa40a3172673d01c3ce9d3e8d3 (patch) | |
| tree | 2d952c2d4470f665ecf8c6c8f2914ad9548f7423 /bla.py | |
| parent | 3fd5c7ce8ec71dd74fc3f4c72ab99463c6f911a7 (diff) | |
Add trade directly
Diffstat (limited to 'bla.py')
| -rw-r--r-- | bla.py | 13 |
1 files changed, 7 insertions, 6 deletions
@@ -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: |