feat: P0 output relay — images, files, and long code back to Telegram

- adapters/claude.js: capture SDKUserMessage (tool result images),
  SDKFilesPersistedEvent, and Write/Edit file paths as new event types
- bridge.js: collect image/file events during streaming, send via
  replyWithPhoto/replyWithDocument before text result; long code blocks
  (>60% code, >4000 chars) sent as file attachment with preview
- progress.js: add screenshot tool icons

Closes the biggest UX gap: input was bidirectional but output was
text-only. Now CC screenshots, generated images, and created files
flow back to Telegram automatically.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: AliceLJY

adapters/claude.js

@@ -230,6 +230,10 @@ export function createAdapter(config = {}) {
                   };
                 }
               }
+              // 从 Write/Edit 输入提取文件路径
+              if ((block.name === "Write" || block.name === "Edit") && block.input?.file_path) {
+                yield { type: "file_written", filePath: block.input.file_path, tool: block.name };
+              }
               yield {
                 type: "progress",
                 toolName: block.name,
@@ -241,6 +245,43 @@ export function createAdapter(config = {}) {
           }
         }
 
+        // 捕获工具结果中的图片（SDKUserMessage）
+        if (msg.type === "user" && msg.parent_tool_use_id) {
+          const content = msg.message?.content;
+          if (Array.isArray(content)) {
+            for (const block of content) {
+              // tool_result 嵌套内容
+              if (block.type === "tool_result" && Array.isArray(block.content)) {
+                for (const part of block.content) {
+                  if (part.type === "image" && part.source?.data) {
+                    yield {
+                      type: "image",
+                      data: part.source.data,
+                      mediaType: part.source.media_type || "image/png",
+                      toolUseId: block.tool_use_id,
+                    };
+                  }
+                }
+              }
+              // 顶层 image block
+              if (block.type === "image" && block.source?.data) {
+                yield {
+                  type: "image",
+                  data: block.source.data,
+                  mediaType: block.source.media_type || "image/png",
+                };
+              }
+            }
+          }
+        }
+
+        // 捕获文件持久化事件
+        if (msg.type === "system" && msg.subtype === "files_persisted") {
+          for (const f of msg.files || []) {
+            yield { type: "file_persisted", filename: f.filename, fileId: f.file_id };
+          }
+        }
+
         if (msg.type === "result") {
           const resultText = msg.subtype === "success" ? (msg.result || "") : (msg.errors || []).join("\n");
           console.log(`[Claude SDK] result: subtype=${msg.subtype} cost=${msg.total_cost_usd} text=${resultText.slice(0, 200)}`);

bridge.js

@@ -1,9 +1,9 @@
 #!/usr/bin/env bun
 // Telegram → AI Bridge（多后端：Claude Agent SDK / Codex SDK）
 
-import { Bot, InlineKeyboard, GrammyError } from "grammy";
+import { Bot, InlineKeyboard, InputFile, GrammyError } from "grammy";
 import { HttpsProxyAgent } from "https-proxy-agent";
-import { mkdirSync, writeFileSync, readdirSync, statSync, unlinkSync } from "fs";
+import { mkdirSync, writeFileSync, readdirSync, statSync, unlinkSync, existsSync } from "fs";
 import { basename, join } from "path";
 import {
   getSession,
@@ -563,6 +563,19 @@ async function sendLong(ctx, text) {
   }
 }
 
+function estimateCodeRatio(text) {
+  const codeBlocks = text.match(/```[\s\S]*?```/g) || [];
+  const codeLen = codeBlocks.reduce((sum, b) => sum + b.length, 0);
+  return text.length > 0 ? codeLen / text.length : 0;
+}
+
+function detectCodeLang(text) {
+  const m = text.match(/```(\w+)/);
+  const lang = m?.[1]?.toLowerCase();
+  const map = { javascript: "js", typescript: "ts", python: "py", bash: "sh", shell: "sh", ruby: "rb" };
+  return map[lang] || lang || "txt";
+}
+
 function getSessionProjectLabel(sessionMeta, fallbackCwd = "") {
   const cwd = sessionMeta?.cwd || fallbackCwd || "";
   if (!cwd) return "";
@@ -921,6 +934,8 @@ async function processPrompt(ctx, prompt) {
     let capturedSessionId = sessionId || null;
     let resultText = "";
     let resultSuccess = true;
+    const capturedImages = [];  // { data, mediaType, toolUseId }
+    const capturedFiles = [];   // { filePath, source }
 
     // 软看门狗：只打日志，不 abort（TG 发出去的消息无法撤回）
     const startTime = Date.now();
@@ -969,6 +984,17 @@ async function processPrompt(ctx, prompt) {
           });
         }
 
+        // 收集图片/文件事件
+        if (event.type === "image" && capturedImages.length < 10) {
+          capturedImages.push(event);
+        }
+        if (event.type === "file_persisted") {
+          capturedFiles.push({ filePath: event.filename, source: "persisted" });
+        }
+        if (event.type === "file_written") {
+          capturedFiles.push({ filePath: event.filePath, source: event.tool });
+        }
+
         // 实时进度（progress + text 事件）
         idleMonitor.heartbeat(chatId);
         progress.processEvent(event);
@@ -1004,6 +1030,43 @@ async function processPrompt(ctx, prompt) {
       durationMs: Date.now() - startTime,
     });
 
+    // 发送捕获的图片（在文字结果之前）
+    if (resultSuccess && capturedImages.length > 0) {
+      for (const img of capturedImages) {
+        try {
+          const buf = Buffer.from(img.data, "base64");
+          if (buf.length > 10 * 1024 * 1024) continue; // TG sendPhoto 限 10MB
+          const ext = (img.mediaType || "image/png").split("/")[1] || "png";
+          await ctx.replyWithPhoto(new InputFile(buf, `output.${ext}`));
+        } catch (e) {
+          console.error(`[Bridge] sendPhoto failed: ${e.message}`);
+        }
+      }
+    }
+
+    // 发送捕获的文件（图片/文档类）
+    if (resultSuccess && capturedFiles.length > 0) {
+      const IMAGE_EXTS = new Set([".png", ".jpg", ".jpeg", ".gif", ".webp"]);
+      const DOC_EXTS = new Set([".pdf", ".docx", ".xlsx", ".csv", ".html"]);
+      const sentPaths = new Set();
+      for (const f of capturedFiles) {
+        if (!f.filePath || sentPaths.has(f.filePath)) continue;
+        const ext = f.filePath.slice(f.filePath.lastIndexOf(".")).toLowerCase();
+        if (!IMAGE_EXTS.has(ext) && !DOC_EXTS.has(ext)) continue;
+        if (!existsSync(f.filePath)) continue;
+        sentPaths.add(f.filePath);
+        try {
+          if (IMAGE_EXTS.has(ext)) {
+            await ctx.replyWithPhoto(new InputFile(f.filePath));
+          } else {
+            await ctx.replyWithDocument(new InputFile(f.filePath));
+          }
+        } catch (e) {
+          console.error(`[Bridge] sendFile failed (${basename(f.filePath)}): ${e.message}`);
+        }
+      }
+    }
+
     // 发最终结果
     if (!resultSuccess) {
       finalizeFailure(summarizeText(resultText, 240), "RESULT_ERROR");
@@ -1014,11 +1077,16 @@ async function processPrompt(ctx, prompt) {
       if (replies && resultText.length <= 4000) {
         const kb = new InlineKeyboard();
         for (const r of replies) {
-          // TG callback_data 限 64 字节，"reply:" 占 6 字节，剩 58 给内容
           const cbData = `reply:${r.slice(0, 58)}`;
           kb.text(r, cbData);
         }
         await ctx.reply(resultText, { reply_markup: kb });
+      } else if (resultText.length > 4000 && estimateCodeRatio(resultText) > 0.6) {
+        // 长代码输出 → 文件附件 + 摘要
+        const ext = detectCodeLang(resultText) || "txt";
+        await ctx.replyWithDocument(new InputFile(Buffer.from(resultText, "utf-8"), `output.${ext}`));
+        const preview = resultText.slice(0, 300).replace(/```\w*\n?/, "");
+        await ctx.reply(`${preview}\n\n📎 完整输出 (${resultText.length} 字符) 见附件`);
       } else {
         await sendLong(ctx, resultText);
       }

progress.js

@@ -19,6 +19,11 @@ const TOOL_ICONS = {
   TaskList: "📋",
   TaskGet: "📋",
   AskUserQuestion: "❓",
+  take_screenshot: "📸",
+  "mcp__computer-use__screenshot": "📸",
+  "mcp__peekaboo__see": "👁️",
+  "mcp__chrome-devtools__take_screenshot": "📸",
+  "mcp__chrome-devtools__take_snapshot": "📸",
 };
 
 const SILENT_TOOLS = new Set([