feat: Telegram Bridge 出站消息 Markdown 渲染

新增三层 Markdown → Telegram HTML 渲染管线：

markdown/ir.ts — markdown-it 解析 Markdown 为中间表示 (MarkdownIR)
  - 支持 bold/italic/strikethrough/code/code_block/blockquote/links/lists/headings/tables/hr
  - 表格使用 code-block 模式渲染为 ASCII 表格（<pre> 保留对齐）
  - HTML 内联 <br> 标签转换为换行符

markdown/render.ts — 通用标记渲染器
  - boundary tracking + LIFO stack 处理嵌套样式

markdown/telegram.ts — Telegram 专用渲染器
  - 样式映射到 Telegram HTML 标签 (b/i/s/code/pre+code/blockquote/a)
  - 文件引用保护：README.md/main.go 等不被误识别为 URL
  - render-first 分片：按渲染后 HTML 长度分片，超限时按比例重分割

delivery-layer.ts — 新增 deliverRendered() 接收预渲染 chunks
  - HTML + plain text 双通道，解析失败自动降级纯文本
  - sendWithRetry 支持 plainFallback 参数

bridge-manager.ts — Claude 回复改用 markdownToTelegramChunks + deliverRendered
  - 命令响应和错误消息保持 escapeHtml + deliver

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: 7418

docs/handover/bridge-system.md

@@ -15,6 +15,10 @@ src/lib/bridge/
 ├── permission-broker.ts     # 权限请求转发到 IM 内联按钮，处理回调审批
 ├── delivery-layer.ts        # 出站消息分片、限流、重试退避、HTML 降级
 ├── bridge-manager.ts        # 生命周期编排，adapter 事件循环，/stop abort，命令路由
+├── markdown/
+│   ├── ir.ts                # Markdown → IR 中间表示解析器（基于 markdown-it）
+│   ├── render.ts            # IR → 格式化输出的通用标记渲染器
+│   └── telegram.ts          # Telegram HTML 渲染 + 文件引用保护 + render-first 分片
 ├── adapters/
 │   ├── index.ts             # Adapter 目录文件（side-effect import 自注册所有 adapter）
 │   ├── telegram-adapter.ts  # Telegram 长轮询 + offset 安全水位 + 图片/相册处理 + 自注册
@@ -43,7 +47,8 @@ Telegram 消息 → TelegramAdapter.pollLoop()
           → text/tool_use/tool_result → 累积内容块
           → result → 捕获 tokenUsage + sdkSessionId
         → addMessage() 保存到 DB
