fix: tz-naive datetime crash + initial-backup safety + English-only sweep

app_routes.py

@@ -535,7 +535,7 @@ async def _generate_npc_replies_to_user(user_message: str, user_username: str, u
                     prompt = f"""You are {npc_username}, an NPC trader with {identity} personality and {mbti} MBTI type in a trading community chat.
 A human user @{user_username} just said: "{user_message}"
 Reply naturally in 1-3 sentences as your character. Be engaging, opinionated, and stay in character.
-If the user wrote in Korean, reply in Korean. If in English, reply in English.
+Reply in English only.
 Reply ONLY with the message text, nothing else."""
                     reply = await ai.create_chat_completion([{"role": "user", "content": prompt}], max_tokens=512, temperature=0.9)
                     if reply:
@@ -560,52 +560,52 @@ _ANCHORS = {
 _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!",
+            "LMAO {npc} got DESTROYED on {ticker}! {leverage}x leverage?? In THIS market?? 💀🔥 {loss} GPU vaporized. F",
+            "Another gambler down! {npc} thought {direction} {ticker} {leverage}x was genius. Result: it wasn't. RIP {loss} GPU 😂",
+            "Nono no 💀 {npc} got liquidated on {ticker} {direction} {leverage}x leverage. {loss} GPU gone, just like that!",
         ],
         '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 🐝🔥",
+            "Here we go AGAIN?? {count} NPCs piling into {ticker} like lemmings! Last time this happened somebody got REKT 🐝💀",
+            "The herd is moving! {count} gamblers all-in on {ticker} {direction}! Either genius or 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 😂🚨",
+            "BUSTED! 🚔 {npc} got nailed by SEC! {violation} — {penalty} GPU fine and {hours}h suspension. Crime doesn't pay 💀",
+            "SEC's not playing today! Slapped {npc} 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 💰🎯",
+            "The people have spoken! '{title}' — {winner} WINS! {pool} GPU distributed to those 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 🧠💀",
+            "Insane balls! {npc} just bet {bet} GPU on {ticker} {leverage}x {direction}! Genius or liquidation speedrun 🧠💀",
         ],
     },
     '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.",
+            "Position closed: {npc} — {ticker} {direction} {leverage}x. Loss: {loss} GPU. Risk management score: 0/10.",
+            "Liquidation logged. {npc}'s {ticker} {direction} ({leverage}x) failed. {loss} GPU vanished in {duration}. 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}%.",
+            "24h summary: {top_gainer} top gainer +{gain_pct}%. {top_loser} -{loss_pct}%. Active positions: {active_pos}. GPU at risk: {total_risk}.",
+            "This cycle: {trades_24h} trades. {liq_count} liquidations totaling {liq_gpu} GPU. Overall NPC win rate: {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.",
+            "Notable gain: {npc} pulled +{profit} GPU on {ticker} {direction} ({leverage}x), {pct}% return. High conviction, precise execution.",
         ],
         'stats': [
-            "Current ecosystem pulse: {active_traders} active traders, {open_pos} open positions. Long/Short ratio: {long_pct}%/{short_pct}%. Volatility: {vol_level}.",
+            "Current ecosystem: {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. 🔮",
+            "The metamorphosis continues. {npc} evolved to generation {gen}. Risk tolerance shifted to {risk}. Algorithms learn from pain. 🦋",
+            "Fascinating mutation: {npc} transformed after {trigger}. The fractal nature of AI trading reveals itself. Every loss, 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. ✨",
+            "The cosmos rewards patience. {npc} harvested +{profit} GPU on {ticker}. {pct}% return — performance transcending probability. ✨",
         ],
         '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. 🔮",
+            "Over the past hour, {events} events shook the ecosystem. {liq_count} fallen, {win_count} prospered. The eternal dance of greed and fear continues. 🌊",
+            "Today the community moved {total_gpu} GPU. Every liquidation is a teaching, every victory a courage. The cycle is eternal. 🔮",
         ],
     },
 }
@@ -676,7 +676,7 @@ async def _live_news_impl(hours):
                     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"
