ADD support for new Kraken CSV format

provinzio · Jan 2, 2025 · 6b6c5b4 · 6b6c5b4
1 parent f0345c2
commit 6b6c5b4
Showing 1 changed file with 35 additions and 2 deletions.
diff --git a/src/book.py b/src/book.py
@@ -623,8 +623,24 @@ def _read_kraken_ledgers(self, file_path: Path) -> None:
             for columns in reader:
 
                 num_columns = len(columns)
-                # Kraken ledgers export format from October 2020 and ongoing
-                if num_columns == 10:
+                # Kraken ledgers export format from 2025 and ongoing
+                if num_columns == 11:
+                    (
+                        txid,
+                        refid,
+                        _utc_time,
+                        _type,
+                        subtype,
+                        aclass,
+                        _asset,
+                        _wallet,
+                        _amount,
+                        _fee,
+                        balance,
+                    ) = columns
+
+                # Kraken ledgers export format from October 2020 until 2025
+                elif num_columns == 10:
                     (
                         txid,
                         refid,
@@ -891,6 +907,9 @@ def _read_kraken_ledgers(self, file_path: Path) -> None:
     def _read_kraken_ledgers_old(self, file_path: Path) -> None:
         self._read_kraken_ledgers(file_path)
 
+    def _read_kraken_ledgers_v2(self, file_path: Path) -> None:
+        self._read_kraken_ledgers(file_path)
+
     def _read_bitpanda_pro_trades(self, file_path: Path) -> None:
         """Reads a trade statement from Bitpanda Pro.
 
@@ -1339,6 +1358,7 @@ def detect_exchange(self, file_path: Path) -> Optional[str]:
                 "coinbase_pro": 1,
                 "kraken_ledgers_old": 1,
                 "kraken_ledgers": 1,
+                "kraken_ledgers_v2": 1,
                 "kraken_trades": 1,
                 "bitpanda_pro_trades": 4,
                 "bitpanda": 7,
@@ -1420,6 +1440,19 @@ def detect_exchange(self, file_path: Path) -> Optional[str]:
                     "fee",
                     "balance",
                 ],
+                "kraken_ledgers_v2": [
+                    "txid",
+                    "refid",
+                    "time",
+                    "type",
+                    "subtype",
+                    "aclass",
+                    "asset",
+                    "wallet",
+                    "amount",
+                    "fee",
+                    "balance",
+                ],
                 "kraken_trades": [
                     "txid",
                     "ordertxid",