Use denormalized exchange names for all cache directory paths

- HLCVManager, OHLCVManager, fetch_markets_ccxt, and coin_to_symbol
  now use denormalized names (e.g., "binance" not "binanceusdm")
- Ensures only caches/binance/ is created instead of both
  caches/binance/ and caches/binanceusdm/

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: enarjord

src/downloader.py

@@ -520,10 +520,12 @@ def __init__(
         self.start_ts = date_to_ts(self.start_date)
         self.end_ts = date_to_ts(self.end_date)
         self.cc = cc
+        # Use denormalized exchange name for cache paths (e.g., "binance" not "binanceusdm")
+        cache_exchange = denormalize_exchange_name(self.exchange)
         self.cache_filepaths = {
-            "markets": os.path.join("caches", self.exchange, "markets.json"),
-            "ohlcvs": os.path.join("historical_data", f"ohlcvs_{self.exchange}"),
-            "first_timestamps": os.path.join("caches", self.exchange, "first_timestamps.json"),
+            "markets": os.path.join("caches", cache_exchange, "markets.json"),
+            "ohlcvs": os.path.join("historical_data", f"ohlcvs_{cache_exchange}"),
+            "first_timestamps": os.path.join("caches", cache_exchange, "first_timestamps.json"),
         }
         self.markets = None
         self.verbose = verbose

src/hlcv_preparation.py

@@ -107,9 +107,11 @@ def __init__(
         self.start_ts = int(date_to_ts(self.start_date))
         self.end_ts = int(date_to_ts(self.end_date))
         self.cc = cc
+        # Use denormalized exchange name for cache paths (e.g., "binance" not "binanceusdm")
+        cache_exchange = denormalize_exchange_name(self.exchange)
         self.cache_filepaths = {
-            "markets": os.path.join("caches", self.exchange, "markets.json"),
-            "first_timestamps": os.path.join("caches", self.exchange, "first_timestamps.json"),
+            "markets": os.path.join("caches", cache_exchange, "markets.json"),
+            "first_timestamps": os.path.join("caches", cache_exchange, "first_timestamps.json"),
         }
         self.markets = None
         self.verbose = bool(verbose)

src/utils.py

@@ -492,7 +492,8 @@ async def load_markets(
     consistency with other cache paths (pnls, ohlcv, fill_events).
     """
     # Prefer cc.id when a ccxt instance is supplied, otherwise use the provided exchange string.
-    ex = (getattr(cc, "id", None) or exchange or "").lower()
+    # Denormalize to use canonical form for cache paths (e.g., "binance" not "binanceusdm")
+    ex = denormalize_exchange_name(getattr(cc, "id", None) or exchange or "")
     markets_path = os.path.join("caches", ex, "markets.json")
 
     # Try cache first
@@ -914,7 +915,8 @@ def coin_to_symbol(coin, exchange, quote=None):
     # caches coin_to_symbol_map in memory and reloads if file changes
     if coin == "":
         return ""
-    ex = (exchange or "").lower()
+    # Denormalize to use canonical form for cache paths (e.g., "binance" not "binanceusdm")
+    ex = denormalize_exchange_name(exchange or "")
     quote = get_quote(ex, quote)
     coin_sanitized = symbol_to_coin(coin)
     fallback = f"{coin_sanitized}/{quote}:{quote}"