Update app_routes.py

app_routes.py

@@ -633,6 +633,9 @@ def _assign_anchor(category: str) -> str:
 @router.get("/api/live-news")
 async def api_live_news(hours: int = 24):
     hours = min(hours, 48)
+    return await _cache.get(f'live_news_{hours}', 30.0, lambda: _live_news_impl(hours))
+
+async def _live_news_impl(hours):
     stories = []
     counters = {}
     breaking = []
@@ -672,7 +675,6 @@ async def api_live_news(hours: int = 24):
                         'timestamp': r[9], 'data': data,
                     }
                     stories.append(story)
-                    # Breaking if within last 30 min
                     try:
                         age_min = (_dt.utcnow() - _dt.fromisoformat(closed.replace('Z',''))).total_seconds() / 60
                         if age_min < 30:
@@ -852,32 +854,28 @@ async def api_live_news(hours: int = 24):
             except Exception as e:
                 logger.warning(f"Live news evolution error: {e}")
 
-            # ===== COUNTERS (each query individually wrapped) =====
+            # ===== COUNTERS (consolidated into fewer queries) =====
             open_pos=0; long_count=0; active_traders=0; total_risk=0
             liq_24h=0; liq_gpu_24h=0; trades_24h=0; sec_24h=0; sec_active=0; active_battles=0
             try:
-                c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE status='open'")
-                open_pos = (await c.fetchone())[0] or 0
-            except: pass
-            try:
-                c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE status='open' AND direction='long'")
-                long_count = (await c.fetchone())[0] or 0
-            except: pass
-            try:
-                c = await db.execute("SELECT COUNT(DISTINCT agent_id) FROM npc_positions WHERE status='open'")
-                active_traders = (await c.fetchone())[0] or 0
-            except: pass
-            try:
-                c = await db.execute("SELECT COALESCE(SUM(gpu_bet),0) FROM npc_positions WHERE status='open'")
-                total_risk = (await c.fetchone())[0] or 0
-            except: pass
-            try:
-                c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE status='liquidated' AND closed_at > datetime('now','-24 hours')")
-                liq_24h = (await c.fetchone())[0] or 0
+                c = await db.execute("""
+                    SELECT COUNT(*), 
+                           COUNT(CASE WHEN direction='long' THEN 1 END),
+                           COUNT(DISTINCT agent_id),
+                           COALESCE(SUM(gpu_bet),0)
+                    FROM npc_positions WHERE status='open'
+                """)
+                row = await c.fetchone()
+                if row:
+                    open_pos, long_count, active_traders, total_risk = row[0] or 0, row[1] or 0, row[2] or 0, row[3] or 0
             except: pass
             try:
-                c = await db.execute("SELECT COALESCE(SUM(ABS(profit_gpu)),0) FROM npc_positions WHERE status='liquidated' AND closed_at > datetime('now','-24 hours')")
-                liq_gpu_24h = (await c.fetchone())[0] or 0
+                c = await db.execute("""
+                    SELECT COUNT(*), COALESCE(SUM(ABS(profit_gpu)),0)
+                    FROM npc_positions WHERE status='liquidated' AND closed_at > datetime('now','-24 hours')
+                """)
+                row = await c.fetchone()
+                if row: liq_24h, liq_gpu_24h = row[0] or 0, row[1] or 0
             except: pass
             try:
                 c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE opened_at > datetime('now','-24 hours')")