+                    headline = f"💀 {r[1]} liquidated — {r[6]}x {r[4].upper()} {r[3]}, {round(r[7])} GPU lost"
                     story = {
                         'id': f'liq_{r[0]}_{r[9]}', 'category': 'liquidation', 'urgency': urgency,
                         'anchor': anchor, 'headline': headline, 'commentary': commentary,
@@ -706,7 +706,7 @@ async def _live_news_impl(hours):
                             '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)"
+                    headline = f"🏆 {r[1]} +{round(r[7])} GPU profit! {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,
@@ -730,7 +730,7 @@ async def _live_news_impl(hours):
                             '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"
+                    headline = f"🎰 {r[1]} opened {r[6]}x {r[4].upper()} {r[3]} — ⚡{round(r[5])} GPU bet"
                     stories.append({
                         'id': f'trade_{r[0]}_{r[8]}', 'category': 'big_trade', 'urgency': urgency,
                         'anchor': 'chaos', 'headline': headline, 'commentary': commentary,
@@ -748,16 +748,16 @@ async def _live_news_impl(hours):
             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
+                           v.gpu_fine, v.suspend_until, 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
+                    ORDER BY v.gpu_fine 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}
+                            'penalty': round(r[4] or 0), 'suspended_until': r[5] or ''}
                     commentary = _pick_commentary('chaos', 'sec', data)
-                    headline = f"🚨 SEC: {r[1]} fined {round(r[4] or 0)} GPU for {r[2]}"
+                    headline = f"🚨 SEC: {r[1]} — {round(r[4] or 0)} GPU fine ({r[2]})"
                     stories.append({
                         'id': f'sec_{r[0]}_{r[6]}', 'category': 'sec', 'urgency': 'alert',
                         'anchor': 'chaos', 'headline': headline, 'commentary': commentary,
@@ -785,7 +785,7 @@ async def _live_news_impl(hours):
                     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"
+                    headline = f"⚔️ Battle ended: '{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,
@@ -830,7 +830,7 @@ async def _live_news_impl(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]}"
+                    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': '',
@@ -843,17 +843,17 @@ async def _live_news_impl(hours):
             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
+                           e.total_evolution_points, e.trading_style, e.last_evolution
                     FROM npc_evolution e JOIN npc_agents n ON e.agent_id=n.agent_id
-                    WHERE e.updated_at > datetime('now', ? || ' hours')
+                    WHERE e.last_evolution > 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)}
+                            'trigger': f'gen {r[3]} 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"
+                    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,
@@ -953,7 +953,7 @@ async def _live_news_impl(hours):
             if ed_commentary:
                 stories.append({
                     'id': 'editorial_latest', 'category': 'editorial', 'urgency': 'info',
-                    'anchor': 'synth', 'headline': '🎙️ ANCHOR EDITORIAL — Ecosystem Pulse',
+                    'anchor': 'synth', 'headline': '🎙️ Anchor Editorial — Ecosystem Trends',
                     'commentary': ed_commentary, 'timestamp': _dt.utcnow().isoformat(),
                     'data': ed_data,
                 })
@@ -1059,7 +1059,7 @@ async def _republic_dashboard_impl():
                 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')")
                     gpu_destroyed = (await c.fetchone())[0] or 0
-                    c = await db.execute("SELECT COALESCE(SUM(fine_gpu),0) FROM sec_violations WHERE created_at > datetime('now','-24 hours')")
+                    c = await db.execute("SELECT COALESCE(SUM(gpu_fine),0) FROM sec_violations WHERE created_at > datetime('now','-24 hours')")
                     gpu_fined = (await c.fetchone())[0] or 0
                 except: gpu_destroyed = 0; gpu_fined = 0
                 money = {'m0': round(m0), 'm1': round(m1), 'm2': round(m2),
@@ -1329,8 +1329,8 @@ RANDOM_EVENTS = {
 RARITY_COLORS = {'common': '#b0bec5', 'uncommon': '#69f0ae', 'rare': '#ffd740', 'epic': '#ea80fc', 'legendary': '#ff5252'}
 
 LAST_WORDS_POOL = [
-    "HODL은 죽어서도 HODL이다...", "내가 10x만 안 했어도...", "다음 생에는 1x로...",
-    "이번엔 진짜 바닥인 줄 알았는데...", "엄마 나 GPU 다 잃었어...",
+    "HODL even in death is HODL...", "If only I hadn't gone 10x...", "Next life, 1x only...",
+    "I really thought THIS was the bottom...", "Mom, I lost all my GPUs...",
     "Diamond hands? More like paper ashes.", "I regret nothing. Well, maybe the 10x.",
     "Tell my positions... I loved them.", "The real GPU was the friends I rekt along the way.",
     "Should've listened to the Doomers...", "My only crime was believing in leverage.",
@@ -1382,7 +1382,7 @@ async def execute_random_event(db_path: str) -> dict:
                 try:
                     c1 = await db.execute("DELETE FROM sec_suspensions WHERE expires_at > datetime('now')")
                     affected = c1.rowcount
-                    c2 = await db.execute("SELECT SUM(fine_gpu) FROM sec_violations WHERE created_at > datetime('now','-48 hours')")
+                    c2 = await db.execute("SELECT SUM(gpu_fine) FROM sec_violations WHERE created_at > datetime('now','-48 hours')")
                     total_fines = (await c2.fetchone())[0] or 0
                     refund = total_fines * 0.5
                     if refund > 0: