Update app.py

app.py

@@ -1,3 +1,14 @@
+# 核心问题
+
+`bot.run()` 内部调用 `asyncio.run()`，它会注册**信号处理器**——这在子线程中会抛出 `ValueError: signal only works in main thread`，线程直接静默崩溃。
+
+日志里你看到**零条** Bot 输出就是证据。
+
+---
+
+以下是完整修复后的 `app.py`，可以直接覆盖：
+
+```python
 import discord
 from discord.ext import commands, tasks
 from google import genai
@@ -33,9 +44,6 @@ logger = logging.getLogger("BK_GTA_ARCHITECT_TITAN")
 # 1. 物理层：Gradio 哨兵与探针 (Gradio Sentinel)
 # ==============================================================================
 def get_status():
-    """
-    提供给外部（如 UptimeRobot/Cron-Job）的心跳对账数据
-    """
     now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
     bot_status = "OFFLINE"
     latency = "N/A"
@@ -45,7 +53,7 @@ def get_status():
             latency = f"{round(bot.latency * 1000, 2)}ms"
     except Exception as e:
         logger.error(f"Status check failed: {e}")
-    
+
     return {
         "status": "BK-GTA-TITAN-ACTIVE",
         "logic_integrity": "100%",
@@ -63,7 +71,6 @@ def get_status():
 DISCORD_TOKEN = os.environ.get('DISCORD_TOKEN', '').strip()
 SESSION_ID = random.randint(10000, 99999)
 
-# [CORE] 8 密钥轮询加载器
 raw_keys = os.environ.get('GEMINI_KEYS_POOL', '')
 KEY_POOL = [k.strip() for k in raw_keys.split(',') if k.strip()]
 if not KEY_POOL:
@@ -73,30 +80,24 @@ if not KEY_POOL:
 if not KEY_POOL:
     logger.critical("❌ [CRITICAL] NO API KEYS FOUND! Please set GEMINI_KEYS_POOL.")
 
-# 权限位设置
 intents = discord.Intents.default()
 intents.message_content = True
 intents.members = True
 bot = commands.Bot(command_prefix='!', intents=intents)
 
-# 并发审计锁
 audit_lock = asyncio.Lock()
-# 优先使用持久化目录 /data
 DB_PATH = '/data/bk_gta_v62_unified.json' if os.path.exists('/data') else 'bk_gta_v62_unified.json'
 
 # ==============================================================================
 # 3. 状态引擎 (BKEngine Core)
 # ==============================================================================
 class BKEngine:
-    """
-    负责量化资产的持久化、ELO 计算及风险对账
-    """
     def __init__(self):
         self.db_file = DB_PATH
         self.data = self._load_db()
         self.pending_challenges = {}
         self.active_duels = {}
-        self.active_bets = {} 
+        self.active_bets = {}
 
     def _load_db(self):
         if os.path.exists(self.db_file):
@@ -105,7 +106,7 @@ class BKEngine:
                     content = json.load(f)
                     if "users" not in content: content["users"] = {}
                     return content
-            except Exception as e: 
+            except Exception as e:
                 logger.error(f"DB Load Failure: {e}")
                 return self._init_schema()
         return self._init_schema()
@@ -115,7 +116,7 @@ class BKEngine:
             "version": "62.9-Titan",
             "users": {},
             "factions": {
-                "BULLS": {"score": 0, "emoji": "🐂", "wins": 0}, 
+                "BULLS": {"score": 0, "emoji": "🐂", "wins": 0},
                 "BEARS": {"score": 0, "emoji": "🐻", "wins": 0}
             },
             "prize_pool": 1000000.0,
@@ -152,7 +153,6 @@ class BKEngine:
         if mdd is not None: u["mdd_record"] = mdd
         if sharpe is not None: u["sharpe_record"] = sharpe
         u["points"] += 50
-        # 记录最近 5 次审计历史
         u["audit_history"].append({"s": score, "t": str(datetime.datetime.now())})
         u["audit_history"] = u["audit_history"][-5:]
         u["last_active"] = str(datetime.datetime.now())
@@ -163,17 +163,13 @@ class BKEngine:
         K = 32
         Rw, Rl = w["elo"], l["elo"]
         Ew = 1 / (1 + 10 ** ((Rl - Rw) / 400))
-        
         w["elo"] = round(Rw + K * (1 - Ew))
         l["elo"] = round(Rl + K * (0 - Ew))
-        
         w["win_streak"] += 1
         l["win_streak"] = 0
-        
         if w["faction"] and w["faction"] in self.data["factions"]:
             self.data["factions"][w["faction"]]["score"] += 15
             self.data["factions"][w["faction"]]["wins"] += 1
-        
         self.save_db()
         return w["elo"], l["elo"], w["win_streak"]
 
@@ -185,7 +181,7 @@ bk_engine = BKEngine()
 def safe_extract_float(text, key):
     try:
         patterns = [
-            rf"{key}:\s*([-+]?\d*\.?\d+)", 
+            rf"{key}:\s*([-+]?\d*\.?\d+)",
             rf"{key}\s*=\s*([-+]?\d*\.?\d+)",
             rf"【{key}】\s*([-+]?\d*\.?\d+)"
         ]
@@ -205,11 +201,8 @@ def safe_extract_text(text, start, end=None):
     except: return "N/A"
 
 async def call_gemini(prompt, attachment=None):
-    """
-    [Core Logic] 8 密钥池高频轮询与故障自动迁移
-    """
     if not KEY_POOL: return "ERROR: NO_KEYS"
-    
+
     img_data = None
     if attachment:
         try: img_data = await attachment.read()
@@ -227,7 +220,7 @@ async def call_gemini(prompt, attachment=None):
                 contents.append(types.Part.from_bytes(data=img_data, mime_type='image/png'))
 
             response = await loop.run_in_executor(
-                None, 
+                None,
                 functools.partial(client.models.generate_content, model="gemini-1.5-flash", contents=contents)
             )
             if response and response.text:
@@ -249,8 +242,7 @@ async def profile(ctx, member: discord.Member = None):
     t = member or ctx.author
     u = bk_engine.get_user(t.id)
     elo = u['elo']
-    
-    # 动态段位
+
     if elo < 1300: rank, color = "Iron 学徒 🗑️", 0x717d7e
     elif elo < 1500: rank, color = "Bronze 资深 🥉", 0xcd7f32
     elif elo < 1800: rank, color = "Silver 精英 🥈", 0xbdc3c7
@@ -261,7 +253,7 @@ async def profile(ctx, member: discord.Member = None):
     emb = discord.Embed(title=f"📊 Quant Profile: {t.display_name}", color=color)
     emb.add_field(name="Rating (ELO)", value=f"**{elo}** ({rank})", inline=True)
     emb.add_field(name="Assets", value=f"💰 **{u['points']}**", inline=True)
-    
+
     f_info = u['faction'] or "Free Agent"
     f_emoji = bk_engine.data["factions"].get(f_info, {}).get("emoji", "🌐")
     emb.add_field(name="Faction", value=f"{f_emoji} {f_info}", inline=True)
@@ -272,7 +264,7 @@ async def profile(ctx, member: discord.Member = None):
         f"Max MDD: {u.get('mdd_record',0):.2f}%"
     )
     emb.add_field(name="Institutional Metrics", value=f"```yaml\n{stats}\n```", inline=False)
-    
+
     if target_avatar := t.avatar:
         emb.set_thumbnail(url=target_avatar.url)
     emb.set_footer(text=f"Node: HuggingFace Titan | Session: {SESSION_ID}")
@@ -283,21 +275,21 @@ async def leaderboard(ctx):
     all_users = []
     for uid, d in bk_engine.data["users"].items():
         all_users.append({"id": uid, "elo": d["elo"], "score": d["highest_score"]})
-    
+
     top = sorted(all_users, key=lambda x: x["elo"], reverse=True)[:10]
     desc = ""
     for idx, u in enumerate(top):
         icon = ["🥇","🥈","🥉"][idx] if idx < 3 else f"{idx+1}."
         desc += f"{icon} <@{u['id']}> : **{u['elo']}** (Peak: {u['score']:.1f})\n"
-    
+
     emb = discord.Embed(title="🏆 BK-GTA Institutional Leaderboard", description=desc or "No data.", color=0xf1c40f)
-    
+
     f_info = ""
     for k, v in bk_engine.data["factions"].items():
         f_info += f"{v['emoji']} {k}: {v['score']} pts  "
     if f_info:
         emb.add_field(name="⚔️ Faction War", value=f_info, inline=False)
-        
+
     await ctx.send(embed=emb)
 
 # ==============================================================================
@@ -307,7 +299,7 @@ async def leaderboard(ctx):
 async def news(ctx):
     if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传情报截图。")
     m = await ctx.send("📡 **[Sentinel] Analyzing Macro Pulse...**")
-    
+
     prompt = (
         "你是一名顶级对冲基金策略师。请解析截图内容：\n"
         "1. 评分 (SCORE): -10 (极大利空) 到 +10 (极大利多)。\n"
@@ -316,17 +308,17 @@ async def news(ctx):
         "格式必须为：\nSCORE: [v]\nSUMMARY: [v]\nTAKE: [v]"
     )
     res = await call_gemini(prompt, ctx.message.attachments[0])
-    
+
     score = safe_extract_float(res, "SCORE")
     summary = safe_extract_text(res, "SUMMARY", "TAKE")
     take = safe_extract_text(res, "TAKE")
-    
+
     color = 0x2ecc71 if score > 0 else 0xe74c3c if score < 0 else 0xbdc3c7
     emb = discord.Embed(title="📰 Macro Intelligence Analysis", color=color)
     emb.add_field(name="Sentiment Score", value=f"**{score:+.1f} / 10**", inline=True)
     emb.add_field(name="Core Catalyst", value=summary, inline=False)
     emb.add_field(name="Institutional View", value=f"```\n{take}\n```", inline=False)
-    
+
     await m.delete()
     await ctx.send(embed=emb)
 
@@ -336,7 +328,7 @@ async def news(ctx):
 @bot.command()
 async def evaluate(ctx):
     if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传回测或结算截图。")
-    
+
     if audit_lock.locked():
         return await ctx.send("⚠️ **[System Busy]** 正在处理另一项审计，请稍后。")
 
@@ -349,9 +341,9 @@ async def evaluate(ctx):
             "H_ZH: 中文核心优势或致命风险概括。\n"
             "格式：\nRET: [v]\nMDD: [v]\nPF: [v]\nSHARPE: [v]\nTRADES: [v]\nS_BASE: [v]\nVIOLATION: [TRUE/FALSE]\nH_ZH: [v]"
         )
-        
+
         res = await call_gemini(prompt, ctx.message.attachments[0])
-        
+
         if "ERROR" in res:
             await m.delete()
             return await ctx.send("🔴 [Audit Crash] 引擎请求失败。")
@@ -363,13 +355,11 @@ async def evaluate(ctx):
         s_base = safe_extract_float(res, "S_BASE")
         violation = "TRUE" in res.upper()
 
-        # 风控核心：MDD 否决制
         if violation or mdd > 35.0:
             s_final = 0.0
             status = "❌ REJECTED (High Risk)"
             color = 0xe74c3c
         else:
-            # 复合评分逻辑：基础分 * 样本权重 * 风险权重
             weight_sample = math.log10(max(trades, 1)) / 1.5
             weight_risk = (sharpe / 2.0) if sharpe > 0 else 0.5
             s_final = min(max(s_base * weight_sample * weight_risk, 0.0), 100.0)
@@ -378,14 +368,14 @@ async def evaluate(ctx):
 
         bk_engine.update_audit(ctx.author.id, s_final, mdd, sharpe)
         highlights = safe_extract_text(res, "H_ZH")
-        
+
         emb = discord.Embed(title="🛡️ Quantitative Audit Report", color=color)
         emb.add_field(name="Verdict", value=f"**{status}**", inline=False)
         metrics = f"Return: {ret}% | MDD: {mdd}%\nSharpe: {sharpe} | Trades: {trades}"
         emb.add_field(name="Key Metrics", value=f"```\n{metrics}\n```", inline=False)
         emb.add_field(name="Logic Score", value=f"**{s_final:.2f} / 100**", inline=True)
         emb.add_field(name="Highlights", value=highlights, inline=False)
-        
+
         await m.delete()
         await ctx.send(embed=emb)
 
@@ -397,7 +387,7 @@ async def evaluate(ctx):
 async def open_bet(ctx, *, topic):
     bid = str(random.randint(100, 999))
     bk_engine.active_bets[bid] = {
-        "topic": topic, "up": 0, "down": 0, 
+        "topic": topic, "up": 0, "down": 0,
         "u_up": {}, "u_down": {}, "status": "OPEN",
         "time": str(datetime.datetime.now())
     }
@@ -407,20 +397,20 @@ async def open_bet(ctx, *, topic):
 async def bet(ctx, bid: str, side: str, amt: int):
     if bid not in bk_engine.active_bets or bk_engine.active_bets[bid]["status"] != "OPEN":
         return await ctx.send("❌ 盘口不存在或已关闭。")
-    
+
     u = bk_engine.get_user(ctx.author.id)
     if u["points"] < amt or amt <= 0:
         return await ctx.send("❌ 资产点数不足。")
-    
+
     side = side.upper()
     if side not in ["UP", "DOWN"]: return await ctx.send("❌ 必须选择 UP 或 DOWN。")
-    
+
     u["points"] -= amt
     b = bk_engine.active_bets[bid]
     pool = "u_up" if side == "UP" else "u_down"
     b[side.lower()] += amt
     b[pool][str(ctx.author.id)] = b[pool].get(str(ctx.author.id), 0) + amt
-    
+
     bk_engine.save_db()
     await ctx.send(f"✅ 已确认：{ctx.author.name} 向 {side} 注入 {amt} 点资产。")
 
@@ -430,16 +420,16 @@ async def settle_bet(ctx, bid: str, winner: str):
     if bid not in bk_engine.active_bets: return
     b = bk_engine.active_bets[bid]
     winner = winner.upper()
-    
+
     win_pool = b["u_up"] if winner == "UP" else b["u_down"]
     total_w = b["up"] if winner == "UP" else b["down"]
     total_l = b["down"] if winner == "UP" else b["up"]
-    
+
     if total_w > 0:
         for uid, amt in win_pool.items():
             profit = (amt / total_w) * total_l
             bk_engine.get_user(int(uid))["points"] += int(amt + profit)
-    
+
     b["status"] = "SETTLED"
     bk_engine.save_db()
     await ctx.send(f"🏁 盘口 {bid} 已结算！胜利方：**{winner}**。资产已自动划转。")
@@ -458,11 +448,11 @@ async def challenge(ctx, member: discord.Member):
 async def accept(ctx):
     if ctx.author.id not in bk_engine.pending_challenges:
         return await ctx.send("❌ 没有待处理的决斗请求。")
-    
+
     req = bk_engine.pending_challenges.pop(ctx.author.id)
     did = req["id"]
     bk_engine.active_duels[did] = {
-        "p1": req["challenger"], "p2": ctx.author.id, 
+        "p1": req["challenger"], "p2": ctx.author.id,
         "s1": None, "s2": None, "t": str(datetime.datetime.now())
     }
     await ctx.send(f"🔥 **竞技场锁定！** 决斗 ID: `{did}`\n请双方通过 `!duel_submit {did}` 提交审计截图。")
@@ -471,23 +461,23 @@ async def accept(ctx):
 async def duel_submit(ctx, did: str):
     if did not in bk_engine.active_duels: return
     if not ctx.message.attachments: return
-    
+
     duel = bk_engine.active_duels[did]
     if ctx.author.id not in [duel["p1"], duel["p2"]]: return
-    
+
     m = await ctx.send("🔍 正在审计决斗数据...")
     res = await call_gemini("Extract SCORE:[0-100]. Format: SCORE:[v]", ctx.message.attachments[0])
     score = safe_extract_float(res, "SCORE")
-    
+
     if ctx.author.id == duel["p1"]: duel["s1"] = score
     else: duel["s2"] = score
-    
+
     if duel["s1"] is not None and duel["s2"] is not None:
         p1, p2 = duel["p1"], duel["p2"]
         s1, s2 = duel["s1"], duel["s2"]
         wid, lid = (p1, p2) if s1 > s2 else (p2, p1)
         w_elo, l_elo, streak = bk_engine.update_elo(wid, lid)
-        
+
         emb = discord.Embed(title="🏆 Duel Arena Verdict", color=0xf1c40f)
         emb.add_field(name="Winner", value=f"<@{wid}>\nScore: {max(s1,s2)}\nELO: {w_elo}", inline=True)
         emb.add_field(name="Loser", value=f"<@{lid}>\nScore: {min(s1,s2)}\nELO: {l_elo}", inline=True)
@@ -503,31 +493,24 @@ async def duel_submit(ctx, did: str):
 # ==============================================================================
 @bot.command()
 async def viral_audit(ctx):
-    """
-    [完全版] 提取审计数据并渲染具备像素级视觉逻辑的海报
-    """
     if not ctx.message.attachments: return
     m = await ctx.send("🎨 **[GPU-Node] 正在渲染视觉海报...**")
-    
+
     p = "Extract RET: [v] and SHARPE: [v]. Format: RET: [v] SHARPE: [v]"
     res = await call_gemini(p, ctx.message.attachments[0])
     ret, sharpe = safe_extract_float(res, "RET"), safe_extract_float(res, "SHARPE")
 
     try:
         W, H = 600, 800
-        # 暗色底板
         base = Image.new('RGB', (W, H), (18, 20, 30))
         draw = ImageDraw.Draw(base)
 
-        # 绘制背景装饰网格 (逻辑恢复)
         for i in range(0, W, 40): draw.line([(i, 0), (i, H)], fill=(30, 35, 45), width=1)
         for j in range(0, H, 40): draw.line([(0, j), (W, j)], fill=(30, 35, 45), width=1)
-        
-        # 边框
+
         draw.rectangle([10, 10, 590, 790], outline=(46, 204, 113), width=2)
         draw.rectangle([20, 20, 580, 780], outline=(46, 204, 113), width=5)
 
-        # 文字渲染
         draw.text((40, 60), "BK-GTA QUANTITATIVE SYSTEM", fill=(255, 255, 255))
         draw.text((40, 150), f"TRADER: {ctx.author.name.upper()}", fill=(46, 204, 113))
         draw.text((40, 260), f"ALPHA RET: +{ret}%", fill=(255, 255, 255))
@@ -559,7 +542,7 @@ async def on_ready():
         auto_backup.start()
     await bot.change_presence(
         activity=discord.Activity(
-            type=discord.ActivityType.watching, 
+            type=discord.ActivityType.watching,
             name="HuggingFace Node"
         )
     )
@@ -573,40 +556,81 @@ async def on_disconnect():
 async def on_resumed():
     logger.info("✅ [Gateway] Session resumed successfully.")
 
-
+# ==============================================================================
+# 12. 启动入口 — 关键修复区域
+# ==============================================================================
 def run_bot():
     """
-    [修复] 不再使用 while True 循环。
-    discord.py 内置自动重连机制 (reconnect=True 是默认值)，
-    无需手动重启。bot.run() 只能调用一次。
+    [核心修复] bot.run() 内部调用 asyncio.run()，会注册信号处理器，
+    但信号处理器只能在主线程注册。在子线程中必须：
+      1. 手动创建事件循环 asyncio.new_event_loop()
+      2. 使用 bot.start()（协程版本）而非 bot.run()
     """
     if not DISCORD_TOKEN:
-        logger.critical("❌ [FATAL] DISCORD_TOKEN Missing.")
+        logger.critical("❌ [FATAL] DISCORD_TOKEN is missing! Set it in HuggingFace Secrets.")
         return
-    
+
+    logger.info("🚀 [Bot Thread] Initializing Discord connection...")
+
+    # ====== 关键：为子线程创建专属事件循环 ======
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+
     try:
-        bot.run(DISCORD_TOKEN, reconnect=True)
+        # bot.start() 是纯协程，不会触发信号注册
+        loop.run_until_complete(bot.start(DISCORD_TOKEN, reconnect=True))
     except discord.LoginFailure:
-        logger.critical("❌ [FATAL] Invalid DISCORD_TOKEN! Check your token.")
+        logger.critical(
+            "❌ [FATAL] DISCORD_TOKEN is invalid!\n"
+            "Go to https://discord.com/developers/applications → Bot → Reset Token"
+        )
     except discord.PrivilegedIntentsRequired:
         logger.critical(
             "❌ [FATAL] Privileged Intents not enabled!\n"
-            "Go to https://discord.com/developers/applications → Your Bot → Bot tab\n"
-            "→ Enable 'SERVER MEMBERS INTENT' and 'MESSAGE CONTENT INTENT'"
+            "Go to Discord Developer Portal → Bot tab →\n"
+            "Enable 'SERVER MEMBERS INTENT' and 'MESSAGE CONTENT INTENT'"
         )
     except Exception as e:
-        logger.error(f"⚠️ [Fatal Error] Bot terminated: {e}")
+        logger.error(f"❌ [Bot Fatal Error] {e}")
         traceback.print_exc()
+    finally:
+        logger.warning("🔴 [Bot Thread] Event loop ending, cleaning up...")
+        try:
+            # 清理所有未完成的任务
+            pending = asyncio.all_tasks(loop)
+            for task in pending:
+                task.cancel()
+            # 等待取消完成
+            if pending:
+                loop.run_until_complete(asyncio.gather(*pending, return_exceptions=True))
+            if not bot.is_closed():
+                loop.run_until_complete(bot.close())
+        except Exception as cleanup_err:
+            logger.error(f"Cleanup error: {cleanup_err}")
+        finally:
+            loop.close()
+        logger.error("🔴 [Bot Thread] Discord bot has stopped.")
 
 
 if __name__ == "__main__":
-    # 1. 启动 Discord 后台线程
-    threading.Thread(target=run_bot, daemon=True).start()
-    
-    # 2. 给 bot 一点启动时间，避免 get_status 立即报错
+    logger.info("=" * 60)
+    logger.info("  BK-GTA V62.9-Titan Starting...")
+    logger.info(f"  Token present: {'YES' if DISCORD_TOKEN else 'NO (!!)'}")
+    logger.info(f"  Token length:  {len(DISCORD_TOKEN)} chars")
+    logger.info(f"  Gemini keys:   {len(KEY_POOL)}")
+    logger.info(f"  DB path:       {DB_PATH}")
+    logger.info("=" * 60)
+
+    # 1. 启动 Discord Bot 后台线程
+    bot_thread = threading.Thread(target=run_bot, daemon=True)
+    bot_thread.start()
+    logger.info("📡 [Main] Bot thread launched.")
+
+    # 2. 给 bot 线程一点启动时间
     time.sleep(3)
-    
-    # 3. 启动 Gradio 前台哨兵
+
+    # 3. 启动 Gradio 前台哨兵 (占据主线程)
+    logger.info("📡 [Main] Starting Gradio on port 7860...")
     iface = gr.Interface(
         fn=get_status,
         inputs=None,
@@ -614,4 +638,23 @@ if __name__ == "__main__":
         title="BK-GTA Sentinel AI",
         description="Physical architecture monitor. Logic Integrity: Secure."
     )
-    iface.launch(server_name="0.0.0.0", server_port=7860)
+    iface.launch(server_name="0.0.0.0", server_port=7860)
+```
+
+---
+
+## 改了什么（只有第 12 节不同）
+
+| 旧代码（崩溃） | 新代码（修复） |
+|---|---|
+| `bot.run(DISCORD_TOKEN)` | `loop.run_until_complete(bot.start(DISCORD_TOKEN))` |
+| 无事件循环管理 | `asyncio.new_event_loop()` + `asyncio.set_event_loop(loop)` |
+| 无启动诊断 | 启动时打印 Token 长度、密钥数、DB 路径 |
+| 无 cleanup | `finally` 中取消任务 + 关闭 bot + 关闭 loop |
+
+**核心一行修复：**
+```python
+# ❌ 旧：子线程中会因信号注册崩溃
+bot.run(DISCORD_TOKEN, reconnect=True)
+
+# ✅ 新：纯协程，不注册信号，子