feat: add wecom bot thinking content support

Author: 勾勾的数字生命

CHANGELOG.md

@@ -4,6 +4,20 @@ All notable changes to this project will be documented in this file.
 
 ## [Unreleased]
 
+## [1.9.5] - 2026-03-08
+
+### Added
+- 新增 Bot `thinking_content` 支持：当模型输出包含 `<think>` / `<thinking>` / `<thought>` 标签时，插件会自动拆分正文与思考内容，并通过企业微信 Bot 原生 `thinking_content` 字段展示折叠思考区
+- 新增 `thinking-parser` 与回归测试，覆盖闭合标签、未闭合标签和代码块内标签忽略
+
+### Changed
+- Bot block/final 流式状态现在会把思考内容单独写入流状态，不再和可见正文混在一起
+- Bot stream refresh 现在会把 `thinking_content` 一并返回给企业微信客户端
+- Bot block-fallback 在只有思考内容时也能保留思考区，不会直接丢失
+
+### Fixed
+- 修复 Bot 流式输出中 `<think>` 标签内容被直接混入正文的问题
+
 ## [1.9.4] - 2026-03-08
 
 ### Added

README.en.md

@@ -55,6 +55,7 @@ This release is a major operations-focused upgrade: **WeCom now supports visual
 | WeCom inbound message handling | ✅ | text/image/voice/link/file/video (Agent + Bot) |
 | AI auto-reply via OpenClaw runtime | ✅ | routed by session key |
 | Native WeCom Bot stream protocol | ✅ | `msgtype=stream` refresh flow |
+| Bot thinking display | ✅ | parses `<think>/<thinking>/<thought>` into native `thinking_content` |
 | Bot card replies | ✅ | `markdown/template_card` with automatic text fallback |
 | Multi-account support | ✅ | `channels.wecom.accounts.<id>` |
 | Sender allowlist and admin bypass | ✅ | `allowFrom` + `adminUsers` |
@@ -75,6 +76,7 @@ This release is a major operations-focused upgrade: **WeCom now supports visual
 | Default callback path | `/wecom/callback` | `/wecom/bot/callback` |
 | Reply mechanism | WeCom send APIs | stream response + refresh polling |
 | Streaming UX | simulated via multiple messages | native stream protocol |
+| Thinking display | not applicable | native `thinking_content` from `<think>` tags |
 | Outbound media | full support (image/voice/video/file) | image/file supported (`active_stream msg_item(image)` first, then `response_url` mixed / webhook fallback) |
 
 ## 5-Minute Quick Start

README.md

@@ -193,6 +193,7 @@ npm run wecom:bot:selfcheck -- --all-accounts
 | 语音/视频/文件发送（出站） | ✅ | 自动判型上传后发送（语音支持 AMR/SILK） |
 | 语音转写（本地） | ✅ | 企业微信 Recognition 优先，缺失时回退本地 whisper |
 | Bot 模式媒体回传 | ✅ | `active_stream` 优先 `msg_item(image)`；失败自动降级媒体链接，`response_url`/Webhook Bot 继续兜底 |
+| Bot 思考过程展示 | ✅ | 识别 `<think>/<thinking>/<thought>`，映射到原生 `thinking_content` 折叠区 |
 | Bot 文件入站 | ✅ | 支持 `msgtype=file` 下载并注入会话上下文 |
 | Bot 引用消息上下文 | ✅ | 自动将 `quote` 内容前置到本轮上下文 |
 
@@ -205,6 +206,7 @@ npm run wecom:bot:selfcheck -- --all-accounts
 | 回调路径默认值 | `/wecom/callback` | `/wecom/bot/callback` |
 | 回复机制 | 主动调用 WeCom 发送 API | 回调响应 `stream` + 轮询刷新 |
 | 流式体验 | 多条消息模拟增量 | 原生 stream 协议 |
+| 思考展示 | 不适用 | 支持 `<think>` 标签映射到 `thinking_content` |
 | 出站媒体（图/语音/视频/文件） | 支持 | 支持（`active_stream msg_item(image)` + `response_url/Webhook` 回包，video 自动按 file 回传） |
 | 典型场景 | 标准企业应用、菜单/回调体系 | 对话机器人、连续流式问答 |
 

docs/channels/wecom.md

@@ -197,6 +197,11 @@ Bot E2E (signed/encrypted callback + stream refresh):
 npm run wecom:bot:selfcheck
 ```
 
+Thinking mode:
+
+- Bot replies now recognize `<think>...</think>` / `<thinking>...</thinking>` / `<thought>...</thought>` and send the reasoning via native `thinking_content`.
+- Think tags inside fenced code blocks and inline code are ignored.
+
 Remote matrix E2E (against public callback URLs):
 
 ```bash

openclaw.plugin.json

