{json.dumps(data, indent=2)}")
@app.get("/logout")
def logout():
response = RedirectResponse(url="/")
response.delete_cookie("access_token")
return response
@app.get("/api/status")
def get_status(): return JSONResponse(SYSTEM_STATUS)
@app.get("/api/search")
def search_symbol(q: str = Query(..., min_length=1)):
if not SYSTEM_STATUS["ready"]: return JSONResponse([])
query = q.upper()
results = [x for x in SEARCH_INDEX if x['root'].startswith(query)]
if len(results) < 10: results += [x for x in SEARCH_INDEX if query in x['root'] and x not in results]
return JSONResponse(results[:20])
@app.get("/api/chain")
def get_chain(symbol: str):
root = symbol.upper()
if root in MASTER_DB: return JSONResponse(MASTER_DB[root])
return JSONResponse({"error": "Symbol not found"}, status_code=404)
@app.get("/api/refresh")
def force_refresh(background_tasks: BackgroundTasks):
SYSTEM_STATUS["ready"] = False
SYSTEM_STATUS["message"] = "Refreshing..."
background_tasks.add_task(update_master_db)
return JSONResponse({"s": "ok"})
# --- HISTORICAL API ---
def parse_bucket_data(bucket_rows):
slots = [{"s": f"{i*10:02d}", "d": {}} for i in range(6)]
for row in bucket_rows:
data = row.get('data')
if not data or not isinstance(data, dict): continue
for symbol, metrics in data.items():
p_arr = metrics.get('p', [])
b_arr = metrics.get('b', [])
s_arr = metrics.get('s', [])
v_arr = metrics.get('v', [])
o_arr = metrics.get('o', [])
for i in range(6):
try:
ltp = p_arr[i] if i < len(p_arr) else None
if ltp is None: continue
slots[i]['d'][symbol] = {
"ltp": ltp,
"totalbuyqty": b_arr[i] if i < len(b_arr) else 0,
"totalsellqty": s_arr[i] if i < len(s_arr) else 0,
"v": v_arr[i] if i < len(v_arr) else 0,
"oi": o_arr[i] if i < len(o_arr) else 0,
"expiry": 0
}
except: continue
return slots
@app.get("/api/hist/dates")
def get_hist_dates(symbol: str):
try:
res = supabase.table('history_buckets').select('minute').ilike('root', f"%{symbol}%").order('minute', desc=True).limit(2000).execute()
dates = set()
if res.data:
for item in res.data:
if item.get('minute'): dates.add(item.get('minute').split('T')[0].split(' ')[0])
return JSONResponse(sorted(list(dates), reverse=True))
except Exception as e: return JSONResponse({"error": str(e)}, status_code=500)
@app.get("/api/hist/minutes")
def get_hist_minutes(symbol: str, date: str):
try:
res = supabase.table('history_buckets').select('minute').ilike('root', f"%{symbol}%").gte('minute', f"{date}T00:00:00").lte('minute', f"{date}T23:59:59").order('minute', desc=True).limit(1000).execute()
minutes = set()
if res.data:
for item in res.data:
clean = item.get('minute').replace('T', ' ').split(' ')
if len(clean)>1: minutes.add(clean[1][:5])
return JSONResponse(sorted(list(minutes), reverse=True))
except Exception as e: return JSONResponse({"error": str(e)}, status_code=500)
@app.get("/api/hist/expiries")
def get_hist_expiries(symbol: str, date: str, minute: str):
try:
q1 = f"{date} {minute}:00"
q2 = f"{date}T{minute}:00"
res = supabase.table('history_buckets').select('expiry').ilike('root', f"%{symbol}%").or_(f"minute.eq.{q1},minute.eq.{q2}").neq('expiry', 'MARKET').execute()
expiries = set()
if res.data:
for item in res.data:
if item.get('expiry') and item.get('expiry') != 'MARKET': expiries.add(item.get('expiry'))
return JSONResponse(sorted(list(expiries)))
except Exception as e: return JSONResponse({"error": str(e)}, status_code=500)
@app.get("/api/hist/load")
def get_hist_data(symbol: str, date: str, minute: str, expiry: Optional[str] = None):
try:
q1 = f"{date} {minute}:00"
q2 = f"{date}T{minute}:00"
res = supabase.table('history_buckets').select('data, expiry').ilike('root', f"%{symbol}%").or_(f"minute.eq.{q1},minute.eq.{q2}").execute()
rows = res.data
if not rows: return JSONResponse({"s": "ok", "timeline": []})
filtered_rows = []
for r in rows:
e = r.get('expiry')
if not expiry or e == 'MARKET' or e == expiry: filtered_rows.append(r)
return JSONResponse({"s": "ok", "timeline": parse_bucket_data(filtered_rows)})
except Exception as e: return JSONResponse({"error": str(e)}, status_code=500)
# ==========================================
# 4. FRONTEND
# ==========================================
HTML_TEMPLATE = """