Complete Futures luxury dashboard data integration

hermes_overlay/tools/futures_dashboard_api.py

@@ -41,6 +41,7 @@ from trading.futures_execution import get_futures_positions as _get_futures_posi
 from trading.futures_execution import get_futures_account as _get_futures_account
 from trading.futures_execution import get_trading_mode as _get_trading_mode
 from trading.trade_cycle import run_futures_cycle as _run_futures_cycle
+from trading.dual_datasource_client import get_market_context as _get_market_context
 from trading.symbols import normalize_symbol
 
 router = APIRouter()
@@ -52,7 +53,6 @@ _SYMBOL_CACHE_PATH = Path(os.environ.get("HERMES_SYMBOL_CACHE_PATH", "/opt/data/
 _TEMPLATE_PATH = Path(__file__).with_name("templates") / "hermes_futures_desk_luxury.html"
 # UI discovery only. These are deliberately unverified; they never authorize execution.
 _EMERGENCY_BASES = tuple("""BTC ETH USDT BNB SOL XRP USDC ADA AVAX DOGE DOT TRX LINK MATIC LTC BCH UNI ATOM ETC XLM NEAR FIL APT ARB OP ICP SUI INJ MKR AAVE ALGO VET QNT EGLD FTM THETA XTZ EOS FLOW GRT SAND MANA AXS CHZ SNX CRV LDO RUNE KAS PEPE WIF BONK FLOKI SHIB HBAR IMX SEI TIA JUP JTO PYTH WLD FET RNDR TAO KAVA COMP DAI GALA ENJ BAT ZEC DASH XMR NEO IOTA KSM WAVES ZIL ONE CELO ROSE MINA LUNC LUNA GMT GST APE YGG ILV MAGIC DYDX GMX PERP ENS BLUR LPT ARKM STRK DYM MANTA ALT ZK JASMY SFP CAKE BSV BS BCH SV CFX AGIX OCEAN OGN IOST IOTX ICX QTUM ONT ZRX KNC OMG SKL ANKR STORJ SC HNT AUDIO API3 BAND UMA NMR REQ RLC CTSI CELR COTI DENT HOT WIN JST SUN TWT BNT KDA XVS ALPHA BAKE BEL BETA C98 DAR DODO LINA LIT MASK MDT MLN NKN NULS OXT PHA QI QKC RAD RARE RAY REEF REN RIF RPL RVN SFP SPELL STG SUSHI TLM TOMO TRB TROY UFT UNFI VTHO WOO WRX XEC XNO XRD XVS YFI ZEN ASTR AURORA BICO CKB CSPR DUSK FLUX GLMR MOVR OSMO SCRT STX EGLD JOE KLAY KMD LQTY LRC LPT METIS NTRN ORDI PENDLE PIXEL PORTAL RON SKL STRAX SUPER SXP TNSR TON TURBO VANA WAXP XAI XCH XCN XEM XMR XRD YGG ZETA ZRO ACE AEVO AGLD AI ALICE AMB AMP ANKR APE API3 ASTR ATA AXS BADGER BAL BICO BLZ BOME BOND BSW C98 CANTO CELO CFX COMBO COS COTI CYBER DATA DCR DEGO DENT DEXE DGB DIA DODO DOGS DUSK EDU ELF ELF ELA FIDA FIO FLM FORT FLOKI FRONT GTC HIFI HIGH HIVE HOOK HOT ICP ID IDIA ILV IMX IRIS JOE KAVA KDA KEY KLAY LEVER LINA LOOKS LQTY LSK LTO MBOX MDT MEME MERL METER MINA MOB MOG MOCA MOVR NFP NKN NMR NTRN OAX OCEAN OGN OM ONG ONDO ORBS OSMO OXT PAXG PEOPLE PEPE PERP PHB PHA PIVX PONKE POND POWR PROM PSG PUNDIX QI QUICK RAD RARE RATS RAY RDNT REI REQ RLC RON ROSE RSR RSS3 RUNE SAGA SAND SC SCRT SFP SHIB SKL SLERF SNT SNX SOLV SONIC SPELL SPX SRM STEEM STG STMX STORJ STRK STX SSV SWEAT TAIKO TKO TLM TNSR TOKEN TON TRB TROY TURBO TUT USTC VANA VELO VET VOXEL WAXP WIF WIN WLD WOO XAI XEC XEL XLM XNO XRD XTZ YFI ZEC ZEN ZK ZRO ZRX""".split())
-_TELEGRAM_PAGE_SUFFIX = """<script>(async()=>{const c=document.createElement('div');c.className='card full';c.innerHTML='<h2 class=section-title>Telegram analysis bot</h2><div id=telegramStatus>Loading...</div>';document.querySelector('.grid')?.appendChild(c);try{const r=await fetch('/api/telegram/status');const s=await r.json();document.getElementById('telegramStatus').textContent=(s.enabled?'Enabled':'Disabled')+' · '+s.mode+' · webhook '+(s.webhookEndpointReady?'ready':'not configured')+' · proxy '+(s.proxyConfigured?'yes':'no')+' · relay '+(s.relayConfigured?'yes':'no')+' · authorized users '+s.authorizedUserCount}catch(e){document.getElementById('telegramStatus').textContent='Status unavailable'}})();</script>"""
 
 
 class _CycleRequest(BaseModel):
@@ -110,13 +110,20 @@ def _is_future_iso(value: object) -> bool:
         return False
 
 
-async def _probe(url: str, timeout: float = 3.0) -> str:
+async def _probe(url: str, timeout: float = 3.0) -> dict:
+    started = time.perf_counter()
     try:
         async with httpx.AsyncClient() as client:
             resp = await client.get(url, timeout=timeout)
-            return "ok" if resp.status_code < 400 else "degraded"
-    except Exception:
-        return "unreachable"
+            status = "healthy" if resp.status_code < 400 else "degraded"
+            return {"status": status, "endpoint": url, "httpStatus": resp.status_code,
+                    "latencyMs": round((time.perf_counter()-started)*1000, 1),
+                    "lastSuccessful": time.time() if resp.status_code < 400 else None,
+                    "failureReason": None if resp.status_code < 400 else f"HTTP {resp.status_code}"}
+    except Exception as exc:
+        return {"status": "unavailable", "endpoint": url,
+                "latencyMs": round((time.perf_counter()-started)*1000, 1),
+                "lastSuccessful": None, "failureReason": type(exc).__name__}
 
 
 async def _mark_price(ccxt_perp_symbol: str) -> float | None:
@@ -264,13 +271,22 @@ async def _load_symbols() -> tuple[list[dict], str]:
 @router.get("/api/futures/status")
 async def futures_status() -> JSONResponse:
     state = _dash_state.snapshot()
-    ds4_health, ds2_health = await _probe(f"{DS4_BASE}/api/short-hunter/health"), \
-        await _probe(f"{DS2_BASE}/api/market")
+    ds4_health, ds2_primary, ds2_fallback = await asyncio.gather(
+        _probe(f"{DS4_BASE}/api/short-hunter/health"),
+        _probe(f"{DS2_BASE}/real/api/market/tickers"),
+        _probe(f"{DS2_BASE}/api/coins/top"),
+    )
+    def health_obj(value):
+        return value if isinstance(value, dict) else {"status": value}
+    ds4_health, ds2_primary, ds2_fallback = map(health_obj, (ds4_health, ds2_primary, ds2_fallback))
+    ds2_health = ds2_primary if ds2_primary.get("status") in {"healthy", "ok"} else ds2_fallback
+    ds2_health["fallbackEndpoint"] = ds2_fallback.get("endpoint")
     account = await _get_futures_account()
     positions = await _get_futures_positions()
     return JSONResponse({
-        "primaryDatasource": {"status": ds4_health, "url": DS4_BASE},
-        "secondaryDatasource": {"status": ds2_health, "url": DS2_BASE},
+        "primaryDatasource": {**ds4_health, "url": DS4_BASE},
+        "secondaryDatasource": {**ds2_health, "url": DS2_BASE,
+                                 "primaryEndpoint": ds2_primary.get("endpoint")},
         "fieldSources": state.get("field_sources", {}),
         "currentSignal": state.get("current_signal"),
         "signalReasons": state.get("signal_reasons", []),
@@ -292,6 +308,7 @@ async def futures_status() -> JSONResponse:
         "openPositionCount": len(positions.get("positions", [])),
         "updatedAt": state.get("updated_at"),
         "serverTime": time.time(),
+        "marketDataStatus": "healthy" if ds4_health.get("status") == "healthy" else "degraded",
     })
 
 
@@ -302,23 +319,54 @@ async def futures_symbols() -> JSONResponse:
     for item in items:
         item.setdefault("source", source)
         item["updatedAt"] = time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime(float(updated)))
-    return JSONResponse({"symbols": items, "source": source, "updatedAt": items[0]["updatedAt"] if items else None})
+    verified = sum(1 for item in items if item.get("futuresVerified") is True)
+    return JSONResponse({"symbols": items, "source": source,
+                         "catalogCount": len(items), "verifiedFuturesCount": verified,
+                         "marketOnlyCount": max(0, len(items)-verified),
+                         "updatedAt": items[0]["updatedAt"] if items else None})
 
 
 @router.get("/api/futures/positions")
 async def futures_positions() -> JSONResponse:
     positions = await _get_futures_positions()
-    enriched = []
-    for p in positions.get("positions", []):
-        mark = await _mark_price(p["symbol"])
+    sem = asyncio.Semaphore(4)
+    async def enrich(p):
+        async with sem:
+            try:
+                mark = await asyncio.wait_for(_mark_price(p["symbol"]), timeout=4.0)
+            except Exception:
+                mark = None
         unrealized = None
         if mark:
             direction = 1 if p["side"] == "long" else -1
             unrealized = (mark - p["entryPrice"]) * p["size"] * direction
-        enriched.append({**p, "markPrice": mark, "unrealizedPnl": unrealized})
+        return {**p, "markPrice": mark, "unrealizedPnl": unrealized}
+    enriched = await asyncio.gather(*(enrich(p) for p in positions.get("positions", [])))
     return JSONResponse({"mode": positions.get("mode"), "positions": enriched})
 
 
+@router.get("/api/futures/market", dependencies=[Depends(_authenticated_dashboard_request)])
+async def futures_market(symbol: str = "BTCUSDT", interval: str = "5m", limit: int = 120) -> JSONResponse:
+    """Return real merged OHLCV and market metrics for the chart."""
+    if interval not in {"1m", "5m", "15m", "1h"}:
+        raise HTTPException(status_code=400, detail="Unsupported interval")
+    context = await _get_market_context(symbol, timeframe=interval)
+    merged = context.get("merged") or {}
+    candles = merged.get("ohlcv") or []
+    if limit > 0:
+        candles = candles[-min(limit, 500):]
+    ticker = merged.get("ticker") or {}
+    return JSONResponse({"symbol": context.get("symbol"), "interval": interval,
+                         "candles": candles, "ticker": ticker,
+                         "funding": merged.get("funding"),
+                         "openInterest": merged.get("openInterest"),
+                         "source": context.get("sources", {}).get("ohlcv", "unavailable"),
+                         "sources": context.get("sources", {}),
+                         "fetchedAt": context.get("fetchedAt"),
+                         "warnings": context.get("warnings", []),
+                         "noTradeGuard": context.get("noTradeGuard", True)})
+
+
 @router.post("/api/futures/analyze", dependencies=[Depends(_authenticated_dashboard_request)])
 async def futures_analyze(request: _CycleRequest) -> JSONResponse:
     """Run analysis only and return a server-referenced deterministic plan."""
@@ -456,13 +504,7 @@ async def futures_page() -> HTMLResponse:
     try:
         page = _TEMPLATE_PATH.read_text(encoding="utf-8")
     except OSError:
-        # Keep the existing inline page as a safe compatibility fallback if a
-        # legacy installation has not yet copied the template directory.
-        page = _PAGE
-    if "</body>" in page:
-        page = page.replace("</body>", _TELEGRAM_PAGE_SUFFIX + "</body>", 1)
-    else:
-        page += _TELEGRAM_PAGE_SUFFIX
+        page = "<!doctype html><title>Futures Desk unavailable</title><p>The Futures dashboard template is not installed.</p>"
     return HTMLResponse(page)
 
 

hermes_overlay/tools/templates/hermes_futures_desk_luxury.html

@@ -440,6 +440,10 @@ details.tech-shell[open] summary svg{transform:rotate(90deg)}
 }
 @media(prefers-reduced-motion:reduce){*{animation-duration:.01ms!important;animation-iteration-count:1!important;scroll-behavior:auto!important;transition-duration:.01ms!important}}
 </style>
