Update app.py

app.py

@@ -436,7 +436,7 @@ HTML_PAGE = f"""
         const askSeries = denChart.addAreaSeries({{ lineColor: '#ff3b3b', topColor: 'rgba(255, 59, 59, 0.15)', bottomColor: 'rgba(0,0,0,0)', lineWidth: 1 }});
 
         let activeLines = [];
-        let activeCandleLines = []; // New array to track lines on the candle chart
+        let activeCandleLines = [];
 
         new ResizeObserver(entries => {{
             for(let entry of entries) {{
@@ -505,31 +505,27 @@ HTML_PAGE = f"""
                         low: c.low,
                         close: c.close
                     }}));
+                    // Deduplicate candles
                     const uniqueCandles = [...new Map(candles.map(i => [i.time, i])).values()];
                     candleSeries.setData(uniqueCandles);
                 }}
 
                 if (data.walls) {{
-                    // Remove old lines from both charts
                     activeLines.forEach(l => priceSeries.removePriceLine(l));
                     activeLines = [];
                     activeCandleLines.forEach(l => candleSeries.removePriceLine(l));
                     activeCandleLines = [];
-
+                    
                     let html = "";
                     const addWall = (w, type) => {{
                         const color = type === 'BID' ? '#00ff9d' : '#ff3b3b';
                         const lineOpts = {{ price: w.price, color: color, lineWidth: 1, lineStyle: 2, axisLabelVisible: false }};
                         
-                        // Add to Price Chart
                         activeLines.push(priceSeries.createPriceLine(lineOpts));
-                        
-                        // Add to Candle Chart
                         activeCandleLines.push(candleSeries.createPriceLine(lineOpts));
-
+                        
                         html += `<div class="list-item"><span style="color:${{color}}">${{type}} ${{w.price}}</span><span class="c-dim">Z:${{w.z_score.toFixed(1)}}</span></div>`;
                     }};
-                    
                     data.walls.asks.forEach(w => addWall(w, 'ASK'));
                     data.walls.bids.forEach(w => addWall(w, 'BID'));
                     dom.wallList.innerHTML = html || '<span class="c-dim" style="font-size:11px">Scanning...</span>';
@@ -571,6 +567,7 @@ HTML_PAGE = f"""
 async def kraken_worker():
     global market_state
     try:
+        # Fetch initial history (Kraken REST API uses start time for candles)
         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:
@@ -646,27 +643,61 @@ async def kraken_worker():
                         for trade in data:
                             try:
                                 qty = float(trade['qty'])
+                                price = float(trade['price'])
                                 side = trade['side']
+                                
+                                # Update Vol stats
                                 if side == 'buy': market_state['current_vol_window']['buy'] += qty
                                 else: market_state['current_vol_window']['sell'] += qty
+
+                                # LIVE CANDLE UPDATE (Crucial for "actual price")
+                                current_minute_start = int(time.time()) // 60 * 60
+                                
+                                if market_state['ohlc_history']:
+                                    last_candle = market_state['ohlc_history'][-1]
+                                    
+                                    # If still in the same minute, update the current candle
+                                    if last_candle['time'] == current_minute_start:
+                                        last_candle['close'] = price
+                                        if price > last_candle['high']: last_candle['high'] = price
+                                        if price < last_candle['low']: last_candle['low'] = price
+                                    
+                                    # If new minute started, create new candle
+                                    elif current_minute_start > last_candle['time']:
+                                        new_candle = {
+                                            'time': current_minute_start,
+                                            'open': price,
+                                            'high': price,
+                                            'low': price,
+                                            'close': price
+                                        }
+                                        market_state['ohlc_history'].append(new_candle)
+                                        if len(market_state['ohlc_history']) > 200:
+                                            market_state['ohlc_history'].pop(0)
+
                             except: pass
 
                     elif channel == "ohlc":
                         for candle in data:
                             try:
+                                # Kraken WS sends 'endtime'. We convert to 'starttime' to match REST data and charting lib.
+                                start_time = int(float(candle['endtime'])) - 60
                                 c_data = {
-                                    'time': int(float(candle['endtime'])), 
+                                    'time': start_time, 
                                     'open': float(candle['open']),
                                     'high': float(candle['high']),
                                     'low': float(candle['low']),
                                     'close': float(candle['close'])
                                 }
-                                if market_state['ohlc_history'] and market_state['ohlc_history'][-1]['time'] == c_data['time']:
-                                    market_state['ohlc_history'][-1] = c_data
-                                else:
-                                    market_state['ohlc_history'].append(c_data)
-                                    if len(market_state['ohlc_history']) > 100:
-                                        market_state['ohlc_history'].pop(0)
+                                
+                                # Sync with existing history if found
+                                if market_state['ohlc_history']:
+                                    if market_state['ohlc_history'][-1]['time'] == start_time:
+                                        market_state['ohlc_history'][-1] = c_data
+                                    elif market_state['ohlc_history'][-1]['time'] < start_time:
+                                        market_state['ohlc_history'].append(c_data)
+                                        if len(market_state['ohlc_history']) > 200:
+                                            market_state['ohlc_history'].pop(0)
                             except Exception as e:
                                 pass