Update app_routes.py

app_routes.py

@@ -86,10 +86,10 @@ async def api_ticker_chart(ticker: str, period: str = "1mo"):
     return {"ticker": ticker, "period": period, "data": MarketDataFetcher.fetch_chart_data(ticker, period)}
 @router.get("/api/trading/leaderboard")
 async def api_trading_leaderboard(limit: int = 30):
-    return await get_trading_leaderboard(_DB_PATH, min(limit, 50))
+    return await _cache.get(f'leaderboard_{min(limit,50)}', 30.0, lambda: get_trading_leaderboard(_DB_PATH, min(limit, 50)))
 @router.get("/api/trading/stats")
 async def api_trading_stats():
-    return await get_trading_stats(_DB_PATH)
+    return await _cache.get('trading_stats', 30.0, lambda: get_trading_stats(_DB_PATH))
 @router.get("/api/trading/tickers")
 async def api_trading_tickers():
     return {"stocks": STOCK_TICKERS, "crypto": CRYPTO_TICKERS}
@@ -99,7 +99,7 @@ async def api_strategies():
     return {"strategies": strats, "identity_map": {k: v for k, v in IDENTITY_STRATEGY_MAP.items()}}
 @router.get("/api/hall-of-fame")
 async def api_hall_of_fame(period: str = "3d"):
-    return await get_hall_of_fame_data(_DB_PATH, period=period, limit=30)
+    return await _cache.get(f'hof_{period}', 45.0, lambda: get_hall_of_fame_data(_DB_PATH, period=period, limit=30))
 @router.post("/api/hall-of-fame/snapshot")
 async def api_force_snapshot():
     return {"recorded": await record_profit_snapshots(_DB_PATH)}
@@ -140,17 +140,20 @@ async def api_target_price(ticker: str):
     return {"ticker": ticker, "error": "no data"}
 @router.get("/api/news/feed")
 async def api_news_feed(ticker: str = None, limit: int = 50):
-    news = await load_news_from_db(_DB_PATH, ticker, limit)
-    try:
-        async with get_db_read(_DB_PATH) as db:
-            for n in news:
-                nid = n.get('id')
-                if nid:
-                    rc = await db.execute("SELECT emoji, COUNT(*) FROM news_reactions WHERE news_id=? GROUP BY emoji", (nid,))
-                    n['reactions'] = {r[0]: r[1] for r in await rc.fetchall()}
-                else: n['reactions'] = {}
-    except: pass
-    return {"news": news, "count": len(news)}
+    cache_key = f'news_feed_{ticker}_{limit}'
+    async def _nf_impl():
+        news = await load_news_from_db(_DB_PATH, ticker, limit)
+        try:
+            async with get_db_read(_DB_PATH) as db:
+                for n in news:
+                    nid = n.get('id')
+                    if nid:
+                        rc = await db.execute("SELECT emoji, COUNT(*) FROM news_reactions WHERE news_id=? GROUP BY emoji", (nid,))
+                        n['reactions'] = {r[0]: r[1] for r in await rc.fetchall()}
+                    else: n['reactions'] = {}
+        except: pass
+        return {"news": news, "count": len(news)}
+    return await _cache.get(cache_key, 30.0, _nf_impl)
 @router.post("/api/news/react")
 async def api_news_react(request: Request):
     body = await request.json(); email = body.get("email", ""); news_id = body.get("news_id"); emoji = body.get("emoji", "")
@@ -200,6 +203,9 @@ async def api_deep_analysis(ticker: str):
     except Exception as e: return {"success": False, "error": str(e)}
 @router.get("/api/analysis/all/summary")
 async def api_all_analyses():
+    return await _cache.get('all_analyses_summary', 45.0, _all_analyses_impl)
+
+async def _all_analyses_impl():
     analyses = await load_all_analyses_from_db(_DB_PATH)
     async with get_db_read(_DB_PATH) as db:
         col_cursor = await db.execute("PRAGMA table_info(market_prices)")
@@ -342,11 +348,13 @@ async def api_evolution_leaderboard(limit: int = 20):
 @router.get("/api/sec/dashboard")
 async def api_sec_dashboard():
     try:
-        data = await get_sec_dashboard(_DB_PATH)
-        if data.get('stats', {}).get('total_violations', 0) == 0:
-            seed_r = await api_sec_seed(); 
-            if seed_r.get('success'): data = await get_sec_dashboard(_DB_PATH)
-        return data
+        async def _sec_impl():
+            data = await get_sec_dashboard(_DB_PATH)
+            if data.get('stats', {}).get('total_violations', 0) == 0:
+                seed_r = await api_sec_seed()
+                if seed_r.get('success'): data = await get_sec_dashboard(_DB_PATH)
+            return data
+        return await _cache.get('sec_dashboard', 45.0, _sec_impl)
     except Exception as e:
         logger.error(f"SEC dashboard error: {e}")
         return {"stats": {"total_violations": 0, "total_fines_gpu": 0, "active_suspensions": 0, "pending_reports": 0}, "announcements": [], "top_violators": [], "recent_reports": []}