修复：过滤模型思考标签 <|channel>thought / <channel|> 泄漏到用户界面

问题：某些模型输出的内部思考标签 <|channel>thought ... <channel|>
未被 hermes-agent 现有的 _strip_think_blocks() 过滤，导致这些标签
以独立消息的形式出现在微信/飞书用户界面中。

修复：
- 新增 patch_strip_thinking_tags.py 补丁脚本
- 扩展 run_agent.py 的 _strip_think_blocks() 方法：
添加 <|channel>thought...<channel|> 闭合标签对匹配
添加 <|...> 未终止标签匹配
添加 <|...> 散落标签清理
- 扩展 gateway/stream_consumer.py 的流式过滤：
向 _OPEN_THINK_TAGS 添加 <|channel>thought, <|channel|>
向 _CLOSE_THINK_TAGS 添加 <channel|>
- Dockerfile 构建时应用补丁
- start.sh 自动更新后重新应用补丁

Dockerfile

@@ -46,6 +46,10 @@ RUN python3 /tmp/patch_resolve_media_paths.py; rm -f /tmp/patch_resolve_media_pa
 COPY scripts/patch_weixin_cross_loop.py /tmp/patch_weixin_cross_loop.py
 RUN python3 /tmp/patch_weixin_cross_loop.py; rm -f /tmp/patch_weixin_cross_loop.py
 
+# Patch: Strip <|channel>thinking / <channel|> model tags from user-visible output
+COPY scripts/patch_strip_thinking_tags.py /tmp/patch_strip_thinking_tags.py
+RUN python3 /tmp/patch_strip_thinking_tags.py; rm -f /tmp/patch_strip_thinking_tags.py
+
 # Patch: DuckDuckGo free fallback for web_search (no API key needed)
 COPY scripts/patch_web_search_fallback.py /tmp/patch_web_search_fallback.py
 RUN python3 /tmp/patch_web_search_fallback.py; rm -f /tmp/patch_web_search_fallback.py

scripts/patch_strip_thinking_tags.py

