Line numbers for errors in trades csv-file

report.py

@@ -1,6 +1,7 @@
 import argparse
 import datetime
 import os
+import sys
 from enum import Enum
 
 from taxdata import PersonalDetails, Fees, Trades, TaxEvent
@@ -43,6 +44,9 @@ def __str__(self):
                              exclude_groups=opts.exclude_groups if opts.exclude_groups else [],
                              coin_report_filename=os.path.join(opts.out, "coin_report.csv") if opts.coin_report else None
                              )
+if not tax_events:
+    print(f"Aborting tax computation.")
+    sys.exit(1)
 
 if opts.simplified_k4:
     tax_events = tax.aggregate_per_coin(tax_events)

tax.py

@@ -57,38 +57,44 @@ def get_sell_coin(trade:Trade):
         elif trade.group in exclude_groups:
             continue
 
-        if trade.type == 'Trade':
-            buy_coin = get_buy_coin(trade)
-            sell_coin = get_sell_coin(trade)
+        try:
 
-            if trade.sell_coin == native_currency:
-                value_sek = trade.sell_value
-            else:
-                value_sek = trade.buy_value
-
-            if buy_coin:
-                buy_coin.buy(trade.buy_amount, value_sek)
-            if sell_coin:
-                tax_event = sell_coin.sell(trade.sell_amount, value_sek)
-                if trade.date >= from_date:
-                    tax_events.append(tax_event)
-
-        elif trade.type == 'Mining':
-            buy_coin = get_buy_coin(trade)
-            if buy_coin:
-                buy_coin.buy(trade.buy_amount, trade.buy_value)
-
-        elif trade.type == 'Gift/Tip':
-            buy_coin = get_buy_coin(trade)
-            if buy_coin:
-                buy_coin.buy(trade.buy_amount, 0.0)
-
-        elif trade.type == 'Spend':
-            sell_coin = get_sell_coin(trade)
-            if sell_coin:
-                tax_event = sell_coin.sell(trade.sell_amount, trade.sell_value)
-                if trade.date >= from_date:
-                    tax_events.append(tax_event)
+            if trade.type == 'Trade':
+                buy_coin = get_buy_coin(trade)
+                sell_coin = get_sell_coin(trade)
+
+                if trade.sell_coin == native_currency:
+                    value_sek = trade.sell_value
+                else:
+                    value_sek = trade.buy_value
+
+                if buy_coin:
+                    buy_coin.buy(trade.buy_amount, value_sek)
+                if sell_coin:
+                    tax_event = sell_coin.sell(trade.sell_amount, value_sek)
+                    if trade.date >= from_date:
+                        tax_events.append(tax_event)
+
+            elif trade.type == 'Mining':
+                buy_coin = get_buy_coin(trade)
+                if buy_coin:
+                    buy_coin.buy(trade.buy_amount, trade.buy_value)
+
+            elif trade.type == 'Gift/Tip':
+                buy_coin = get_buy_coin(trade)
+                if buy_coin:
+                    buy_coin.buy(trade.buy_amount, 0.0)
+
+            elif trade.type == 'Spend':
+                sell_coin = get_sell_coin(trade)
+                if sell_coin:
+                    tax_event = sell_coin.sell(trade.sell_amount, trade.sell_value)
+                    if trade.date >= from_date:
+                        tax_events.append(tax_event)
+
+        except Exception as e:
+            print(f"Exception encountered at line {trade.lineno} in trades csv-file: {e}")
+            return None
 
     if coin_report_filename:
         with open(coin_report_filename, "w") as f:

taxdata.py

@@ -30,9 +30,10 @@ def read_from(filename):
 
 
 class Trade:
-    def __init__(self, date:datetime, type, group,
+    def __init__(self, lineno, date:datetime, type, group,
                  buy_coin, buy_amount, buy_value,
                  sell_coin, sell_amount, sell_value):
+        self.lineno = lineno
         self.date = date
         self.type = type
         self.group = group
@@ -100,8 +101,10 @@ def indices(col_name):
         sell_value_index = indices(price_field_name)[1]
 
         trades = []
+        lineno = 2
         for line in lines[1:]:
             trade = Trade(
+                lineno,
                 datetime.strptime(line[date_index], "%d.%m.%Y %H:%M"),
                 line[type_index],
                 None if line[group_index] == '-' else line[group_index],
@@ -119,6 +122,7 @@ def indices(col_name):
                 if trade.sell_value:
                     trade.sell_value *= usdsek_rate
             trades.append(trade)
+            lineno += 1
 
         trades.sort(key=lambda x: x.date)