{json.dumps(response, indent=2)}")
except Exception as e:
return HTMLResponse(f"{str(e)}")
@app.get("/logout")
def logout():
response = RedirectResponse(url="/")
response.delete_cookie("access_token")
stop_fyers_ws()
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)
# ==========================================
# 5. FASTAPI WEBSOCKET (STREAM TO BROWSER)
# ==========================================
@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
await websocket.accept()
active_client_symbols =[]
try:
while True:
try:
data = await asyncio.wait_for(websocket.receive_json(), timeout=0.3)
action = data.get("action")
if action == "init":
token = data.get("token")
if token: start_fyers_ws(token)
elif action == "subscribe":
active_client_symbols = data.get("symbols",[])
update_subscriptions(active_client_symbols)
elif action == "stop":
stop_fyers_ws()
elif action == "start":
if GLOBAL_TOKEN: start_fyers_ws(GLOBAL_TOKEN)
except asyncio.TimeoutError:
pass
if SOCKET_RUNNING and active_client_symbols:
payload = {sym: STATE_MEMORY[sym] for sym in active_client_symbols if sym in STATE_MEMORY}
if payload:
await websocket.send_json({"type": "data", "payload": payload})
except WebSocketDisconnect:
print("[Client WS] Disconnected")
# ==========================================
# 6. FRONTEND UI (WORLD'S BEST LIGHT MODE)
# ==========================================
HTML_TEMPLATE = """