@@ -0,0 +1,164 @@
+#!/usr/bin/env python3
+"""Patch hermes-agent to strip <|channel>thought / <channel|> thinking tags.
+
+PROBLEM: Some models output internal thinking tokens in the format
+    <|channel>thought ... <channel|>
+  that leak into user-facing messages on WeChat/Feishu. The existing
+  _strip_think_blocks() in run_agent.py handles <thought>, <thinking>,
+  <reasoning> etc., but NOT this <|...> pipe-delimited variant.
+
+FIX: Extend both the agent-level tag stripper AND the gateway stream
+  consumer to recognise and suppress these tags.
+
+  Files patched:
+    1. run_agent.py — _strip_think_blocks() + stray-tag cleanup
+    2. gateway/stream_consumer.py — _OPEN_THINK_TAGS / _CLOSE_THINK_TAGS
+"""
+
+import sys
+import os
+import glob
+import re
+
+
+def patch_run_agent(filepath: str) -> bool:
+    """Add <|channel>thinking / <channel|> patterns to _strip_think_blocks."""
+    with open(filepath, "r") as f:
+        content = f.read()
+
+    if "<|channel" in content and "_strip_think_blocks" in content:
+        # Check if already patched by looking for our specific addition
+        if '<|channel>thought' in content or '<|' in content and 'hermes-bot patch' in content:
+            print(f"  run_agent.py already patched, skipping")
+            return True
+
+    applied = False
+
+    # ── Patch 1a: Add closed-tag regex for <|channel>thought ... <channel|> ──
+    # Find the block of re.sub calls for closed tag pairs.
+    # We add our pattern right after the <thought>.*?</thought> line.
+    old_thought = "content = re.sub(r'<thought>.*?</thought>', '', content, flags=re.DOTALL | re.IGNORECASE)"
+    new_thought = (
+        old_thought
+        + "\n        # Hermes Bot patch: <|channel>thinking / <channel|> variants"
+        + "\n        content = re.sub(r'<\\|channel>thought.*?<channel\\|>', '', content, flags=re.DOTALL | re.IGNORECASE)"
+        + "\n        content = re.sub(r'<\\|channel\\|>thought.*?<\\|channel\\|>', '', content, flags=re.DOTALL | re.IGNORECASE)"
+        + "\n        content = re.sub(r'<\\|[^|>]*\\|>.*?<\\|/[^|>]*\\|>', '', content, flags=re.DOTALL | re.IGNORECASE)"
+    )
+    if old_thought in content:
+        content = content.replace(old_thought, new_thought, 1)
+        applied = True
+        print("  [run_agent.py] Added closed-tag regex for <|...> thinking blocks")
+
+    # ── Patch 1b: Add unterminated open-tag pattern ──
+    # Find the unterminated block regex and extend it.
+    old_unterm = (
+        "r'(?:^|\\n)[ \\t]*<(?:think|thinking|reasoning|thought|REASONING_SCRATCHPAD)\\b[^>]*>.*$'"
+    )
+    new_unterm = (
+        "r'(?:^|\\n)[ \\t]*<(?:think|thinking|reasoning|thought|REASONING_SCRATCHPAD)\\b[^>]*>.*$'"
+        + "\n            + r'|(?:^|\\n)[ \\t]*<\\|[^|>]*>.*$'"  # <|channel>thought
+    )
+    if old_unterm in content and not "<\\|[^|>]*>" in content.split("def _has_natural_response_ending")[0].split("def _strip_think_blocks")[1]:
+        content = content.replace(old_unterm, new_unterm, 1)
+        applied = True
+        print("  [run_agent.py] Extended unterminated-tag regex for <|...> variants")
+
+    # ── Patch 1c: Add stray orphan tag cleanup ──
+    # Find the stray tag cleanup and extend it.
+    old_stray = (
+        "r'</?(?:think|thinking|reasoning|thought|REASONING_SCRATCHPAD)>\\s*'"
+    )
+    new_stray = (
+        "r'</?(?:think|thinking|reasoning|thought|REASONING_SCRATCHPAD)>\\s*'"
+        + "\n            + r'|<\\|[^|>]*\\|>\\s*'"  # stray <|channel|> or <channel|>
+    )
+    if old_stray in content:
+        content = content.replace(old_stray, new_stray, 1)
+        applied = True
+        print("  [run_agent.py] Extended stray-tag cleanup for <|...> variants")
+
+    if applied:
+        with open(filepath, "w") as f:
+            f.write(content)
+        return True
+    else:
+        print(f"  WARNING: Could not patch {filepath}", file=sys.stderr)
+        return False
+
+
+def patch_stream_consumer(filepath: str) -> bool:
+    """Add <|channel>thought / <channel|> to stream consumer think-tag lists."""
+    with open(filepath, "r") as f:
+        content = f.read()
+
+    applied = False
+
+    # ── Patch 2a: Add to _OPEN_THINK_TAGS ──
+    old_open = '    _OPEN_THINK_TAGS = (\n        "<REASONING_SCRATCHPAD>", "\U0001f9ae", "<reasoning>",\n        "<THINKING>", "<thinking>", "<thought>",\n    )'
+    new_open = '    _OPEN_THINK_TAGS = (\n        "<REASONING_SCRATCHPAD>", "\U0001f9ae", "<reasoning>",\n        "<THINKING>", "<thinking>", "<thought>",\n        # Hermes Bot patch: <|...> thinking variants\n        "<|channel>thought", "<|channel|>",\n    )'
+
+    if old_open in content:
+        content = content.replace(old_open, new_open, 1)
+        applied = True
+        print("  [stream_consumer.py] Added <|channel>thought to _OPEN_THINK_TAGS")
+
+    # ── Patch 2b: Add to _CLOSE_THINK_TAGS ──
+    old_close = '    _CLOSE_THINK_TAGS = (\n        "</REASONING_SCRATCHPAD>", "\U0001f9d0", "</reasoning>",\n        "</THINKING>", "</thinking>", "</thought>",\n    )'
+    new_close = '    _CLOSE_THINK_TAGS = (\n        "</REASONING_SCRATCHPAD>", "\U0001f9d0", "</reasoning>",\n        "</THINKING>", "</thinking>", "</thought>",\n        # Hermes Bot patch: <|...> thinking variants\n        "<channel|>",\n    )'
+
+    if old_close in content:
+        content = content.replace(old_close, new_close, 1)
+        applied = True
+        print("  [stream_consumer.py] Added <channel|> to _CLOSE_THINK_TAGS")
+
+    if applied:
+        with open(filepath, "w") as f:
+            f.write(content)
+        return True
+    else:
+        print(f"  WARNING: Could not patch {filepath}", file=sys.stderr)
+        return False
+
+
+if __name__ == "__main__":
+    results = {}
+
+    # Patch run_agent.py
+    run_agent_candidates = [
+        "/app/hermes-agent/run_agent.py",
+    ]
+    run_agent_candidates.extend(
+        glob.glob("/app/venv/lib/**/run_agent.py", recursive=True)
+    )
+
+    for c in run_agent_candidates:
+        if os.path.isfile(c):
+            results["run_agent.py"] = patch_run_agent(c)
+            break
+
+    # Patch gateway/stream_consumer.py
+    stream_candidates = [
+        "/app/hermes-agent/gateway/stream_consumer.py",
+    ]
+    stream_candidates.extend(
+        glob.glob("/app/venv/lib/**/gateway/stream_consumer.py", recursive=True)
+    )
+
+    for c in stream_candidates:
+        if os.path.isfile(c):
+            results["stream_consumer.py"] = patch_stream_consumer(c)
+            break
+
+    if not results:
+        print("WARNING: No target files found to patch", file=sys.stderr)
+        print(f"  run_agent.py checked: {run_agent_candidates}", file=sys.stderr)
+        print(f"  stream_consumer.py checked: {stream_candidates}", file=sys.stderr)
+        sys.exit(0)
+
+    all_ok = all(results.values())
+    if all_ok:
+        print(f"All patches applied successfully: {list(results.keys())}")
+    else:
+        print(f"Some patches failed: {results}", file=sys.stderr)
+        sys.exit(1)

start.sh

@@ -551,6 +551,9 @@ update_hermes_agent_background() {
     if [ -f "/app/scripts/patch_web_search_fallback.py" ]; then
         python3 /app/scripts/patch_web_search_fallback.py 2>/dev/null
     fi
+    if [ -f "/app/scripts/patch_strip_thinking_tags.py" ]; then
+        python3 /app/scripts/patch_strip_thinking_tags.py 2>/dev/null
+    fi
     # Copy patch files if they exist
     for patch_file in prompt_builder.py send_message_tool.py; do
         if [ -f "/app/patches/hermes-agent/agent/$patch_file" ] && [ -f "$AGENT_DIR/agent/$patch_file" ]; then