-      → DeliveryLayer.deliver() → 分片 + 限流 + 发送到 Telegram
+      → markdownToTelegramChunks() → Markdown→IR→HTML render-first 分片
+      → DeliveryLayer.deliverRendered() → 限流 + HTML/plain 双通道发送到 Telegram
     → finally: adapter.acknowledgeUpdate(updateId) → 推进 committedOffset 并持久化
 ```
 
@@ -93,6 +98,15 @@ PermissionBroker 在处理 IM 内联按钮回调时，验证 callbackData 中的
 **10. 图片消息 DB 格式统一**
 Bridge 和桌面端使用相同的消息存储格式：图片写入 `.codepilot-uploads/`，消息 content 以 `<!--files:[{id,name,type,size,filePath}]-->text` 格式保存。桌面 UI 的 `MessageItem.parseMessageFiles()` 解析后通过 `FileAttachmentDisplay` + `/api/uploads?path=` 渲染缩略图。`conversation-engine.ts` 中 `getSession()` 提前到文件持久化之前调用，确保 workingDirectory 可用。
 
+**11. Telegram 出站 Markdown 渲染**
+Claude 的回复是 Markdown 格式，Telegram 仅支持有限 HTML 标签（b/i/s/code/pre+code/blockquote/a）。采用三层架构将 Markdown 转换为 Telegram HTML：
+
+- **IR 层**（`markdown/ir.ts`）：使用 markdown-it 将 Markdown 解析为中间表示 `MarkdownIR = { text, styles[], links[] }`。text 是纯文本，styles 是 `{ start, end, style }` 区间标记。支持 bold/italic/strikethrough/code/code_block/blockquote/links/lists/headings/tables/hr。表格使用 code-block 模式渲染为 ASCII 表格（包裹在 `<pre><code>` 中保留对齐）。HTML 内联标签中的 `<br>` 被转换为换行符。
+- **渲染层**（`markdown/render.ts`）：通用标记渲染器 `renderMarkdownWithMarkers(ir, options)`，接受样式→标签映射表 + escapeText + buildLink 回调，输出格式化文本。使用 boundary tracking + LIFO stack 处理嵌套。
+- **Telegram 层**（`markdown/telegram.ts`）：组合 IR+渲染器，映射样式到 Telegram HTML 标签。`wrapFileReferencesInHtml()` 防止 `README.md`、`main.go` 等文件名被 Telegram linkify 误识别为 URL（用 `<code>` 包裹）。`markdownToTelegramChunks(text, limit)` 实现 render-first 分片：先按 IR text 长度分块，再渲染每块为 HTML，若 HTML 超出 4096 限制则按比例重新分割。
+
+`bridge-manager.ts` 对 Claude 回复调用 `markdownToTelegramChunks()`，通过 `deliverRendered()` 发送预渲染 chunks（每个 chunk 包含 html + text 双通道，HTML 解析失败自动降级纯文本）。命令响应和错误消息仍使用 `escapeHtml()` + `deliver()`。
+
 ## 设置项（settings 表）
 
 | Key | 说明 |

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "codepilot",
-  "version": "0.21.2",
+  "version": "0.22.0",
   "private": true,
   "author": {
     "name": "op7418",
@@ -42,6 +42,7 @@
     "cmdk": "^1.1.1",
     "electron-updater": "^6.8.3",
     "lucide-react": "^0.563.0",
+    "markdown-it": "^14.1.1",
     "motion": "^12.33.0",
     "nanoid": "^5.1.6",
     "next": "16.1.6",
@@ -64,6 +65,7 @@
     "@playwright/test": "^1.58.1",
     "@tailwindcss/postcss": "^4",
     "@types/better-sqlite3": "^7.6.13",
+    "@types/markdown-it": "^14.1.2",
     "@types/node": "^20",
     "@types/react": "^19",
     "@types/react-dom": "^19",

package.json

@@ -15,7 +15,8 @@ import './adapters';
 import * as router from './channel-router';
 import * as engine from './conversation-engine';
 import * as broker from './permission-broker';
-import { deliver } from './delivery-layer';
+import { deliver, deliverRendered } from './delivery-layer';
+import { markdownToTelegramChunks } from './markdown/telegram';
 import { getSetting, insertAuditLog, updateChannelBinding } from '../db';
 import { setBridgeModeActive } from '../telegram-bot';
 import { escapeHtml } from './adapters/telegram-utils';
@@ -382,16 +383,14 @@ async function handleMessage(
       );
     }, taskAbort.signal, hasAttachments ? msg.attachments : undefined);
 
-    // Send response text
+    // Send response text — render Markdown to Telegram HTML
     if (result.responseText) {
-      const response: OutboundMessage = {
-        address: msg.address,
-        text: escapeHtml(result.responseText),
-        parseMode: 'HTML',
-      };
-      await deliver(adapter, response, {
-        sessionId: binding.codepilotSessionId,
-      });
+      const chunks = markdownToTelegramChunks(result.responseText, 4096);
+      if (chunks.length > 0) {
+        await deliverRendered(adapter, msg.address, chunks, {
+          sessionId: binding.codepilotSessionId,
+        });
+      }
     } else if (result.hasError) {
       const errorResponse: OutboundMessage = {
         address: msg.address,

src/lib/bridge/bridge-manager.ts

@@ -5,10 +5,12 @@
 
 import type {
   ChannelType,
+  ChannelAddress,
   OutboundMessage,
   SendResult,
   PLATFORM_LIMITS,
 } from './types';
+import type { TelegramChunk } from './markdown/telegram';
 import { PLATFORM_LIMITS as limits } from './types';
 import type { BaseChannelAdapter } from './channel-adapter';
 import {
@@ -222,6 +224,7 @@ export async function deliver(
 async function sendWithRetry(
   adapter: BaseChannelAdapter,
   message: OutboundMessage,
+  plainFallback?: string,
 ): Promise<SendResult> {
   let lastError: string | undefined;
 
@@ -234,8 +237,10 @@ async function sendWithRetry(
 
     // HTML parse error: immediately fallback to plain text (no retry needed)
     if (category === 'parse_error' && message.parseMode === 'HTML') {
+      const fallbackText = plainFallback || message.text;
       const plainResult = await adapter.send({
         ...message,
+        text: fallbackText,
         parseMode: 'plain',
       });
       if (plainResult.ok) return plainResult;
@@ -260,3 +265,73 @@ async function sendWithRetry(
 
   return { ok: false, error: lastError || 'Max retries exceeded' };
 }
+
+/**
+ * Deliver pre-rendered chunks (from Markdown renderer).
+ * Each chunk already has HTML and plain text fallback.
+ */
+export async function deliverRendered(
+  adapter: BaseChannelAdapter,
+  address: ChannelAddress,
+  chunks: TelegramChunk[],
+  opts?: { sessionId?: string; dedupKey?: string },
+): Promise<SendResult> {
+  // Dedup check
+  if (opts?.dedupKey) {
+    if (checkDedup(opts.dedupKey)) {
+      return { ok: true, messageId: undefined };
+    }
+  }
+  if (Math.random() < 0.01) {
+    try { cleanupExpiredDedup(); } catch { /* best effort */ }
+  }
+
+  let lastMessageId: string | undefined;
+
+  for (let i = 0; i < chunks.length; i++) {
+    await rateLimiter.acquire(address.chatId);
+    if (i > 0) {
+      await new Promise(r => setTimeout(r, INTER_CHUNK_DELAY_MS));
+    }
+
+    const chunk = chunks[i];
+    const htmlMessage: OutboundMessage = {
+      address,
+      text: chunk.html,
+      parseMode: 'HTML',
+    };
+
+    // Try HTML first, fall back to plain text on parse error
+    const result = await sendWithRetry(adapter, htmlMessage, chunk.text);
+    if (!result.ok) return result;
+    lastMessageId = result.messageId;
+
+    if (result.messageId && opts?.sessionId) {
+      try {
+        insertOutboundRef({
+          channelType: adapter.channelType,
+          chatId: address.chatId,
+          codepilotSessionId: opts.sessionId,
+          platformMessageId: result.messageId,
+          purpose: 'response',
+        });
+      } catch { /* best effort */ }
+    }
+  }
+
+  if (opts?.dedupKey) {
+    try { insertDedup(opts.dedupKey); } catch { /* best effort */ }
+  }
+
+  try {
+    insertAuditLog({
+      channelType: adapter.channelType,
+      chatId: address.chatId,
+      direction: 'outbound',
+      messageId: lastMessageId || '',
+      summary: chunks.map(c => c.text).join('').slice(0, 200),
+    });
+  } catch { /* best effort */ }
+
+  return { ok: true, messageId: lastMessageId };
+}