+<style>
+.market-card{min-height:280px}.market-header,.chart-toolbar{display:flex;justify-content:space-between;align-items:center;gap:12px}.market-header strong{font-size:24px}.market-header .muted{display:block;font-size:12px;margin-top:4px}.market-chart{width:100%;height:220px;margin-top:12px;background:linear-gradient(180deg,#111d29,#0a121a);border:1px solid var(--line);border-radius:12px}.chart-empty{fill:var(--muted);font-size:14px}.source-badge{color:var(--blue);font-size:10px;border:1px solid #315a80;border-radius:999px;padding:2px 5px}.state-NOT_ANALYZED{border-color:var(--line)}
+@media(max-width:720px){.market-card{grid-column:span 12}.market-header,.chart-toolbar{align-items:flex-start;flex-direction:column}.market-chart{height:180px}.action-cluster{align-items:stretch}.action-cluster .mobile-note{max-width:none}}
+</style>
 </head>
 <body>
 <div class="app-shell">
@@ -530,18 +534,23 @@ details.tech-shell[open] summary svg{transform:rotate(90deg)}
           </div>
           <div class="action-cluster">
             <button id="analyze" class="btn primary"><svg viewBox="0 0 24 24" width="14" height="14" fill="none" stroke="currentColor" stroke-width="2.4" stroke-linecap="round" stroke-linejoin="round"><path d="M13 2 3 14h7l-1 8 10-12h-7z"/></svg>Analyze market</button>
-            <button id="execute" class="btn secondary" disabled><svg viewBox="0 0 24 24" width="14" height="14" fill="none" stroke="currentColor" stroke-width="2.4" stroke-linecap="round" stroke-linejoin="round"><path d="M5 12h14M13 5l7 7-7 7"/></svg>Execute paper trade</button>
+            <button id="execute" class="btn secondary" disabled><svg viewBox="0 0 24 24" width="14" height="14" fill="none" stroke="currentColor" stroke-width="2.4" stroke-linecap="round" stroke-linejoin="round"><path d="M5 12h14M13 5l7 7-7 7"/></svg>Execute paper trade</button><div id="executeReason" class="mobile-note">Run analysis first</div>
           </div>
         </div>
       </section>
 
       <section class="grid">
-        <div id="decisionCard" class="card decision state-NO_TRADE">
+        <div id="marketCard" class="card span-7 market-card">
+          <div class="market-header"><div><div class="section-title">Selected market</div><strong id="marketSymbol">BTCUSDT</strong><span id="marketMeta" class="muted">Waiting for market data</span></div><strong id="marketPrice" class="num">—</strong></div>
+          <div class="chart-toolbar"><span id="chartSource" class="muted">Chart unavailable</span><div id="chartIntervals" class="segmented"><button type="button" data-interval="1m">1m</button><button type="button" data-interval="5m" class="active">5m</button><button type="button" data-interval="15m">15m</button><button type="button" data-interval="1h">1h</button></div></div>
+          <svg id="marketChart" class="market-chart" viewBox="0 0 900 260" preserveAspectRatio="none" role="img" aria-label="OHLCV market chart"><text x="450" y="130" text-anchor="middle" class="chart-empty">No real OHLCV data available</text></svg>
+        </div>
+        <div id="decisionCard" class="card decision state-NOT_ANALYZED">
           <div class="decision-icon"><span class="medallion amber"><svg id="decisionIconSvg" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.4" stroke-linecap="round" stroke-linejoin="round"><rect x="6" y="4" width="4" height="16" rx="1"/><rect x="14" y="4" width="4" height="16" rx="1"/></svg></span></div>
           <div class="decision-body">
             <div class="section-title">Decision</div>
-            <strong id="decision">NO_TRADE</strong>
-            <div id="decisionHint" class="hint">Trading is blocked until all safety gates pass.</div>
+            <strong id="decision">Waiting for analysis</strong>
+            <div id="decisionHint" class="hint">Run an analysis to evaluate the current market.</div>
           </div>
         </div>
 
@@ -617,7 +626,7 @@ details.tech-shell[open] summary svg{transform:rotate(90deg)}
         <div id="signalsCard" class="card span-5 accS"><h2 class="section-title"><span class="medallion sapphire"><svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.2" stroke-linecap="round" stroke-linejoin="round"><path d="M12 2v4M12 18v4M4.9 4.9l2.8 2.8M16.3 16.3l2.8 2.8M2 12h4M18 12h4M4.9 19.1l2.8-2.8M16.3 7.7l2.8-2.8"/></svg></span>Signal analysis</h2><div id="signals" class="rows"><div class="empty">No valid signal components were available.</div></div></div>
 
         <div id="advisoryCard" class="card span-7 accL"><h2 class="section-title"><span class="medallion violet"><svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.2" stroke-linecap="round" stroke-linejoin="round"><path d="M12 2a7 7 0 0 1 7 7c0 3-2 4-2 7H7c0-3-2-4-2-7a7 7 0 0 1 7-7z"/><path d="M9 21h6"/><path d="M12 6v6l3 2"/></svg></span>Remote advisory</h2><div id="advisoryPanel" class="empty">Disabled until Analyze is run with Remote advisory enabled.</div></div>
-        <div id="accountCard" class="card span-5 accP"><div class="account-head"><h2 class="section-title"><span class="medallion amber"><svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.2" stroke-linecap="round" stroke-linejoin="round"><rect x="3" y="6" width="18" height="14" rx="2.5"/><path d="M3 10h18"/><path d="M7 3.5h6"/></svg></span>Account &amp; positions</h2></div><div id="account" class="rows"><div class="empty">Waiting for account status…</div></div><div id="positionsTable" class="positions" hidden></div></div>
+        <div id="accountCard" class="card span-5 accP"><div class="account-head"><h2 class="section-title"><span class="medallion amber"><svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.2" stroke-linecap="round" stroke-linejoin="round"><rect x="3" y="6" width="18" height="14" rx="2.5"/><path d="M3 10h18"/><path d="M7 3.5h6"/></svg></span>Account &amp; positions</h2></div><div id="account" class="rows"><div class="empty">Waiting for account status…</div></div><div id="positionsTable" class="positions"><div class="empty">No open Paper positions</div></div></div>
 
         <div id="sourcesCard" class="card source-wrap">
           <div class="source-grid">
@@ -626,6 +635,7 @@ details.tech-shell[open] summary svg{transform:rotate(90deg)}
             <div id="ds2Card" class="card source"><h2 class="section-title"><span class="medallion sapphire"><svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.2" stroke-linecap="round" stroke-linejoin="round"><circle cx="12" cy="12" r="9"/><path d="M8 12h8M12 8v8"/></svg></span>Datasource 2 · Complementary</h2><div id="ds2" class="empty">Loading…</div></div>
           </div>
         </div>
+        <div id="telegramCard" class="card full"><h2 class="section-title">System health · Telegram</h2><div id="telegramStatus" class="empty">Status unavailable</div></div>
 
         <div class="card full accP"><h2 class="section-title"><span class="medallion amber"><svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2.2" stroke-linecap="round" stroke-linejoin="round"><path d="M10.3 3.9 1.8 18a2 2 0 0 0 1.7 3h17a2 2 0 0 0 1.7-3L13.7 3.9a2 2 0 0 0-3.4 0z"/><path d="M12 9v4M12 17h.01"/></svg></span>Trade rejection reasons</h2><div id="reasons" class="empty">No plan analyzed yet.</div></div>
 
@@ -651,6 +661,8 @@ details.tech-shell[open] summary svg{transform:rotate(90deg)}
 const $=id=>document.getElementById(id);
 const esc=x=>String(x??'—').replace(/[&<>"']/g,c=>({'&':'&amp;','<':'&lt;','>':'&gt;','"':'&quot;',"'":'&#39;'}[c]));
 const fmt=x=>x===null||x===undefined||x===''?'—':esc(x);
+const numFmt=x=>{const n=Number(x);return Number.isFinite(n)?n.toLocaleString(undefined,{maximumFractionDigits:8}):'—'};
+const money=x=>{const n=Number(x);return Number.isFinite(n)?n.toLocaleString(undefined,{minimumFractionDigits:2,maximumFractionDigits:2})+' USDT':'—'};
 let symbols=[],activeIndex=-1,analysisBusy=false,latestPlan=null,latestStatus=null,statusBusy=false,positionsBusy=false,confirmResolver=null,hydratedFromStatus=false,selectedSymbolMeta=null;
 
 async function apiFetch(url,options={},timeoutMs=15000){
@@ -801,13 +813,16 @@ function formatLocalTime(iso){
   const d=new Date(iso);return isNaN(d.getTime())?String(iso):'Valid until '+d.toLocaleTimeString([], {hour:'2-digit',minute:'2-digit',second:'2-digit'});
 }
 function updateExecutionAvailability(){
-  if(!latestPlan)return;
+  if(!latestPlan){$('execute').disabled=true;$('executeReason').textContent='Run analysis first';return}
   const d=latestPlan.decision||'NO_TRADE';
   const validExpiry=latestPlan.expires_at&&Date.parse(latestPlan.expires_at)>Date.now();
   const currentSymbol=normalizedSymbol(),planSymbol=String(latestPlan.symbol||'').toUpperCase();
   const currentRisk=riskValue(),planRisk=latestPlan.risk_profile||'';
   const verified=latestPlan.futuresVerified===true || selectedSymbolMeta?.symbol===planSymbol&&selectedSymbolMeta?.futuresVerified===true;
-  $('execute').disabled=analysisBusy||!latestPlan.planId||!(d==='LONG'||d==='SHORT')||!!latestPlan.noTradeGuard||!latestPlan.risk_approved||!verified||!validExpiry||!!latestPlan.executed||currentSymbol!==planSymbol||currentRisk!==planRisk;
+  const disabled=analysisBusy||!latestPlan.planId||!(d==='LONG'||d==='SHORT')||!!latestPlan.noTradeGuard||!latestPlan.risk_approved||!verified||!validExpiry||!!latestPlan.executed||currentSymbol!==planSymbol||currentRisk!==planRisk;
+  $('execute').disabled=disabled;
+  const reason=analysisBusy?'Analysis in progress':!latestPlan.planId?'Run analysis first':d!=='LONG'&&d!=='SHORT'?'No directional plan':latestPlan.noTradeGuard?'noTradeGuard active':!latestPlan.risk_approved?'Risk approval failed':!verified?'Market-only symbol':!validExpiry?'Plan expired':latestPlan.executed?'Plan already executed':currentSymbol!==planSymbol?'Symbol changed':currentRisk!==planRisk?'Risk profile changed':'Ready';
+  $('executeReason').textContent=reason;
   const track=$('expiryTrack').children;
   if(validExpiry&&latestPlan.created_at){
     const total=Date.parse(latestPlan.expires_at)-Date.parse(latestPlan.created_at),left=Date.parse(latestPlan.expires_at)-Date.now();
@@ -836,9 +851,9 @@ function renderPlan(p){
   $('expiry').title=p.expires_at||'';
   $('expirySub').textContent=formatLocalTime(p.expires_at);
   $('planRows').innerHTML=[
-    rowCopy('Entry',p.entry),rowCopy('Stop Loss',p.stop_loss),rowCopy('Take Profit',p.take_profit),
+    rowCopy('Entry',money(p.entry)),rowCopy('Stop Loss',money(p.stop_loss)),rowCopy('Take Profit',money(p.take_profit)),
     row('Reward-to-risk',p.reward_to_risk),row('Leverage',p.effective_leverage??p.requested_leverage),
-    row('Quantity',p.quantity),row('Slippage',p.estimated_slippage_percent),row('Created',p.created_at),
+    row('Quantity',numFmt(p.quantity)),row('Slippage',p.estimated_slippage_percent==null?'—':p.estimated_slippage_percent+'%'),row('Created',p.created_at),
     rowCopy('Plan ID',p.planId)
   ].join('');
   const comps=Object.entries(p.components||{});
@@ -853,12 +868,12 @@ function renderPlan(p){
 
 function renderPositions(list,mode){
   const positions=Array.isArray(list)?list:[];
-  if(!positions.length){$('positionsTable').hidden=true;$('positionsTable').innerHTML='';return}
+  if(!positions.length){$('positionsTable').hidden=false;$('positionsTable').innerHTML='<div class="empty">No open Paper positions</div>';return}
   $('positionsTable').hidden=false;
   $('positionsTable').innerHTML='<table class="acct"><thead><tr><th>Symbol</th><th>Side</th><th>Quantity</th><th>Entry</th><th>Mark</th><th>PnL</th></tr></thead><tbody>'+positions.map(p=>{
     const side=String(p.side||p.positionSide||'—').toUpperCase(),sideClass=side.includes('LONG')?'long':side.includes('SHORT')?'short':'';
     const pnl=p.unrealizedPnl??p.pnl??p.unrealized_pnl,pnlNum=parseFloat(pnl),pnlClass=isFinite(pnlNum)?(pnlNum>=0?'pnl-pos':'pnl-neg'):'';
-    return '<tr><td>'+fmt(p.symbol)+'</td><td><span class="pos-side '+sideClass+'">'+fmt(side)+'</span></td><td>'+fmt(p.quantity??p.size??p.qty??p.positionAmt)+'</td><td>'+fmt(p.entryPrice??p.entry_price)+'</td><td>'+fmt(p.markPrice??p.mark_price)+'</td><td class="'+pnlClass+'">'+fmt(pnl)+'</td></tr>';
+    return '<tr><td>'+fmt(p.symbol)+'</td><td><span class="pos-side '+sideClass+'">'+fmt(side)+'</span></td><td>'+numFmt(p.quantity??p.size??p.qty??p.positionAmt)+'</td><td>'+money(p.entryPrice??p.entry_price)+'</td><td>'+money(p.markPrice??p.mark_price)+'</td><td class="'+pnlClass+'">'+money(pnl)+'</td></tr>';
   }).join('')+'</tbody></table>';
 }
 async function refreshPositions(){
@@ -874,10 +889,10 @@ function renderStatus(s){
   latestStatus=s;
   $('mode').textContent=fmt(s.tradingMode);
   $('account').innerHTML=[
-    row('Paper equity',s.equity),row('Daily PnL',s.realizedPnlToday),
+    row('Paper equity',money(s.equity)),row('Daily PnL',money(s.realizedPnlToday)),
     row('Open positions',s.openPositionCount??0),row('Latest execution',s.latestPaperExecutionResult?.status||'None')
   ].join('');
-  const sw=(s.warnings||[]).join(' '),bs=/HTTP 451/i.test(sw)?'unavailable':Object.values(s.fieldSources||{}).some(x=>x==='binance_public')?'degraded':'available';
+  const sw=(s.warnings||[]).join(' '),bs=/HTTP 451/i.test(sw)?'unavailable':Object.values(s.fieldSources||{}).some(x=>x==='binance_public')?'degraded':'standby';
   const badges=[['DS4',s.primaryDatasource?.status],['Binance',bs],['DS2',s.secondaryDatasource?.status],['Remote Advisory',s.latestTradePlan?.external_advisory?(s.latestTradePlan.external_advisory.status||'available'):'info']];
   $('badges').innerHTML=badges.map(x=>{
     const cls=x[1]==='info'?'info':statusClass(x[1]);
@@ -886,6 +901,10 @@ function renderStatus(s){
   const now=new Date().toLocaleTimeString();
   $('refresh').textContent='Last refresh '+now;$('footerTime').textContent=now;
   renderSources(s);
+  apiFetch('/api/telegram/status',{},5000).then(t=>{
+    const state=!t.enabled?'Disabled':!t.authorizedUserCount?'Owner setup required':(t.proxyConfigured||t.relayConfigured?'Ready':'Relay/proxy required for proactive alerts');
+    $('telegramStatus').innerHTML='<span class="badge '+(state==='Ready'?'ok':state==='Disabled'?'info':'degraded')+'">'+esc(state)+'</span><div class="muted">Webhook '+(t.webhookEndpointReady?'ready':'not configured')+' · mode '+esc(t.mode||'webhook')+'</div>';
+  }).catch(()=>{$('telegramStatus').textContent='Status unavailable'});
 
   /* hydrate the workspace with the server's last known plan on first load only */
   if(!hydratedFromStatus&&!latestPlan&&s.latestTradePlan){
@@ -915,11 +934,11 @@ function setComboOpen(open){
   $('symbolSearch').setAttribute('aria-expanded',String(open));
   if(!open)activeIndex=-1;
 }
-function chooseSymbol(symbol){$('symbolSearch').value=String(symbol||'').toUpperCase();selectedSymbolMeta=symbols.find(x=>x.symbol===$('symbolSearch').value)||null;setComboOpen(false);updateExecutionAvailability()}
+function chooseSymbol(symbol){$('symbolSearch').value=String(symbol||'').toUpperCase();selectedSymbolMeta=symbols.find(x=>x.symbol===$('symbolSearch').value)||null;setComboOpen(false);updateExecutionAvailability();loadChart()}
 function showList(){
   const q=$('symbolSearch').value.trim().toUpperCase();
   const found=symbols.filter(x=>(String(x.symbol||'')+' '+String(x.name||'')+' '+String(x.baseAsset||'')+' '+String(x.quoteAsset||'')+' '+String(x.rank||'')).toUpperCase().includes(q)).slice(0,80);
-  $('symbolList').innerHTML=found.length?found.map(x=>'<div class="combo-item" role="option" tabindex="-1" data-symbol="'+esc(x.symbol)+'"><span><b>'+esc(x.symbol)+'</b><small>'+esc(x.name||'')+' · '+esc(x.baseAsset)+' / '+esc(x.quoteAsset)+'</small></span><small class="'+(x.futuresVerified?'verified':'unverified')+'">'+(x.futuresVerified?'✓ Verified Futures':'Market-only')+'</small></div>').join(''):'<div class="empty">No active pair found. Validated manual entry is allowed.</div>';
+  $('symbolList').innerHTML=found.length?found.map(x=>'<div class="combo-item" role="option" tabindex="-1" data-symbol="'+esc(x.symbol)+'"><span><b>'+esc(x.symbol)+'</b><small>'+esc(x.name||'')+' · '+esc(x.baseAsset)+' / '+esc(x.quoteAsset)+'</small></span><small><span class="source-badge">'+esc(x.source||'unknown')+'</span> <span class="'+(x.futuresVerified?'verified':'unverified')+'">'+(x.futuresVerified?'✓ Verified Futures':'Market-only')+'</span></small></div>').join(''):'<div class="empty">No active pair found. Validated manual entry is allowed.</div>';
   setComboOpen(true);
   document.querySelectorAll('.combo-item').forEach(el=>el.onclick=()=>chooseSymbol(el.dataset.symbol));
 }
@@ -949,11 +968,23 @@ async function loadSymbols(){
   try{
     const p=await apiFetch('/api/futures/symbols');symbols=Array.isArray(p.symbols)?p.symbols.filter(x=>x&&x.symbol):[];
     if(latestPlan){latestPlan.futuresVerified=symbols.some(x=>x.symbol===String(latestPlan.symbol||'').toUpperCase()&&x.futuresVerified===true);updateExecutionAvailability()}
-    $('symbolState').textContent=symbols.length?symbols.length+' active pairs · source '+p.source:'Symbol service unavailable; validated manual entry enabled';
+    $('symbolState').textContent=symbols.length?`${p.catalogCount??symbols.length} catalog entries · ${p.verifiedFuturesCount??symbols.filter(x=>x.futuresVerified).length} verified Futures · ${p.marketOnlyCount??symbols.filter(x=>!x.futuresVerified).length} market-only`:'Symbol service unavailable; validated manual entry enabled';
     renderChips();
   }catch(e){$('symbolState').textContent='Symbol service unavailable; validated manual entry enabled'}
 }
 function normalizedSymbol(){return $('symbolSearch').value.trim().toUpperCase()}
+let chartInterval='5m',chartBusy=false;
+function renderChart(data){
+  const candles=Array.isArray(data?.candles)?data.candles:[],svg=$('marketChart');
+  $('chartSource').textContent=candles.length?(data.source||'unavailable')+' · '+(data.fetchedAt?new Date(data.fetchedAt*1000).toLocaleTimeString():'fresh'):'Chart unavailable — no real candles returned';
+  if(!candles.length){svg.innerHTML='<text x="450" y="130" text-anchor="middle" class="chart-empty">No real OHLCV data available</text>';return}
+  const vals=candles.map(c=>Number(c.close??c[4])).filter(Number.isFinite),lo=Math.min(...vals),hi=Math.max(...vals),span=hi-lo||1;
+  const points=vals.map((v,i)=>`${(i/(vals.length-1||1))*880+10},${240-((v-lo)/span)*220}`).join(' ');
+  svg.innerHTML='<polyline fill="none" stroke="var(--gold)" stroke-width="2" points="'+points+'"/><line x1="10" y1="240" x2="890" y2="240" stroke="var(--line)"/>';
+  const last=vals.at(-1);$('marketPrice').textContent=money(last);$('marketSymbol').textContent=data.symbol||normalizedSymbol();
+}
+async function loadChart(){if(chartBusy)return;chartBusy=true;try{renderChart(await apiFetch('/api/futures/market?symbol='+encodeURIComponent(normalizedSymbol()||'BTCUSDT')+'&interval='+chartInterval+'&limit=120',{},12000))}catch(e){renderChart({candles:[]});$('chartSource').textContent='Chart unavailable'}finally{chartBusy=false}}
+document.querySelectorAll('#chartIntervals button').forEach(btn=>btn.onclick=()=>{document.querySelectorAll('#chartIntervals button').forEach(b=>b.classList.remove('active'));btn.classList.add('active');chartInterval=btn.dataset.interval;loadChart()});
 function setAnalysisBusy(busy){
   analysisBusy=busy;$('analyze').disabled=busy;$('loading').classList.toggle('show',busy);$('analyze').setAttribute('aria-busy',String(busy));
   if(busy)$('execute').disabled=true;else updateExecutionAvailability();
@@ -967,7 +998,7 @@ $('analyze').onclick=async()=>{
     const p=await apiFetch('/api/futures/analyze',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({symbol,risk_profile:riskValue(),include_external_context:$('advisory').checked})});
     renderPlan(p);toast(p.decision==='NO_TRADE'?'Analysis complete — no trade':'Analysis complete — '+p.decision+' plan ready','ok');
   }catch(e){
-    latestPlan=null;$('execute').disabled=true;$('reasons').innerHTML='<div class="empty">'+esc(e.message)+'</div>';$('decision').textContent='NO_TRADE';$('decisionCard').className='card decision state-NO_TRADE';
+    latestPlan=null;$('execute').disabled=true;$('reasons').innerHTML='<div class="empty">'+esc(e.message)+'</div>';$('decision').textContent='Analysis failed';$('decisionHint').textContent='No executable plan was produced.';$('decisionCard').className='card decision state-ANALYSIS_FAILED';$('executeReason').textContent='Analysis failed';
     toast(e.message||'Analysis failed','err');
   }finally{clearInterval(timer);$('elapsed').textContent='0.0s';setAnalysisBusy(false)}
 };
@@ -986,7 +1017,7 @@ $('execute').onclick=async()=>{
 function tickClock(){$('clock').textContent=new Date().toLocaleTimeString()}
 setInterval(tickClock,1000);tickClock();
 setInterval(()=>{if(latestPlan?.expires_at){$('expiry').textContent=expiryCountdown(latestPlan.expires_at);updateExecutionAvailability()}},1000);
-loadSymbols();refresh();
+loadSymbols();refresh();loadChart();
 setInterval(()=>{if(!document.hidden)refresh()},5000);
 document.addEventListener('visibilitychange',()=>{if(!document.hidden)refresh()});
 </script>