@@ -1,7 +1,7 @@
 {
   "id": "openclaw-wechat",
   "name": "OpenClaw-Wechat",
-  "version": "1.9.4",
+  "version": "1.9.5",
   "description": "WeCom (企业微信) channel plugin for OpenClaw (自建应用回调 + 发送 API).",
   "channels": [
     "wecom"

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@dingxiang-me/openclaw-wechat",
-  "version": "1.9.4",
+  "version": "1.9.5",
   "type": "module",
   "description": "WeCom (企业微信) channel plugin for OpenClaw (自建应用回调 + 发送 API).",
   "license": "MIT",

package.json

@@ -7,6 +7,10 @@ function normalizeStreamText(text) {
   return String(text ?? "");
 }
 
+function normalizeThinkingContent(text, maxBytes = DEFAULT_STREAM_MAX_BYTES) {
+  return enforceUtf8ByteLimit(String(text ?? ""), maxBytes);
+}
+
 function enforceUtf8ByteLimit(text, maxBytes = DEFAULT_STREAM_MAX_BYTES) {
   const normalized = normalizeStreamText(text);
   if (!Number.isFinite(maxBytes) || maxBytes <= 0) return normalized;
@@ -73,6 +77,7 @@ export class WecomStreamManager {
     const stream = {
       id,
       content,
+      thinkingContent: "",
       finished: false,
       feedbackId: String(feedbackId ?? "").trim() || null,
       msgItem: [],
@@ -117,7 +122,7 @@ export class WecomStreamManager {
     return queued;
   }
 
-  update(streamId, content, { append = false, finished = false, msgItem } = {}) {
+  update(streamId, content, { append = false, finished = false, msgItem, thinkingContent } = {}) {
     const id = String(streamId ?? "").trim();
     if (!id) return null;
     const existing = this.streams.get(id);
@@ -129,12 +134,15 @@ export class WecomStreamManager {
     if (Array.isArray(msgItem)) {
       existing.msgItem = normalizeStreamMsgItems(msgItem);
     }
+    if (thinkingContent !== undefined) {
+      existing.thinkingContent = normalizeThinkingContent(thinkingContent, this.maxBytes);
+    }
     existing.updatedAt = Date.now();
     this.streams.set(id, existing);
     return existing;
   }
 
-  finish(streamId, content = null, { msgItem } = {}) {
+  finish(streamId, content = null, { msgItem, thinkingContent } = {}) {
     const id = String(streamId ?? "").trim();
     if (!id) return null;
     const existing = this.streams.get(id);
@@ -145,6 +153,9 @@ export class WecomStreamManager {
     if (Array.isArray(msgItem)) {
       existing.msgItem = normalizeStreamMsgItems(msgItem);
     }
+    if (thinkingContent !== undefined) {
+      existing.thinkingContent = normalizeThinkingContent(thinkingContent, this.maxBytes);
+    }
     existing.queuedMedia = [];
     existing.finished = true;
     existing.updatedAt = Date.now();

src/core/stream-manager.js

@@ -1,3 +1,5 @@
+import { parseThinkingContent } from "./thinking-parser.js";
+
 function assertFunction(name, value) {
   if (typeof value !== "function") {
     throw new Error(`bot-dispatch-fallback: ${name} is required`);
@@ -26,9 +28,17 @@ export async function handleWecomBotPostDispatchFallback({
   const filledFromTranscript = await tryFinishFromTranscript(dispatchStartedAt);
   if (filledFromTranscript) return false;
 
-  const fallback = markdownToWecomText(dispatchState.blockText).trim();
-  if (fallback) {
-    await safeDeliverReply(fallback, "block-fallback");
+  const parsed = parseThinkingContent(dispatchState.blockText);
+  const fallback = markdownToWecomText(parsed.visibleContent).trim();
+  const thinkingContent = markdownToWecomText(parsed.thinkingContent).trim();
+  if (fallback || thinkingContent) {
+    await safeDeliverReply(
+      {
+        text: fallback,
+        thinkingContent,
+      },
+      "block-fallback",
+    );
     return false;
   }
 

src/wecom/bot-dispatch-fallback.js

@@ -1,3 +1,5 @@
+import { parseThinkingContent } from "./thinking-parser.js";
+
 function assertFunction(name, value) {
   if (typeof value !== "function") {
     throw new Error(`createWecomBotDispatchHandlers: ${name} is required`);
@@ -41,6 +43,17 @@ export function createWecomBotDispatchHandlers({
 
   const logger = api?.logger;
 
+  const buildThinkingState = (rawText) => {
+    const parsed = parseThinkingContent(rawText);
+    const visibleRaw = String(parsed.visibleContent ?? "").trim();
+    const thinkingRaw = String(parsed.thinkingContent ?? "").trim();
+    return {
+      rawText: String(rawText ?? ""),
+      visibleText: visibleRaw ? markdownToWecomText(visibleRaw).trim() : "",
+      thinkingContent: thinkingRaw ? markdownToWecomText(thinkingRaw).trim() : "",
+    };
+  };
+
   return {
     deliver: async (payload, info) => {
       if (!hasBotStream(streamId)) return;
@@ -57,7 +70,12 @@ export function createWecomBotDispatchHandlers({
         }
         if (!payload?.text) return;
         state.blockText = normalizeWecomBotBlockText(state.blockText, payload.text);
-        updateBotStream(streamId, markdownToWecomText(state.blockText), { append: false, finished: false });
+        const blockState = buildThinkingState(state.blockText);
+        updateBotStream(streamId, blockState.visibleText, {
+          append: false,
+          finished: false,
+          thinkingContent: blockState.thinkingContent,
+        });
         return;
       }
       if (info.kind !== "final") return;
@@ -66,9 +84,15 @@ export function createWecomBotDispatchHandlers({
           state.streamFinished = await safeDeliverReply(`抱歉，请求失败：${payload.text}`, "upstream-failure");
           return;
         }
-        const finalText = markdownToWecomText(payload.text).trim();
-        if (finalText) {
-          state.streamFinished = await safeDeliverReply(finalText, "final");
+        const finalState = buildThinkingState(payload.text);
+        if (finalState.visibleText || finalState.thinkingContent) {
+          state.streamFinished = await safeDeliverReply(
+            {
+              text: finalState.visibleText,
+              thinkingContent: finalState.thinkingContent,
+            },
+            "final",
+          );
           return;
         }
       }