發佈 0.1.11：連線中斷自動重試，已生成的圖不再丟失

根本原因：
imagegen 產圖成功後，模型把含圖結果串流回來時 OpenAI 端偶發切斷
WebSocket（stream disconnected / websocket closed），codex 回報 turn.failed，
bot 視為致命錯誤，連已生好的圖一起丟掉，使用者只看到錯誤。

修法：
1. codex.js 失敗時附帶 threadId 與 transient 旗標（辨識暫時性連線錯誤）。
2. bot.js 改為重試迴圈：暫時性錯誤時，若本輪 generated_images 已有產圖，
   直接交付並註明「連線中斷但圖已生成」，不重跑（避免重複生圖）；
   沒產出才 resume 同一會話重試一次，狀態訊息顯示「自動重試中」。
   會話失效／換模型的自動開新會話邏輯併入同一迴圈。

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

package.json

@@ -1,6 +1,6 @@
 {
   "name": "telegram-codex-bot",
-  "version": "0.1.9",
+  "version": "0.1.11",
   "description": "Telegram bot powered by the local Codex CLI — zero-dependency, pm2-managed, with a built-in PM2 web viewer",
   "license": "MIT",
   "type": "commonjs",

src/bot.js

@@ -111,14 +111,21 @@ function startBot(config) {
 
   function shouldRespond(message) {
     if (message.chat.type === 'private') return true;
-    if (message.reply_to_message?.from?.id === botId) return true;
     const text = message.text || message.caption || '';
     const entities = message.entities || message.caption_entities || [];
-    return entities.some((e) =>
+    // 訊息中所有被 tag 的 bot（Telegram bot username 一定以 bot 結尾；
-      (e.type === 'mention' &&
+    // tag 到一般使用者不算，不影響回覆觸發）
-        text.slice(e.offset, e.offset + e.length).toLowerCase() === `@${botUsername.toLowerCase()}`) ||
+    const botMentions = entities
-      (e.type === 'text_mention' && e.user?.id === botId)
+      .filter((e) => e.type === 'mention')
-    );
+      .map((e) => text.slice(e.offset + 1, e.offset + e.length))
+      .filter((u) => /bot$/i.test(u));
+    if (botMentions.length > 0) {
+      // 有明確 tag 時以 tag 為準：只有第一個被 tag 的 bot 回應。
+      // 就算這則訊息是回覆我的（例如回覆我的訊息但 tag 別的 bot），我也讓位。
+      return botMentions[0].toLowerCase() === botUsername.toLowerCase();
+    }
+    if (message.reply_to_message?.from?.id === botId) return true;
+    return entities.some((e) => e.type === 'text_mention' && e.user?.id === botId);
   }
 
   function stripMention(text) {
@@ -315,21 +322,44 @@ function startBot(config) {
 
       let result;
       let sessionResetNote = '';
-      try {
+      let tid = existing?.threadId || null;
-        result = await runCodex({ config, prompt, threadId: existing?.threadId || null, images, onProgress });
+      const MAX_ATTEMPTS = 2;
-      } catch (err) {
+      for (let attempt = 1; ; attempt++) {
-        // 舊會話 resume 不了的情況，自動開新會話重試一次：
+        try {
-        // 1) 會話已被 codex 清掉（not found）
+          result = await runCodex({ config, prompt, threadId: tid, images, onProgress });
-        // 2) bot 換了模型，codex 拒絕跨模型 resume（recorded with model X but resuming with Y）
+          break;
-        const sessionGone = /session|thread|conversation/i.test(err.message) && /not.*found|找不到|no .*(session|thread)/i.test(err.message);
+        } catch (err) {
-        const modelMismatch = /recorded with model/i.test(err.message);
+          // 舊會話 resume 不了：1) 會話已被 codex 清掉  2) 換模型後 codex 拒絕跨模型 resume
-        if (existing && (sessionGone || modelMismatch)) {
+          // → 清掉會話、開新會話重跑（tid=null 之後不會再進這個分支，不會無限迴圈）
-          sessions.clear(sessionKey);
+          const sessionGone = /session|thread|conversation/i.test(err.message) && /not.*found|找不到|no .*(session|thread)/i.test(err.message);
-          result = await runCodex({ config, prompt, threadId: null, images, onProgress });
+          const modelMismatch = /recorded with model/i.test(err.message);
-          sessionResetNote = modelMismatch
+          if (tid && (sessionGone || modelMismatch)) {
-            ? '🆕 模型設定已變更，舊會話無法沿用，已自動開新會話（先前的對話記憶未帶入）。\n\n'
+            sessions.clear(sessionKey);
-            : '🆕 舊會話已失效，已自動開新會話。\n\n';
+            tid = null;
-        } else {
+            sessionResetNote = modelMismatch
+              ? '🆕 模型設定已變更，舊會話無法沿用，已自動開新會話（先前的對話記憶未帶入）。\n\n'
+              : '🆕 舊會話已失效，已自動開新會話。\n\n';
+            continue;
+          }
+          // 暫時性連線中斷（OpenAI 端切斷串流等）
+          if (err.transient) {
+            if (err.threadId) tid = err.threadId;
+            if (tid) sessions.set(sessionKey, tid); // 會話已建立，先記下來以便 resume
+            // 中斷前若圖已生成，直接交付，不重跑（避免重複生圖、多花時間）
+            if (collectGeneratedImages(tid, turnStart).length > 0) {
+              result = { text: '（回覆文字因連線中斷遺失，圖片如下）', threadId: tid, usage: null };
+              sessionResetNote += '⚠️ 連線在回覆途中中斷，但圖片已生成完畢，直接送上。\n\n';
+              break;
+            }
+            if (attempt < MAX_ATTEMPTS) {
+              await t.tg('editMessageText', {
+                chat_id: chatId,
+                message_id: statusMsg.message_id,
+                text: `⚠️ 連線中斷，自動重試中（${attempt + 1}/${MAX_ATTEMPTS}）…`,
+              }).catch(() => {});
+              continue;
+            }
+          }
           throw err;
         }
       }

src/codex.js

@@ -198,7 +198,11 @@ function runCodex({ config, prompt, threadId, images = [], onProgress }) {
     proc.on('close', (code) => {
       clearTimeout(timer);
       if (turnFailedMessage) {
-        return reject(new Error(`Codex 執行失敗：${turnFailedMessage}`));
+        const e = new Error(`Codex 執行失敗：${turnFailedMessage}`);
+        e.threadId = resultThreadId; // 會話可能已建立，讓呼叫端能 resume 重試
+        // 暫時性連線問題（OpenAI 端切斷串流等），呼叫端可重試
+        e.transient = /stream disconnected|websocket closed|Falling back from WebSockets|connection reset|ECONNRESET|socket hang up|timed out/i.test(turnFailedMessage);
+        return reject(e);
       }
       if (turnCompleted || messages.length > 0) {
         return resolve({ text: messages.join('\n\n'), threadId: resultThreadId, usage });