Update app.py

app.py

@@ -5,6 +5,7 @@ import time
 import bisect
 import math
 import statistics
+import aiohttp
 from datetime import datetime
 from aiohttp import web
 import websockets
@@ -559,6 +560,31 @@ HTML_PAGE = f"""
 
 async def kraken_worker():
     global market_state
+    
+    try:
+        async with aiohttp.ClientSession() as session:
+            url = "https://api.kraken.com/0/public/OHLC?pair=XBTUSD&interval=1"
+            async with session.get(url) as response:
+                if response.status == 200:
+                    data = await response.json()
+                    if 'result' in data:
+                        for key in data['result']:
+                            if key != 'last':
+                                raw_candles = data['result'][key]
+                                market_state['ohlc_history'] = [
+                                    {
+                                        'time': int(c[0]),
+                                        'open': float(c[1]),
+                                        'high': float(c[2]),
+                                        'low': float(c[3]),
+                                        'close': float(c[4])
+                                    }
+                                    for c in raw_candles[-120:]
+                                ]
+                                break
+    except Exception as e:
+        logging.error(f"History fetch failed: {e}")
+
     while True:
         try:
             async with websockets.connect("wss://ws.kraken.com/v2") as ws: