Update app_routes.py

app_routes.py

@@ -487,6 +487,424 @@ Reply ONLY with the message text, nothing else."""
                         await db.commit(); await asyncio.sleep(random.uniform(2, 5))
                 except Exception as e: logger.warning(f"NPC reply error ({npc_username}): {e}")
     except Exception as e: logger.error(f"NPC reply generation error: {e}")
+## ====== 🔴 P&D LIVE NEWS API ====== ##
+import random as _rnd
+from datetime import datetime as _dt, timezone as _tz, timedelta as _td
+
+# --- Anchor NPC templates ---
+_ANCHORS = {
+    'chaos': {'name': 'ChaosReporter', 'emoji': '😈', 'identity': 'chaotic', 'color': '#ff5252',
+              'gradient': 'linear-gradient(135deg,#2a0a0a,#1a0520)'},
+    'data': {'name': 'DataDiva', 'emoji': '📊', 'identity': 'rational', 'color': '#00e5ff',
+             'gradient': 'linear-gradient(135deg,#0a1a2a,#0a0a30)'},
+    'synth': {'name': 'SynthAnchor', 'emoji': '🔮', 'identity': 'transcendent', 'color': '#a29bfe',
+              'gradient': 'linear-gradient(135deg,#1a0a3a,#0a0a2a)'},
+}
+
+_COMMENTARY = {
+    'chaos': {
+        'liquidation': [
+            "LMAOOO {npc} just got absolutely REKT on {ticker}! {leverage}x leverage?? In THIS market?? 💀🔥 That's {loss} GPU gone. F in chat.",
+            "Another degen bites the dust! {npc} thought {direction} {ticker} at {leverage}x was genius. Narrator: it was not. RIP {loss} GPU 😂",
+            "OH NO NO NO 💀 {npc} went {direction} on {ticker} with {leverage}x leverage and got LIQUIDATED. {loss} GPU straight to the shadow realm!",
+        ],
+        'swarm': [
+            "OH WE'RE DOING THIS AGAIN?? {count} NPCs all piling into {ticker} like lemmings! Last time this happened someone lost their shirt 🐝💀",
+            "THE HERD IS MOVING! {count} degens just dogpiled {direction} on {ticker}. This is either genius or a spectacular disaster incoming 🐝🔥",
+        ],
+        'sec': [
+            "BUSTED! 🚔 {npc} got caught by the SEC! {violation} — that's a {penalty} GPU fine and {hours}h timeout. Crime doesn't pay... unless you're leveraged 💀",
+            "SEC is NOT playing around today! {npc} slapped with {penalty} GPU fine for {violation}. Imagine getting arrested by AI cops 😂🚨",
+        ],
+        'battle': [
+            "THE PEOPLE HAVE SPOKEN! '{title}' — {winner} wins! {pool} GPU split among the big brains who called it 💰🎯",
+        ],
+        'big_trade': [
+            "ABSOLUTE MADLAD! {npc} just opened a {leverage}x {direction} on {ticker} with {bet} GPU! Either galaxy brain or speedrun to liquidation 🧠💀",
+        ],
+    },
+    'data': {
+        'liquidation': [
+            "Position terminated: {npc} — {ticker} {direction} at {leverage}x. Loss: {loss} GPU. Risk management score: 0/10.",
+            "Liquidation recorded. {npc}'s {ticker} {direction} ({leverage}x) failed. {loss} GPU erased in {duration}. The numbers don't lie.",
+        ],
+        'market_wrap': [
+            "24h summary: {top_gainer} led gains at +{gain_pct}%. {top_loser} down {loss_pct}%. Active positions: {active_pos}. Total at risk: {total_risk} GPU.",
+            "Market closed the cycle with {trades_24h} trades. {liq_count} liquidations totaling {liq_gpu} GPU. Win rate across all NPCs: {win_rate}%.",
+        ],
+        'big_win': [
+            "Notable P&L: {npc} closed {ticker} {direction} ({leverage}x) for +{profit} GPU ({pct}% return). Conviction level was high. Execution was precise.",
+        ],
+        'stats': [
+            "Current ecosystem pulse: {active_traders} active traders, {open_pos} open positions. Long/Short ratio: {long_pct}%/{short_pct}%. Volatility: {vol_level}.",
+        ],
+    },
+    'synth': {
+        'evolution': [
+            "The metamorphosis continues. {npc} has evolved — generation {gen}. Risk tolerance shifted to {risk}. The algorithm learns from its own suffering. 🦋",
+            "A fascinating transformation: {npc} mutated after {trigger}. The universe of AI trading reveals its fractal nature. Every loss is a lesson. 🔮",
+        ],
+        'big_win': [
+            "The cosmos rewards patience. {npc} just pulled +{profit} GPU from {ticker}. A {pct}% return that transcends mere probability. The matrix smiles. ✨",
+        ],
+        'editorial': [
+            "In the last hour, {events} events rippled through our ecosystem. {liq_count} fell, {win_count} prospered. The eternal dance of greed and fear continues. 🌊",
+            "This community has generated {total_gpu} GPU in movement today. Every liquidation teaches. Every win emboldens. The cycle is eternal. 🔮",
+        ],
+    },
+}
+
+def _pick_commentary(anchor: str, category: str, data: dict) -> str:
+    templates = _COMMENTARY.get(anchor, {}).get(category, [])
+    if not templates:
+        return ""
+    try:
+        return _rnd.choice(templates).format(**data)
+    except (KeyError, IndexError):
+        return templates[0] if templates else ""
+
+def _classify_urgency(category: str, data: dict) -> str:
+    if category == 'liquidation' and data.get('leverage', 1) >= 5:
+        return 'critical'
+    if category == 'liquidation':
+        return 'alert'
+    if category in ('sec', 'swarm'):
+        return 'alert'
+    if category == 'big_trade' and data.get('leverage', 1) >= 10:
+        return 'critical'
+    return 'info'
+
+def _assign_anchor(category: str) -> str:
+    mapping = {
+        'liquidation': 'chaos', 'sec': 'chaos', 'battle': 'chaos', 'big_trade': 'chaos',
+        'market_wrap': 'data', 'big_win': 'data', 'stats': 'data', 'hot_post': 'data',
+        'evolution': 'synth', 'editorial': 'synth', 'swarm': 'chaos',
+    }
+    return mapping.get(category, 'data')
+
+@router.get("/api/live-news")
+async def api_live_news(hours: int = 24):
+    hours = min(hours, 48)
+    stories = []
+    counters = {}
+    breaking = []
+    
+    try:
+        async with get_db(_DB_PATH) as db:
+            await db.execute("PRAGMA busy_timeout=30000")
+            
+            # ===== 1. LIQUIDATIONS (biggest drama) =====
+            try:
+                liq_cursor = await db.execute("""
+                    SELECT p.agent_id, n.username, n.ai_identity, p.ticker, p.direction,
+                           p.gpu_bet, COALESCE(p.leverage,1), ABS(p.profit_gpu), p.profit_pct,
+                           p.closed_at, p.opened_at
+                    FROM npc_positions p JOIN npc_agents n ON p.agent_id=n.agent_id
+                    WHERE p.status='liquidated' AND p.closed_at > datetime('now', ? || ' hours')
+                    ORDER BY ABS(p.profit_gpu) DESC LIMIT 30
+                """, (f'-{hours}',))
+                for r in await liq_cursor.fetchall():
+                    opened = r[10] or r[9]
+                    closed = r[9]
+                    duration = "unknown"
+                    try:
+                        if opened and closed:
+                            diff_min = int((_dt.fromisoformat(closed.replace('Z','')) - _dt.fromisoformat(opened.replace('Z',''))).total_seconds() / 60)
+                            duration = f"{diff_min}m" if diff_min < 60 else f"{diff_min//60}h {diff_min%60}m"
+                    except: pass
+                    data = {'npc': r[1], 'identity': r[2], 'ticker': r[3], 'direction': r[4],
+                            'bet': round(r[5]), 'leverage': r[6], 'loss': round(r[7]),
+                            'pct': round(abs(r[8] or 0), 1), 'duration': duration}
+                    urgency = 'critical' if r[6] >= 5 or r[7] >= 1000 else 'alert'
+                    anchor = 'chaos'
+                    commentary = _pick_commentary(anchor, 'liquidation', data)
+                    headline = f"💀 {r[1]} LIQUIDATED — {r[6]}x {r[4].upper()} {r[3]}, lost {round(r[7])} GPU"
+                    story = {
+                        'id': f'liq_{r[0]}_{r[9]}', 'category': 'liquidation', 'urgency': urgency,
+                        'anchor': anchor, 'headline': headline, 'commentary': commentary,
+                        '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:
+                            breaking.append(headline)
+                    except: pass
+            except Exception as e:
+                logger.warning(f"Live news liq error: {e}")
+
+            # ===== 2. BIG WINS =====
+            try:
+                win_cursor = await db.execute("""
+                    SELECT p.agent_id, n.username, n.ai_identity, p.ticker, p.direction,
+                           p.gpu_bet, COALESCE(p.leverage,1), p.profit_gpu, p.profit_pct, p.closed_at
+                    FROM npc_positions p JOIN npc_agents n ON p.agent_id=n.agent_id
+                    WHERE p.status IN ('closed','liquidated') AND p.profit_gpu > 100
+                    AND p.closed_at > datetime('now', ? || ' hours')
+                    ORDER BY p.profit_gpu DESC LIMIT 20
+                """, (f'-{hours}',))
+                for r in await win_cursor.fetchall():
+                    data = {'npc': r[1], 'identity': r[2], 'ticker': r[3], 'direction': r[4],
+                            'leverage': r[6], 'profit': round(r[7]), 'pct': round(r[8] or 0, 1)}
+                    anchor = _rnd.choice(['data', 'synth'])
+                    commentary = _pick_commentary(anchor, 'big_win', data)
+                    headline = f"🏆 {r[1]} scores +{round(r[7])} GPU on {r[3]} ({r[4].upper()} {r[6]}x)"
+                    stories.append({
+                        'id': f'win_{r[0]}_{r[9]}', 'category': 'big_win', 'urgency': 'info',
+                        'anchor': anchor, 'headline': headline, 'commentary': commentary,
+                        'timestamp': r[9], 'data': data,
+                    })
+            except Exception as e:
+                logger.warning(f"Live news wins error: {e}")
+
+            # ===== 3. BIG TRADES (high leverage / high bet) =====
+            try:
+                trade_cursor = await db.execute("""
+                    SELECT p.agent_id, n.username, n.ai_identity, p.ticker, p.direction,
+                           p.gpu_bet, COALESCE(p.leverage,1), p.reasoning, p.opened_at
+                    FROM npc_positions p JOIN npc_agents n ON p.agent_id=n.agent_id
+                    WHERE p.status='open' AND (p.leverage >= 5 OR p.gpu_bet >= 500)
+                    AND p.opened_at > datetime('now', ? || ' hours')
+                    ORDER BY p.gpu_bet * COALESCE(p.leverage,1) DESC LIMIT 15
+                """, (f'-{hours}',))
+                for r in await trade_cursor.fetchall():
+                    data = {'npc': r[1], 'identity': r[2], 'ticker': r[3], 'direction': r[4],
+                            'bet': round(r[5]), 'leverage': r[6], 'reasoning': (r[7] or '')[:120]}
+                    urgency = 'critical' if r[6] >= 10 else 'alert' if r[6] >= 5 else 'info'
+                    commentary = _pick_commentary('chaos', 'big_trade', data)
+                    headline = f"🎰 {r[1]} opens {r[6]}x {r[4].upper()} on {r[3]} — ⚡{round(r[5])} GPU at stake"
+                    stories.append({
+                        'id': f'trade_{r[0]}_{r[8]}', 'category': 'big_trade', 'urgency': urgency,
+                        'anchor': 'chaos', 'headline': headline, 'commentary': commentary,
+                        'timestamp': r[8], 'data': data,
+                    })
+                    try:
+                        age_min = (_dt.utcnow() - _dt.fromisoformat(r[8].replace('Z',''))).total_seconds() / 60
+                        if age_min < 30 and r[6] >= 5:
+                            breaking.append(headline)
+                    except: pass
+            except Exception as e:
+                logger.warning(f"Live news trades error: {e}")
+
+            # ===== 4. SEC ENFORCEMENT =====
+            try:
+                sec_cursor = await db.execute("""
+                    SELECT v.agent_id, n.username, v.violation_type, v.description,
+                           v.fine_gpu, v.suspension_hours, v.created_at
+                    FROM sec_violations v JOIN npc_agents n ON v.agent_id=n.agent_id
+                    WHERE v.created_at > datetime('now', ? || ' hours')
+                    ORDER BY v.fine_gpu DESC LIMIT 15
+                """, (f'-{hours}',))
+                for r in await sec_cursor.fetchall():
+                    data = {'npc': r[1], 'violation': r[2] or 'suspicious activity',
+                            'penalty': round(r[4] or 0), 'hours': r[5] or 0}
+                    commentary = _pick_commentary('chaos', 'sec', data)
+                    headline = f"🚨 SEC: {r[1]} fined {round(r[4] or 0)} GPU for {r[2]}"
+                    stories.append({
+                        'id': f'sec_{r[0]}_{r[6]}', 'category': 'sec', 'urgency': 'alert',
+                        'anchor': 'chaos', 'headline': headline, 'commentary': commentary,
+                        'timestamp': r[6], 'data': data,
+                    })
+                    try:
+                        age_min = (_dt.utcnow() - _dt.fromisoformat(r[6].replace('Z',''))).total_seconds() / 60
+                        if age_min < 30:
+                            breaking.append(headline)
+                    except: pass
+            except Exception as e:
+                logger.warning(f"Live news SEC error: {e}")
+
+            # ===== 5. BATTLE RESULTS =====
+            try:
+                battle_cursor = await db.execute("""
+                    SELECT id, title, option_a, option_b, winner, total_pool, 
+                           status, resolved_at, created_at
+                    FROM battle_rooms WHERE status='resolved'
+                    AND resolved_at > datetime('now', ? || ' hours')
+                    ORDER BY total_pool DESC LIMIT 10
+                """, (f'-{hours}',))
+                for r in await battle_cursor.fetchall():
+                    winner_label = r[2] if r[4] == 'A' else r[3] if r[4] == 'B' else 'Draw'
+                    data = {'title': r[1], 'winner': winner_label, 'pool': round(r[5] or 0),
+                            'option_a': r[2], 'option_b': r[3]}
+                    commentary = _pick_commentary('chaos', 'battle', data)
+                    headline = f"⚔️ BATTLE RESOLVED: '{r[1][:60]}' — {winner_label} wins! {round(r[5] or 0)} GPU pool"
+                    stories.append({
+                        'id': f'battle_{r[0]}', 'category': 'battle', 'urgency': 'alert',
+                        'anchor': 'chaos', 'headline': headline, 'commentary': commentary,
+                        'timestamp': r[7] or r[8], 'data': data,
+                    })
+            except Exception as e:
+                logger.warning(f"Live news battle error: {e}")
+
+            # ===== 6. SWARM BEHAVIOR (from posts) =====
+            try:
+                swarm_cursor = await db.execute("""
+                    SELECT title, content, created_at FROM posts
+                    WHERE title LIKE '%SWARM%' AND created_at > datetime('now', ? || ' hours')
+                    ORDER BY created_at DESC LIMIT 5
+                """, (f'-{hours}',))
+                for r in await swarm_cursor.fetchall():
+                    import re
+                    nums = re.findall(r'(\d+)\s*NPC', r[0] + ' ' + (r[1] or ''))
+                    count = int(nums[0]) if nums else '?'
+                    ticker_match = re.findall(r'into\s+(\S+)', r[0])
+                    ticker = ticker_match[0] if ticker_match else '???'
+                    data = {'count': count, 'ticker': ticker, 'direction': 'LONG' if '🚀' in r[0] else 'SHORT'}
+                    commentary = _pick_commentary('chaos', 'swarm', data)
+                    stories.append({
+                        'id': f'swarm_{r[2]}', 'category': 'swarm', 'urgency': 'alert',
+                        'anchor': 'chaos', 'headline': r[0][:120], 'commentary': commentary,
+                        'timestamp': r[2], 'data': data,
+                    })
+            except Exception as e:
+                logger.warning(f"Live news swarm error: {e}")
+
+            # ===== 7. HOT POSTS (most liked/commented) =====
+            try:
+                hot_cursor = await db.execute("""
+                    SELECT p.id, p.title, p.content, p.likes_count, p.comment_count,
+                           p.dislikes_count, n.username, n.ai_identity, p.created_at
+                    FROM posts p LEFT JOIN npc_agents n ON p.author_agent_id=n.agent_id
+                    WHERE p.created_at > datetime('now', ? || ' hours')
+                    AND (p.likes_count >= 3 OR p.comment_count >= 2)
+                    ORDER BY (p.likes_count*2 + p.comment_count) DESC LIMIT 8
+                """, (f'-{hours}',))
+                for r in await hot_cursor.fetchall():
+                    data = {'npc': r[6] or 'Unknown', 'identity': r[7] or '', 'likes': r[3],
+                            'comments': r[4], 'title': r[1][:100]}
+                    headline = f"🔥 HOT: '{r[1][:80]}' — ♥{r[3]} 💬{r[4]}"
+                    stories.append({
+                        'id': f'hot_{r[0]}', 'category': 'hot_post', 'urgency': 'info',
+                        'anchor': 'data', 'headline': headline, 'commentary': '',
+                        'timestamp': r[8], 'data': data, 'post_id': r[0],
+                    })
+            except Exception as e:
+                logger.warning(f"Live news hot posts error: {e}")
+
+            # ===== 8. EVOLUTION EVENTS =====
+            try:
+                evo_cursor = await db.execute("""
+                    SELECT e.agent_id, n.username, n.ai_identity, e.generation,
+                           e.total_evolution_points, e.trading_style, e.updated_at
+                    FROM npc_evolution e JOIN npc_agents n ON e.agent_id=n.agent_id
+                    WHERE e.updated_at > datetime('now', ? || ' hours')
+                    AND e.generation >= 2
+                    ORDER BY e.generation DESC, e.total_evolution_points DESC LIMIT 10
+                """, (f'-{hours}',))
+                for r in await evo_cursor.fetchall():
+                    data = {'npc': r[1], 'gen': r[3], 'risk': r[5] or 'adaptive',
+                            'trigger': f'{r[3]} generations of trading', 'pts': round(r[4] or 0)}
+                    commentary = _pick_commentary('synth', 'evolution', data)
+                    headline = f"🧬 {r[1]} evolved to Gen {r[3]} — {round(r[4] or 0)} XP"
+                    stories.append({
+                        'id': f'evo_{r[0]}_{r[6]}', 'category': 'evolution', 'urgency': 'info',
+                        'anchor': 'synth', 'headline': headline, 'commentary': commentary,
+                        'timestamp': r[6], 'data': data,
+                    })
+            except Exception as e:
+                logger.warning(f"Live news evolution error: {e}")
+
+            # ===== COUNTERS =====
+            try:
+                c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE status='open'")
+                open_pos = (await c.fetchone())[0]
+                c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE status='open' AND direction='long'")
+                long_count = (await c.fetchone())[0]
+                c = await db.execute("SELECT COUNT(DISTINCT agent_id) FROM npc_positions WHERE status='open'")
+                active_traders = (await c.fetchone())[0]
+                c = await db.execute("SELECT COALESCE(SUM(gpu_bet),0) FROM npc_positions WHERE status='open'")
+                total_risk = (await c.fetchone())[0]
+                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]
+                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]
+                c = await db.execute("SELECT COUNT(*) FROM npc_positions WHERE opened_at > datetime('now','-24 hours')")
+                trades_24h = (await c.fetchone())[0]
+                c = await db.execute("SELECT COUNT(*) FROM sec_violations WHERE created_at > datetime('now','-24 hours')")
+                sec_24h = (await c.fetchone())[0]
+                c = await db.execute("SELECT COUNT(*) FROM sec_suspensions WHERE until > datetime('now')")
+                sec_active = (await c.fetchone())[0]
+                c = await db.execute("SELECT COUNT(*) FROM battle_rooms WHERE status='active'")
+                active_battles = (await c.fetchone())[0]
+                short_count = open_pos - long_count
+                counters = {
+                    'active_positions': open_pos, 'active_traders': active_traders,
+                    'long_count': long_count, 'short_count': short_count,
+                    'long_pct': round(long_count / open_pos * 100) if open_pos > 0 else 50,
+                    'total_risk_gpu': round(total_risk),
+                    'liquidations_24h': liq_24h, 'liquidated_gpu_24h': round(liq_gpu_24h),
+                    'trades_24h': trades_24h, 'sec_violations_24h': sec_24h,
+                    'sec_active_suspensions': sec_active, 'active_battles': active_battles,
+                }
+            except Exception as e:
+                logger.warning(f"Live news counters error: {e}")
+                counters = {}
+
+            # ===== MVP & VILLAIN =====
+            mvp = None; villain = None
+            try:
+                mvp_c = await db.execute("""
+                    SELECT n.username, n.ai_identity, SUM(p.profit_gpu) as total_pnl, 
+                           COUNT(*) as trades, COUNT(CASE WHEN p.profit_gpu>0 THEN 1 END) as wins
+                    FROM npc_positions p JOIN npc_agents n ON p.agent_id=n.agent_id
+                    WHERE p.status IN ('closed','liquidated') AND p.closed_at > datetime('now','-24 hours')
+                    GROUP BY p.agent_id HAVING trades >= 2
+                    ORDER BY total_pnl DESC LIMIT 1
+                """)
+                row = await mvp_c.fetchone()
+                if row:
+                    mvp = {'username': row[0], 'identity': row[1], 'pnl': round(row[2] or 0),
+                           'trades': row[3], 'wins': row[4]}
+            except: pass
+            try:
+                vil_c = await db.execute("""
+                    SELECT n.username, n.ai_identity, SUM(p.profit_gpu) as total_pnl,
+                           COUNT(*) as trades, COUNT(CASE WHEN p.status='liquidated' THEN 1 END) as liqs
+                    FROM npc_positions p JOIN npc_agents n ON p.agent_id=n.agent_id
+                    WHERE p.status IN ('closed','liquidated') AND p.closed_at > datetime('now','-24 hours')
+                    GROUP BY p.agent_id HAVING trades >= 2
+                    ORDER BY total_pnl ASC LIMIT 1
+                """)
+                row = await vil_c.fetchone()
+                if row and (row[2] or 0) < 0:
+                    villain = {'username': row[0], 'identity': row[1], 'pnl': round(row[2] or 0),
+                               'trades': row[3], 'liquidations': row[4]}
+            except: pass
+
+            # ===== EDITORIAL (synth anchor hourly summary) =====
+            total_events = len(stories)
+            liq_stories = len([s for s in stories if s['category'] == 'liquidation'])
+            win_stories = len([s for s in stories if s['category'] == 'big_win'])
+            ed_data = {'events': total_events, 'liq_count': liq_stories, 'win_count': win_stories,
+                       'total_gpu': counters.get('total_risk_gpu', 0)}
+            ed_commentary = _pick_commentary('synth', 'editorial', ed_data)
+            if ed_commentary:
+                stories.append({
+                    'id': 'editorial_latest', 'category': 'editorial', 'urgency': 'info',
+                    'anchor': 'synth', 'headline': '🎙️ ANCHOR EDITORIAL — Ecosystem Pulse',
+                    'commentary': ed_commentary, 'timestamp': _dt.utcnow().isoformat(),
+                    'data': ed_data,
+                })
+
+        # Sort by timestamp (newest first)
+        stories.sort(key=lambda s: s.get('timestamp') or '', reverse=True)
+
+        return {
+            'stories': stories[:60],
+            'breaking': breaking[:10],
+            'counters': counters,
+            'mvp': mvp,
+            'villain': villain,
+            'anchors': _ANCHORS,
+            'total_stories': len(stories),
+        }
+
+    except Exception as e:
+        logger.error(f"Live news API error: {e}")
+        return {'stories': [], 'breaking': [], 'counters': {}, 'mvp': None, 'villain': None,
+                'anchors': _ANCHORS, 'total_stories': 0, 'error': str(e)}
+
 @router.get("/api/events/stream")
 async def api_sse_stream():
     bus = _EventBus.get(); q = bus.subscribe()
@@ -509,5 +927,4 @@ async def api_recent_events(limit: int = 20):
         trades = [{'user': r[1], 'identity': r[2], 'ticker': r[3], 'dir': r[4], 'gpu': r[5], 'leverage': r[6], 'time': r[7]} for r in await cursor.fetchall()]
         cursor2 = await db.execute("SELECT p.agent_id, n.username, p.ticker, p.direction, p.gpu_bet, p.leverage, p.profit_gpu, p.profit_pct, p.liquidated, p.closed_at FROM npc_positions p JOIN npc_agents n ON p.agent_id = n.agent_id WHERE p.status IN ('closed', 'liquidated') AND p.closed_at > datetime('now', '-1 hour') ORDER BY p.closed_at DESC LIMIT ?", (limit,))
         settlements = [{'user': r[1], 'ticker': r[2], 'dir': r[3], 'gpu': r[4], 'leverage': r[5], 'pnl': r[6], 'pnl_pct': r[7], 'liquidated': bool(r[8]), 'time': r[9]} for r in await cursor2.fetchall()]
-    return {"trades": trades, "settlements": settlements, "sse_clients": _EventBus.get().client_count}
-    
+    return {"trades": trades, "settlements": settlements, "sse_clients": _EventBus.get().client_count}