Update app/price_fetcher.py

app/price_fetcher.py

@@ -2,6 +2,7 @@
 A professional-grade, multi-asset, multi-oracle price engine.
 This engine dynamically fetches prices for a configured list of assets
 from decentralized oracles to detect market dislocations.
+v11.1: Corrected Pyth Network API endpoint.
 """
 import asyncio
 import logging
@@ -10,11 +11,7 @@ import httpx
 
 logger = logging.getLogger(__name__)
 
-# ====================================================================
-#              THE "MONEY-SPINNING" UPGRADE IS HERE
-# ====================================================================
-# This is our master watchlist. The engine will hunt for opportunities
-# across all 10 of these high-volume assets simultaneously.
+# --- CONFIGURATION ---
 ASSET_CONFIG = {
     "BTC": {
         "pyth_id": "e62df6c8b4a85fe1a67db44dc12de5db330f7ac66b72dc658afedf0f4a415B43",
@@ -57,10 +54,15 @@ ASSET_CONFIG = {
         "coingecko_id": "matic-network",
     },
 }
-# ====================================================================
 
 class PriceFetcher:
-    PYTH_URL = "https://hermes.pyth.network/v2/updates/price/latest"
+    # ====================================================================
+    #                       THE CRITICAL FIX IS HERE
+    # ====================================================================
+    # Using the new, correct endpoint for Pyth Network price feeds.
+    PYTH_URL = "https://hermes.pyth.network/v2/price_feeds"
+    # ====================================================================
+    
     AGGREGATOR_URL = "https://api.coingecko.com/api/v3/simple/price"
 
     def __init__(self, client: httpx.AsyncClient):
@@ -70,16 +72,19 @@ class PriceFetcher:
 
     async def _fetch_pyth_prices(self) -> Dict[str, float]:
         pyth_ids = [v['pyth_id'] for v in ASSET_CONFIG.values()]
-        params = [("ids[]", pid) for pid in pyth_ids]
+        # The new endpoint requires the '0x' prefix for IDs
+        params = [("ids[]", f"0x{pid}") for pid in pyth_ids]
         try:
             resp = await self.client.get(self.PYTH_URL, params=params, timeout=10)
             resp.raise_for_status()
-            parsed_data = resp.json().get('parsed', [])
+            # The new endpoint returns a list directly
+            price_data_list = resp.json()
             
-            id_to_symbol = {v['pyth_id']: k for k, v in ASSET_CONFIG.items()}
+            # Map the returned prices back to our asset symbols
+            id_to_symbol = {f"0x{v['pyth_id']}": k for k, v in ASSET_CONFIG.items()}
             return {
                 id_to_symbol[item['id']]: int(item['price']['price']) / (10 ** abs(int(item['price']['expo'])))
-                for item in parsed_data if item['id'] in id_to_symbol
+                for item in price_data_list if item['id'] in id_to_symbol
             }
         except Exception as e:
             logger.error(f"❌ Oracle Error (Pyth): {e}")
@@ -92,7 +97,6 @@ class PriceFetcher:
             resp = await self.client.get(self.AGGREGATOR_URL, params=params, timeout=10)
             resp.raise_for_status()
             data = resp.json()
-
             id_to_symbol = {v['coingecko_id']: k for k, v in ASSET_CONFIG.items()}
             return {id_to_symbol[cg_id]: prices['usd'] for cg_id, prices in data.items()}
         except Exception as e: