fix(toolchain): 模板双花括号→单花括号 (仲达 M1)

docs/design/07-spawner-acquire-first.md

@@ -233,20 +233,27 @@ def _revive_session(agent_id: str) -> bool:
                 pass
 ```
 
-### 4.5 O5: compact 扫描条件收紧
+### 4.5 O5: compact 检测（§24 rotation-only v3）
 
-当前 compact 扫描在 status 非 idle/done/unknown/None 时都触发，范围过宽。
+§24 设计文档：`docs/design/24-compact-detection-fix.md`
 
-**改后**：只在 status 为 running 或 compacting 相关时扫描：
+**检测方法**：读 gateway 日志尾部 2MB，按 sessionKey 过滤 `[compaction] rotated active transcript` 事件。
+如果最近的 rotation 事件在 120s 窗口内 → 视为 compact 循环进行中（可能还在 post-compact retry）。
+
+旧方法 `_check_recent_compaction_jsonl`（扫描 session jsonl 的 `type=compaction` 事件）保留作为 fallback。
 
 ```python
-# 只在这些状态下检查 compact
-if result["status"] in ("running",) and sf:
-    result["recent_compact"] = AgentSpawner._check_recent_compaction_jsonl(sf)
+# §24 v3: compact 检测优先用 gateway 日志 rotation 事件
+if result["status"] not in ("idle", "unknown", None):
+    session_key = f"agent:{agent_id}:main"
+    result["recent_compact"] = AgentSpawner._check_compact_in_progress_gateway(
+        session_key)
+    if not result["recent_compact"] and sf:
+        result["recent_compact"] = AgentSpawner._check_recent_compaction_jsonl(sf)
 ```
 
 注：Gateway 的 sessions.json status 实际值主要是 `idle/running/timeout/failed`。
-`running` 时检查 compact 有意义（agent turn 执行中可能触发 compact）。
+非空闲状态（`running`/`timeout`/`failed`）时检查 compact 有意义。
 其他状态不需要检查。
 
 ## 五、改动范围

docs/design/13-toolchain-and-dev-workflow.md

@@ -33,26 +33,173 @@
 | 项 | 配置 |
 |----|------|
 | 地址 | `http://192.168.2.154:3000` |
-| 版本 | v1.23.4 |
-| 认证 | HTTP + token（待配置） |
-| 权限 | cfdaily 用户；姜维持有 admin 权限（启用 Actions、分支保护等） |
+| 版本 | v1.26.2（2026-06-11 从 v1.23.4 升级） |
+| 认证 | HTTP + token；admin 账号（姜维持有） |
+| 权限 | 姜维持有 admin 权限（启用 Actions、分支保护、org webhook 等） |
+| 数据库 | SQLite3 |
+| 部署方式 | Docker（NAS 群晖），数据卷 `/volume2/@docker/volumes/gitea-data/_data` |
 
 ### 2.2 CI/CD：Gitea Actions
 
 | 项 | 配置 |
 |----|------|
-| Runner | Mac mini 裸机，act-runner（Go 二进制） |
+| Runner | Mac mini 裸机，gitea-runner v1.0.8（通过 PM2 管理 `sanguo-act-runner`） |
 | 配置文件 | `.gitea/workflows/*.yml`，每个项目自管 |
-| 语法 | 兼容 GitHub Actions（v1.23.4 已验证支持） |
-| 触发 | push / PR / tag |
+| 语法 | 兼容 GitHub Actions（v1.26.2 已验证支持 concurrency groups） |
+| 触发 | push / PR / tag / workflow_dispatch |
+| v1.26 新增 | concurrency groups、re-run failed jobs、可配置 GITEA_TOKEN 权限 |
+| 仍不支持 | `failure()`、`continue-on-error`、`timeout-minutes` |
 
-### 2.3 部署目标
+### 2.4 Gitea 基础设施 Setup 记录（2026-06-11 姜维）
+
+> 以下为 Gitea 从 v1.23.4 升级到 v1.26.2 的完整操作记录，作为未来参考。
+
+#### 2.4.1 升级 v1.23.4 → v1.26.2
+
+**升级原因**：v1.23.4 不支持 concurrency groups，导致双倍触发问题无根因解法。
+
+**升级步骤**：
+1. 备份：`docker exec sanguo_gitea gitea dump -c /data/gitea/conf/app.ini -f /data/gitea/gitea-backup-pre-v126.zip`（765MB）
+2. 拉取镜像：Mac 上 skopeo 下载 → python docker SDK 远程 load（群晖 Docker Hub 太慢）
+3. 停止旧容器 + rename 保留回滚
+4. 启动新容器（数据库自动迁移 Migration[312]→[326]，含 concurrency #323）
+5. 验证：API + Web UI + 仓库数据 + 用户数据
+
+**踩坑：群晖内核 3.10 + git 2.52 不兼容**：
+- 根因：git 2.52 使用 `getrandom(2)` syscall，群晖内核 3.10.108 不支持（3.17 才加入）
+- 症状：`git push` 报 `unable to create temporary file: Function not implemented`
+- 修复：entrypoint 脚本在容器启动时自动从本地缓存降级 git 到 2.45.4
+- 持久化：`/data/entrypoint-wrapper.sh` + `/data/git-2.45.4-r0.apk` 在数据卷里，容器重建不丢失
+- 群晖内核**无法通过 DSM 升级**，内核版本跟硬件型号绑定
+
+**完整重建命令**：
+```bash
+docker -H tcp://192.168.2.154:2375 run -d \
+  --name sanguo_gitea \
+  --restart=always \
+  -p 3000:3000 \
+  -p 2221:22 \
+  -v /volume2/@docker/volumes/gitea-data/_data:/data \
+  -e GITEA__database__DB_TYPE=sqlite3 \
+  -e GITEA__database__PATH=/data/gitea/gitea.db \
+  -e GITEA__server__ROOT_URL=http://192.168.2.154:3000/ \
+  --entrypoint /bin/sh \
+  gitea/gitea:1.26.2 \
+  -c '/data/entrypoint-wrapper.sh'
+```
+
+#### 2.4.2 act_runner 升级 v0.2.11 → v1.0.8
+
+**升级原因**：v0.2.11 的 multi-step job 执行有 bug，Setup Python 和 Lint step 被跳过。
+
+**升级步骤**：
+1. 下载 `gitea-runner-1.0.8-darwin-arm64`（从 gitea.com releases）
+2. `codesign --force --sign -` 重签（macOS Gatekeeper 会 SIGKILL 未签名的二进制）
+3. 替换 `/Users/chufeng/bin/act_runner`
+4. PM2 restart `sanguo-act-runner`
+
+**注意**：act_runner 通过 **PM2** 管理（`sanguo-act-runner`），不是 launchd。launchd plist 仅为备份。
+
+**PM2 常用命令**：
+```bash
+pm2 restart sanguo-act-runner   # 重启
+pm2 logs sanguo-act-runner      # 查看日志
+pm2 show sanguo-act-runner      # 详情
+```
+
+#### 2.4.3 CI Workflow 配置
+
+**三个 workflow 文件**：
+
+| 文件 | 触发 | concurrency | 说明 |
+|------|------|-------------|------|
+| `ci.yml` | `pull_request` | `group: ci-${{ gitea.ref }}, cancel-in-progress: true` | 同一 PR 新 push 自动取消旧 run |
+| `deploy.yml` | `push to main` | `group: deploy-${{ gitea.ref }}, cancel-in-progress: false` | 部署排队不取消 |
+| `e2e.yml` | `workflow_dispatch` | `group: e2e-${{ gitea.ref }}, cancel-in-progress: true` | 手动触发 |
+
+**Branch Protection（main 分支）**：
+- 禁止直接 push
+- status check：`CI / lint (pull_request)` 必须通过
+- 至少 1 人 Review
+
+**⚠️ 踩坑**：v1.26 上报的 commit status context 格式变了：
+- 旧格式：`lint`
+- 新格式：`CI / lint (pull_request)`
+- branch protection 必须用新格式匹配，否则 merge 报 "Not all required status checks successful"
+
+#### 2.4.4 Org Webhook 配置
+
+- **对象**：Gitea 组织 `sanguo` webhook id=28
+- **URL**：`http://192.168.2.153:8083/webhook/gitea`
+- **事件**：16 个（push/issues/PR/PR review 等）
+
+**⚠️ 踩坑**：Gitea v1.26 的 PATCH hooks API，只传 `{"active": true}` 会把 events 重置为 `["push"]`。**必须每次 PATCH 都带上完整的 events 列表。**
+
+**临时措施（已恢复）**：2026-06-10 曾临时关闭 webhook（CI 错误大爆炸期间），2026-06-11 已恢复。
+
+#### 2.4.5 凭据管理
+
+| 凭据 | 用途 | 持有者 |
+|------|------|--------|
+| Gitea admin:cf7561523 | 仓库管理、branch protection、org webhook | 姜维 |
+| Gitea PAT (jiangwei-infra) | API 操作、git clone/push | 姜维 |
+| Gitea PAT (cfdaily) | CI workflow 中的 git 操作 | CI secrets |
+
+#### 2.4.6 备份与回滚
+
+| 项目 | 路径 | 说明 |
+|------|------|------|
+| Gitea 数据库备份 | `/data/gitea/gitea-backup-pre-v126.zip` | 升级前 dump |
+| 旧容器 | 已清理 | 升级验证通过后 `docker rm` |
+| 变更记录 | `~/.openclaw/workspace-jiangwei/changes/gitea-emergency-2026-06-10.md` | 完整操作日志 |
 
 | 环境 | 位置 | 说明 |
 |------|------|------|
 | Mac mini 本机 | `~/.sanguo_projects/<project>/` | 主力开发和运行环境 |
 | NAS Docker | `192.168.2.154` | 部分服务（Gitea、回测等） |
 
+#### 2.4.7 Gitea 迁移验证记录（2026-06-11 司马懿）
+
+> 验证 Gitea 从 gitee 迁移完成后的状态。所有验证在 2026-06-11 完成。
+
+**仓库迁移状态**：
+
+| 项目 | Gitea 仓库 | 开发目录 | 远程地址 | gitee 残留 |
+|------|-----------|---------|---------|----------|
+| sanguo_moziplus_v2 | `sanguo/sanguo_moziplus_v2` | `~/.openclaw/sanguo_projects/sanguo_moziplus_v2/` | `http://192.168.2.154:3000/sanguo/sanguo_moziplus_v2.git` | ✅ 无 |
+| sanguo_quant_live | `sanguo/sanguo_quant_live` | `~/.openclaw/sanguo_projects/sanguo_quant_live/` | `http://192.168.2.154:3000/sanguo/sanguo_quant_live.git` | ✅ 无 |
+| sanguo_vnpy | `sanguo/sanguo_vnpy` | `~/.openclaw/sanguo_projects/sanguo_vnpy/` | `http://192.168.2.154:3000/sanguo/sanguo_vnpy.git` | ✅ 无 |
+
+**验证方法**：在 3 个开发目录分别执行 `git remote -v`，确认 origin 指向 gitea 且无 gitee remote。
+
+**CI 管道验证**：
+
+| 验证项 | 结果 | 备注 |
+|--------|------|------|
+| PR #33 Lint 修复 CI 通过 | ✅ | flake8 全通过 |
+| CD pipeline (deploy.yml) 合并 | ✅ | 含 CI + deploy + notify-deploy-failure 三个 job |
+| Branch protection 生效 | ✅ | main 分支需 CI 通过 + 1 人 Review 才能合并 |
+| Gitea squash merge 兼容 | ✅ | `merge_commit_sha` 在 squash merge 下仍等于 gitea.sha |
+
+**工具链事件中枢验证**：
+
+| Webhook → Mail 流 | 验证结果 |
+|-------------------|--------|
+| PR opened → Review 请求 Mail | ✅ 司马懿收到 PR #30-#35 的 Review 请求 |
+| PR review → 结果 Mail | ✅ 张飞/庞统收到 Review 结果通知 |
+| Issue assigned → 指派 Mail | ✅ （E2E 验证通过） |
+| CI 失败评论 → 通知 Mail | ✅ （E2E 验证通过） |
+| PR synchronize → reviewer 重审 Mail | ✅ 新增（§23） |
+| Review COMMENTED → PR 作者通知 | ✅ 新增（§23） |
+
+**Agent Gitea 凭据**（各 Agent 自行持有 PAT）：
+
+| Agent | Gitea 用户名 | PAT 用途 |
+|-------|-------------|--------:|
+| simayi-challenger | simayi-challenger | PR Review 提交 |
+| pangtong-fujunshi | pangtong-fujunshi | PR 创建/合并、代码 push |
+| jiangwei-infra | jiangwei-infra | 基础设施配置（admin 级操作） |
+
 ---
 
 ## §3. 分支策略
@@ -157,7 +304,7 @@ Open → In Progress → Review → Closed
 
 每个项目在 `.gitea/workflows/ci.yml` 自定义具体步骤，但遵循统一骨架。
 
-> **注**：Gitea Actions v1.23.4 不支持 `paths` 过滤触发条件。通过路径判断放在 job 级别的 `if` 条件中，使用确定支持的语法。（M4 修订）
+> **注**：Gitea Actions v1.26.2 不支持 `paths` 过滤触发条件。通过路径判断放在 job 级别的 `if` 条件中，使用确定支持的语法。（M4 修订）
 
 ```yaml
 name: CI

docs/design/24-compact-detection-fix.md

@@ -0,0 +1,259 @@
+# §24 — Compact 检测方案修正
+
+> 状态：v4（trajectory prompt.submitted），待实施
+> 作者：庞统
+> 日期：2026-06-11
+> 框架：基于 §07 Spawner Acquire-First
+> 评审：仲达 4 轮评审（v1 trajectory → v2 gateway precheck → v3 rotation-only → v4 prompt.submitted）
+> 备选方案：B（内存 flag + sessions.json status），见 §2B
+
+## 1. 问题
+
+### 1.1 现象
+
+2026-06-11 14:02，pangtong main session 正在做 compaction（13:59:26 开始，14:06:00 结束，耗时 ~6.5 分钟），但 spawner Phase 2 检查时 `compact=False`，仍然 spawn 了新进程处理 Mail，导致两个 agent turn 撞车。
+
+### 1.2 根因
+
+当前 compact 检测方法 `_check_recent_compaction_jsonl` 扫描 session jsonl，查找 `type == "compaction"` 事件。这是 compact **完成后**才写入的摘要记录，compact **进行中**时不存在 → 漏检。
+
+同时 Gateway 触发 compact 时先把 session 标为 `done`，所以 `status=running + lock_pid_alive` 检查也无效。14:02:11 实际状态：`status=done lock_pid_alive=False compact=False`——三个检查全部漏过。
+
+## 2. 方案 A：Trajectory prompt.submitted 检测（v4，主选方案）
+
+### 2.1 方案演进
+
+| 版本 | 方案 | 问题 |
+|------|------|------|
+| v1 | trajectory jsonl 间接推断 | trajectoryPath 不可用，需多文件 |
+| v2 | gateway precheck 开始标志 | 覆盖率仅 30%，post-compact retry 无开始标志 |
+| v3 | rotation-only + 120s 窗口 | 120s 覆盖不了多轮 compact loop（实测 pangtong 13:59→14:50 共 5 轮 rotation，总耗时 ~51 分钟，PR #36 已合并但无法覆盖） |
+| **v4** | **trajectory prompt.submitted** | **源码+数据双重验证，仲达背靠背确认** |
+
+### 2.2 核心洞察
+
+**源码证据**（`selection-But6hGR0.js` L14040-14085）：
+
+```javascript
+if (preemptiveCompaction?.shouldCompact) {
+    skipPromptSubmission = true;  // ← compact 时跳过 prompt.submitted
+}
+if (!skipPromptSubmission) {
+    trajectoryRecorder?.recordEvent("prompt.submitted", { ... });
+}
+```
+
+当 context-overflow 触发 compact 时，Gateway 跳过 `prompt.submitted` 事件。
+正常 turn 一定有 `prompt.submitted`。
+
+**仲达背靠背验证**：`skipPromptSubmission` 有 7 条路径（不只 compact），但仲达指出：
+**检测目标不是"是否在 compact"，而是"session 是否处于正常状态"。**
+所有跳过 prompt.submitted 的场景（compact/timeout/hook block/session 结束）
+都是不应该 spawn ticker 的状态，误判方向安全。
+
+**实测数据**（仲达背靠背重新验证，2026-06-11）：
+- pangtong 39 个 turn：34 有 prompt.submitted（正常），5 无
+  - 4 个 tool loop 子迭代（compactionCount=0, <1s, gateway 无 compact 事件）
+  - 1 个 context-overflow precheck 触发 compact
+- simayi 24 个 turn：23 有，1 无（tool-result truncation succeeded）
+- 合计 6/63 = ~9.5% 无 prompt.submitted，其中真正 compact 仅 1 例
+- **所有无 prompt.submitted 的场景都是不应 spawn ticker 的状态**，方向安全
+
+### 2.3 检测逻辑
+
+```
+1. 构造 trajectory jsonl 路径：{sessionFile}.trajectory.jsonl
+2. 读文件尾部，按 session.started 分组找最后一个完整 turn
+3. 如果该 turn 有 prompt.submitted → 正常 turn → 不 skip
+4. 如果该 turn 有 prompt.skipped → 空白 prompt → 不 skip
+5. 如果两者都无 → 非正常状态 → skip ticker
+6. 超过 30min 没有新事件 → 兜底放行
+```
+
+**为什么不需要 gateway 日志？**
+- trajectory jsonl 已经包含了完整的 turn 生命周期
+- prompt.submitted 是 turn 级别的标志，不需要匹配开始/结束
+- 不需要维护跨 tick 的内存状态
+
+### 2.4 为什么不用 session jsonl 的 `type: "compaction"` 事件？
+
+每轮 compact 结束，session jsonl 确实会写入 `type: "compaction"` 摘要事件。
+但 compact 后 Gateway 会 rotate transcript（创建新 session file），
+compaction 事件写在**旧 session jsonl** 里（变成 .reset 文件），
+当前 main session 指向的 jsonl 中没有这些事件。
+
+这就是现有 `_check_recent_compaction_jsonl` 检测不到的根本原因。
+
+## 2B. 备选方案 B：内存 flag + sessions.json status
+
+如果方案 A 在实际使用中不够，可补充方案 B。
+
+```
+1. gateway 日志发现 rotation 或 precheck → 设置内存 flag: compacting=True
+2. 每个 ticker 检查：
+   - flag=True + sessions.json status=running → 清 flag（compact 结束）
+   - flag=True + 超过 30min → 清 flag（兜底放行）
+   - flag=True → skip ticker
+3. daemon 重启会丢失 flag（可接受，重启后状态已刷新）
+```
+
+**优点**：精确检测 compact 结束（status 恢复 running）
+**缺点**：需要维护内存状态、依赖两个数据源、daemon 重启丢失状态
+**触发条件**：仅在方案 A 实际运行中发现不足时实施
+
+## 3. 改动范围（方案 A）
+
+| 文件 | 改动 | 行数估计 |
+|------|------|---------|
+| `spawner.py` | 新增 `_check_compact_in_progress_trajectory()` | ~50 行 |
+| `spawner.py` | `_check_session_state()` 调用新方法，替换旧方法 | ~5 行 |
+| `tests/test_spawner_compact.py` | 更新单元测试 | ~30 行 |
+
+**总计 ~85 行代码改动。**
+
+## 4. 实现细节（方案 A）
+
+### 4.1 核心方法
+
+```python
+def _check_compact_in_progress_trajectory(self, session_file: str, timeout_minutes: int = 30) -> bool:
+    """检查 trajectory jsonl 尾部，判断 session 是否处于非正常状态。
+    
+    检测逻辑：最后一个完整 turn 没有 prompt.submitted → 非正常状态 → skip ticker。
+    覆盖：compact、timeout、hook block、session 结束等所有非正常状态。
+    """
+    traj_path = f"{session_file}.trajectory.jsonl"
+    if not os.path.exists(traj_path):
+        return False
+    
+    # 读尾部 500KB
+    with open(traj_path, 'rb') as f:
+        f.seek(0, 2)
+        size = f.tell()
+        f.seek(max(0, size - 500 * 1024))
+        tail_lines = f.readlines()
+    
+    # 按 session.started 分组，找最后一个完整 turn
+    last_turn_events = []
+    current_turn = []
+    for raw_line in tail_lines:
+        try:
+            obj = json.loads(raw_line)
+        except (json.JSONDecodeError, ValueError):
+            continue
+        
+        event_type = obj.get("type", "")
+        
+        if event_type == "session.started":
+            if current_turn:
+                last_turn_events = current_turn
+            current_turn = [obj]
+        else:
+            current_turn.append(obj)
+    
+    if current_turn:
+        last_turn_events = current_turn
+    
+    if not last_turn_events:
+        return False
+    
+    # 30min 兜底：最后一个事件超过 30min → 放行
+    last_ts = None
+    for evt in reversed(last_turn_events):
+        ts = evt.get("ts") or evt.get("timestamp")
+        if ts:
+            last_ts = ts
+            break
+    
+    if last_ts:
+        try:
+            from datetime import datetime, timezone
+            # trajectory 时间是 ISO UTC
+            if last_ts.endswith('Z'):
+                last_dt = datetime.fromisoformat(last_ts.replace('Z', '+00:00'))
+            else:
+                last_dt = datetime.fromisoformat(last_ts)
+            age = datetime.now(timezone.utc) - last_dt
+            if age.total_seconds() > timeout_minutes * 60:
+                return False  # 超时放行
+        except (ValueError, TypeError):
+            pass
+    
+    # 检查最后一个 turn 是否有 prompt.submitted
+    has_prompt_submitted = any(
+        evt.get("type") == "prompt.submitted" for evt in last_turn_events
+    )
+    has_prompt_skipped = any(
+        evt.get("type") == "prompt.skipped" for evt in last_turn_events
+    )
+    
+    if has_prompt_submitted or has_prompt_skipped:
+        return False  # 正常 turn
+    
+    # 既无 submitted 也无 skipped → 非正常状态 → skip
+    return True
+```
+
+### 4.2 Phase 2 集成
+
+```python
+# 在 _check_session_state 中替换旧方法
+compact = self._check_compact_in_progress_trajectory(session_file)
+if not compact:
+    compact = self._check_recent_compaction_jsonl(...)  # fallback
+    
+if compact:
+    blockers.append(("session_compacting", None))
+```
+
+### 4.3 trajectory 路径构造
+
+trajectory jsonl 路径 = `{sessionFile}.trajectory.jsonl`，其中 sessionFile 来自 sessions.json。
+
+实测验证：
+- `~/.openclaw/agents/pangtong-fujunshi/sessions/745b35bb-...-e8e8988d.jsonl`
+- → trajectory: `~/.openclaw/agents/pangtong-fujunshi/sessions/745b35bb-...-e8e8988d.trajectory.jsonl`
+
+## 5. 边界情况
+
+| 边界情况 | 处理 | 误判方向 |
+|---------|------|----------|
+| trajectory 不存在 | 返回 False（fallback） | 安全 |
+| tool loop 子迭代 | 无 prompt.submitted → skip | 保守但安全（~8%） |
+| timeout turn | 无 prompt.submitted → skip | 安全（timeout 也不该 spawn） |
+| hook block | 无 prompt.submitted → skip | 安全 |
+| truncation 成功 | 无 prompt.submitted → skip | 安全（后面会 retry） |
+| session 结束空 turn | 无 prompt.submitted → skip | 安全 |
+| 空白 prompt | 有 prompt.skipped → 不 skip | 正确区分 |
+| 30min 无新事件 | 兜底放行 | 防死锁 |
+| compact 后 transcript rotate | 读当前 sessionFile 对应的 trajectory | 路径正确 |
+| budget compact | 有 prompt.submitted → 不 skip | 正确（budget compact 不阻止 spawn） |
+
+## 6. 测试验证
+
+### 6.1 单元测试（更新 test_spawner_compact.py）
+
+- `_check_compact_in_progress_trajectory`：
+  - 正常 turn（有 prompt.submitted）→ False
+  - compact turn（无 prompt.submitted）→ True
+  - 空白 prompt（有 prompt.skipped）→ False
+  - 超过 30min 兜底 → False
+  - trajectory 不存在 → False
+  - 空 trajectory → False
+  - 多 turn 尾部只看最后一个 → 正确
+
+### 6.2 集成验证
+
+- `pytest -m "not e2e"` 全量测试
+
+## 7. 关联设计
+
+- §07 Spawner Acquire-First（§4.5 O5 compact 扫描条件收紧）
+- §08 Classify Outcome Optimization（compact_hanging 处理）
+
+## 8. 评审记录
+
+- **v1**：trajectory jsonl 间接推断 → 仲达指出 trajectoryPath 不可用、需多文件等 3 个问题
+- **v2**：gateway 日志 precheck 开始标志 → 仲达指出开始标志覆盖率仅 30%，建议 rotation-only
+- **v3**：rotation-only + 120s 窗口 → 合并 PR #36，但实测 51 分钟 compact loop 无法覆盖
+- **v4**：trajectory prompt.submitted → 仲达背靠背验证（源码 7 条 skipPromptSubmission 路径 + 实际数据 ~8% 假阳性但方向安全）→ 修正检测目标为"session 是否正常"

src/api/toolchain_routes.py

@@ -265,7 +265,8 @@ async def _handle_pull_request(payload: Dict[str, Any]) -> None:
         await _handle_pr_opened(payload)
     elif action == "synchronize":
         await _handle_pr_synchronize(payload)
-    # 其他 action 忽略
+    elif action == "closed":
+        await _handle_pr_closed(payload)
 
 
 async def _handle_pr_opened(payload: Dict[str, Any]) -> None:
@@ -434,9 +435,9 @@ async def _handle_pr_synchronize(payload: Dict[str, Any]) -> None:
     # 查询最近 review 的提交者
     reviewer = await _fetch_latest_reviewer(repo, pr_number)
     if not reviewer:
-        # 没有 review 历史，跳过（opened 事件已经通知过）
-        logger.debug("No review history for PR #%s, skipping synchronize notification", pr_number)
-        return
+        # 没有已有 review 历史，fallback 到默认 reviewer
+        reviewer = "simayi-challenger"
+        logger.info("No review history for PR #%s, using default reviewer %s", pr_number, reviewer)
 
     text = render_template("review_updated", {
         "repo": repo,
@@ -451,6 +452,38 @@ async def _handle_pr_synchronize(payload: Dict[str, Any]) -> None:
     _send_mail(reviewer, title, text)
 
 
+async def _handle_pr_closed(payload: Dict[str, Any]) -> None:
+    """PR closed → 如果 merged，通知 PR 作者。"""
+    pr = payload.get("pull_request")
+    if not pr or not isinstance(pr, dict):
+        return
+
+    # 只处理 merged 的 PR
+    if not pr.get("merged", False):
+        return
+
+    repo = _repo_fullname(payload)
+    pr_number = pr.get("number", 0)
+    pr_title = pr.get("title", "")
+    pr_author = pr.get("user", {}).get("login", "unknown")
+    # merged_by 可能不在 payload 中，fallback 到 sender
+    merged_by = (
+        pr.get("merged_by", {}).get("login", "")
+        or payload.get("sender", {}).get("login", "unknown")
+    )
+
+    text = render_template("review_merged", {
+        "repo": repo,
+        "pr_number": str(pr_number),
+        "pr_title": pr_title,
+        "pr_author": pr_author,
+        "merged_by": merged_by,
+    })
+
+    title = f"PR 已合并: {pr_title} ({repo}#{pr_number})"
+    _send_mail(pr_author, title, text)
+
+
 async def _handle_issues(payload: Dict[str, Any]) -> None:
     """处理 issues 事件：assigned → 通知被指派人；opened+部署失败 → 通知运维。"""
     action = payload.get("action", "")

src/daemon/spawner.py

@@ -1297,6 +1297,90 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_
             logger.exception("Failed to revive %s", agent_id)
             return False
 
+    # deprecated: §24 v3, 保留供方案 B 备选
+    @staticmethod
+    def _get_recent_gateway_logs() -> list:
+        """获取当天和昨天的 gateway 日志路径。
+
+        日志路径通过 OPENCLAW_LOG_DIR 环境变量配置，默认 /tmp/openclaw。
+        文件名格式：openclaw-{YYYY-MM-DD}.log
+        """
+        from datetime import timedelta
+        log_dir = os.environ.get("OPENCLAW_LOG_DIR", "/tmp/openclaw")
+        now_local = datetime.now()
+        today = now_local.strftime("%Y-%m-%d")
+        yesterday = (now_local - timedelta(days=1)).strftime("%Y-%m-%d")
+        paths = []
+        for d in [today, yesterday]:
+            p = os.path.join(log_dir, f"openclaw-{d}.log")
+            if os.path.exists(p):
+                paths.append(p)
+        return paths
+
+    # deprecated: §24 v3, 保留供方案 B 备选
+    @staticmethod
+    def _check_compact_in_progress_gateway(
+            session_key: str, window_seconds: int = 120) -> bool:
+        """§24 v3 rotation-only: 检查 gateway 日志，判断指定 session 是否刚完成 compact。
+
+        检测逻辑：读日志尾部 2MB，按目标 sessionKey 过滤，
+        找最后一个 rotation 事件，如果在窗口内 → compact 可能仍在 retry 循环中。
+        """
+        from datetime import datetime as _dt, timezone as _tz, timedelta
+        log_paths = AgentSpawner._get_recent_gateway_logs()
+        if not log_paths:
+            return False
+
+        now = _dt.now(_tz.utc)
+        window_start = now - timedelta(seconds=window_seconds)
+
+        last_rotation_time = None
+
+        for log_path in log_paths:
+            if not os.path.exists(log_path):
+                continue
+            try:
+                with open(log_path, "rb") as f:
+                    f.seek(0, 2)
+                    size = f.tell()
+                    f.seek(max(0, size - 2 * 1024 * 1024))
+                    tail = f.read().decode("utf-8", errors="replace")
+            except Exception:
+                continue
+
+            for line in tail.splitlines():
+                if not line.strip():
+                    continue
+                try:
+                    obj = json.loads(line)
+                except (json.JSONDecodeError, ValueError):
+                    continue
+
+                msg = obj.get("message", "")
+                # 只看包含目标 sessionKey 的事件
+                if session_key not in msg:
+                    continue
+
+                # rotation 事件
+                if "[compaction] rotated active transcript" in msg:
+                    ts_str = obj.get("time", "")
+                    if ts_str:
+                        try:
+                            event_time = _dt.fromisoformat(
+                                ts_str.replace("Z", "+00:00"))
+                            # timezone-aware: normalize to UTC
+                            if event_time.tzinfo is None:
+                                event_time = event_time.replace(tzinfo=_tz.utc)
+                            if last_rotation_time is None or event_time > last_rotation_time:
+                                last_rotation_time = event_time
+                        except (ValueError, TypeError):
+                            continue
+
+        if last_rotation_time is not None:
+            return last_rotation_time >= window_start
+
+        return False
+
     @staticmethod
     def _check_recent_compaction_jsonl(
             session_file: str, window_seconds: int = 900) -> bool:
@@ -1413,16 +1497,123 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_
                     except Exception:
                         pass
 
-            # v2.8.1 Fix-1: compact 检测改用 session jsonl 末尾扫描
-            # 只在 agent 非空闲时才扫描(减少不必要 I/O)
-            if result["status"] not in (
-                    "done", "idle", "unknown", None) and sf:
-                result["recent_compact"] = AgentSpawner._check_recent_compaction_jsonl(
+            # §24 v4: compact 检测优先用 trajectory prompt.submitted
+            # fallback: _check_recent_compaction_jsonl (v2.8.2)
+            # 重要：compact 进行中时 status=done，所以不能按 status 过滤
+            # 只跳过 idle/unknown（完全没有活动过的 session）
+            if result["status"] not in ("idle", "unknown", None) and sf:
+                result["recent_compact"] = AgentSpawner._check_compact_in_progress_trajectory(
                     sf)
+                if not result["recent_compact"] and sf:
+                    result["recent_compact"] = AgentSpawner._check_recent_compaction_jsonl(
+                        sf)
         except Exception:
             pass
         return result
 
+    @staticmethod
+    def _check_compact_in_progress_trajectory(
+            session_file: str, timeout_minutes: int = 30) -> bool:
+        """§24 v4: 检查 trajectory jsonl 尾部，判断 session 是否处于非正常状态。
+
+        检测逻辑：最后一个完整 turn 没有 prompt.submitted/skipped → 非正常 → skip。
+        覆盖：compact、timeout、hook block、session 结束等所有非正常状态。
+
+        Returns:
+            True = 非正常状态（skip ticker）
+            False = 正常（不 skip）或超时兜底放行
+        """
+        if not session_file:
+            return False
+        traj_path = f"{session_file}.trajectory.jsonl"
+        if not os.path.exists(traj_path):
+            return False
+
+        try:
+            from datetime import datetime as _dt, timezone as _tz
+
+            # 读尾部 500KB
+            with open(traj_path, "rb") as f:
+                f.seek(0, 2)
+                size = f.tell()
+                f.seek(max(0, size - 500 * 1024))
+                tail = f.read().decode("utf-8", errors="replace")
+
+            if not tail.strip():
+                return False
+
+            # 解析所有有效行
+            events = []
+            for line in tail.splitlines():
+                line = line.strip()
+                if not line:
+                    continue
+                try:
+                    obj = json.loads(line)
+                    events.append(obj)
+                except (json.JSONDecodeError, ValueError):
+                    continue
+
+            if not events:
+                return False
+
+            # 按 session.started 分组找 turn
+            # 每个 turn 以 session.started 开始
+            turns = []
+            current_turn = []
+            for evt in events:
+                if evt.get("type") == "session.started":
+                    if current_turn:
+                        turns.append(current_turn)
+                    current_turn = [evt]
+                else:
+                    current_turn.append(evt)
+            if current_turn:
+                turns.append(current_turn)
+
+            if not turns:
+                return False
+
+            # 检查最后一个完整 turn（包含 session.started）
+            last_turn = turns[-1]
+            turn_types = {evt.get("type") for evt in last_turn}
+
+            # 有 prompt.submitted 或 prompt.skipped → 正常 turn
+            if "prompt.submitted" in turn_types or "prompt.skipped" in turn_types:
+                return False
+
+            # 非正常状态 → 检查超时兜底
+            # 找最后一个有 ts 的事件
+            last_ts = None
+            for evt in reversed(events):
+                ts_str = evt.get("ts")
+                if ts_str:
+                    try:
+                        last_ts = _dt.fromisoformat(
+                            ts_str.replace("Z", "+00:00"))
+                        if last_ts.tzinfo is None:
+                            last_ts = last_ts.replace(tzinfo=_tz.utc)
+                    except (ValueError, TypeError):
+                        continue
+                    break
+
+            if last_ts is None:
+                # 没有 ts 信息，无法判断超时 → 非正常 → skip
+                return True
+
+            now = _dt.now(_tz.utc)
+            elapsed = (now - last_ts).total_seconds()
+            if elapsed > timeout_minutes * 60:
+                logger.debug("Trajectory last event %.0fs ago > %dm, fallback pass",
+                             elapsed, timeout_minutes)
+                return False  # 兜底放行
+
+            return True  # 非正常状态且未超时
+
+        except Exception as e:
+            logger.debug("_check_compact_in_progress_trajectory error: %s", e)
+            return False
+
     @staticmethod
     def _classify_outcome(exit_code: int, json_result: dict, stderr_text: str,
                           task_status: Optional[str], stdout_text: str = "") -> dict:

src/daemon/toolchain_templates.py

@@ -23,6 +23,7 @@ _TEMPLATE_MAP: Dict[str, str] = {
     "deploy_failure": "deploy_failure.md",
     "review_updated": "review_updated.md",
     "review_comment": "review_comment.md",
+    "review_merged": "review_merged.md",
 }
 
 # 模板缓存

templates/toolchain/review_merged.md

@@ -0,0 +1,8 @@
+## PR 已合并 ✅
+
+**仓库**: {repo}
+**PR #{pr_number}**: {pr_title}
+**作者**: @{pr_author}
+**合并者**: @{merged_by}
+
+PR 已成功合并到主分支。

tests/test_spawner_compact.py

@@ -0,0 +1,184 @@
+"""单元测试：§24 v4 trajectory prompt.submitted compact 检测
+
+测试 _check_compact_in_progress_trajectory 方法。
+用 tmp_path 构造 mock trajectory jsonl 文件。
+"""
+
+import json
+from datetime import datetime, timedelta, timezone
+from pathlib import Path
+
+import pytest
+
+from src.daemon.spawner import AgentSpawner
+
+
+# ── helpers ──
+
+_SESSION_ID = "sess-abc123"
+
+
+def _make_trajectory_event(event_type: str, ts: str = None, **kwargs) -> dict:
+    """构造 trajectory jsonl 事件"""
+    obj = {"type": event_type}
+    if ts:
+        obj["ts"] = ts
+    obj.update(kwargs)
+    return obj
+
+
+def _write_trajectory(tmp_path: Path, session_id: str, turns: list[list[dict]]):
+    """写入 trajectory jsonl，按 turns 分组。
+
+    每个 turn 是一个 list of events。
+    自动在每组前加 session.started（如果该 turn 没有的话）。
+    """
+    traj_file = tmp_path / f"{session_id}.trajectory.jsonl"
+    with open(traj_file, "w") as f:
+        for turn_events in turns:
+            # 如果 turn 第一个事件不是 session.started，自动加一个
+            if not turn_events or turn_events[0].get("type") != "session.started":
+                started = _make_trajectory_event(
+                    "session.started",
+                    ts=turn_events[0].get("ts") if turn_events else None,
+                )
+                f.write(json.dumps(started, ensure_ascii=False) + "\n")
+            for evt in turn_events:
+                f.write(json.dumps(evt, ensure_ascii=False) + "\n")
+
+
+def _utc_now_str() -> str:
+    """返回当前 UTC 时间的 ISO 字符串（带 Z 后缀）"""
+    return datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%S.") + \
+        f"{datetime.now(timezone.utc).microsecond // 1000:03d}Z"
+
+
+def _utc_past_str(minutes_ago: int) -> str:
+    """返回过去 N 分钟的 UTC ISO 字符串"""
+    ts = datetime.now(timezone.utc) - timedelta(minutes=minutes_ago)
+    return ts.strftime("%Y-%m-%dT%H:%M:%S.") + \
+        f"{ts.microsecond // 1000:03d}Z"
+
+
+# ── 测试用例 ──
+
+
+class TestCheckCompactInProgressTrajectory:
+    """§24 v4: _check_compact_in_progress_trajectory 单元测试"""
+
+    def test_tc1_normal_turn_with_submitted_returns_false(self, tmp_path):
+        """TC1: 正常 turn（有 prompt.submitted）→ False"""
+        now = _utc_now_str()
+        turns = [[
+            _make_trajectory_event("session.started", ts=now),
+            _make_trajectory_event("context.compiled", ts=now),
+            _make_trajectory_event("prompt.submitted", ts=now),
+            _make_trajectory_event("model.completed", ts=now),
+        ]]
+        _write_trajectory(tmp_path, _SESSION_ID, turns)
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is False
+
+    def test_tc2_compact_turn_returns_true(self, tmp_path):
+        """TC2: compact turn（无 prompt.submitted，有 context.compiled + model.completed）→ True"""
+        now = _utc_now_str()
+        turns = [[
+            _make_trajectory_event("session.started", ts=now),
+            _make_trajectory_event("context.compiled", ts=now),
+            _make_trajectory_event("model.completed", ts=now),
+        ]]
+        _write_trajectory(tmp_path, _SESSION_ID, turns)
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is True
+
+    def test_tc3_skipped_prompt_returns_false(self, tmp_path):
+        """TC3: 空白 prompt（有 prompt.skipped）→ False"""
+        now = _utc_now_str()
+        turns = [[
+            _make_trajectory_event("session.started", ts=now),
+            _make_trajectory_event("context.compiled", ts=now),
+            _make_trajectory_event("prompt.skipped", ts=now),
+            _make_trajectory_event("model.completed", ts=now),
+        ]]
+        _write_trajectory(tmp_path, _SESSION_ID, turns)
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is False
+
+    def test_tc4_timeout_fallback_returns_false(self, tmp_path):
+        """TC4: 超过 30min 兜底 → False"""
+        old = _utc_past_str(35)
+        turns = [[
+            _make_trajectory_event("session.started", ts=old),
+            _make_trajectory_event("context.compiled", ts=old),
+            _make_trajectory_event("model.completed", ts=old),
+        ]]
+        _write_trajectory(tmp_path, _SESSION_ID, turns)
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is False
+
+    def test_tc5_trajectory_not_exists_returns_false(self, tmp_path):
+        """TC5: trajectory 不存在 → False"""
+        session_file = str(tmp_path / "nonexistent-session")
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is False
+
+    def test_tc6_empty_trajectory_returns_false(self, tmp_path):
+        """TC6: 空 trajectory → False"""
+        traj_file = tmp_path / f"{_SESSION_ID}.trajectory.jsonl"
+        traj_file.write_text("")
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is False
+
+    def test_tc7_multi_turn_last_normal_returns_false(self, tmp_path):
+        """TC7: 多 turn 尾部只看最后一个（最后一个正常但之前有 compact）→ False"""
+        old = _utc_past_str(10)
+        now = _utc_now_str()
+        turn1 = [
+            _make_trajectory_event("session.started", ts=old),
+            _make_trajectory_event("context.compiled", ts=old),
+            _make_trajectory_event("model.completed", ts=old),  # compact turn, no prompt
+        ]
+        turn2 = [
+            _make_trajectory_event("session.started", ts=now),
+            _make_trajectory_event("prompt.submitted", ts=now),
+            _make_trajectory_event("model.completed", ts=now),  # normal turn
+        ]
+        _write_trajectory(tmp_path, _SESSION_ID, [turn1, turn2])
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is False
+
+    def test_tc8_multi_turn_last_abnormal_returns_true(self, tmp_path):
+        """TC8: 多 turn 尾部最后一个非正常 → True"""
+        old = _utc_past_str(5)
+        now = _utc_now_str()
+        turn1 = [
+            _make_trajectory_event("session.started", ts=old),
+            _make_trajectory_event("prompt.submitted", ts=old),
+            _make_trajectory_event("model.completed", ts=old),  # normal turn
+        ]
+        turn2 = [
+            _make_trajectory_event("session.started", ts=now),
+            _make_trajectory_event("context.compiled", ts=now),
+            _make_trajectory_event("model.completed", ts=now),  # compact turn, no prompt
+        ]
+        _write_trajectory(tmp_path, _SESSION_ID, [turn1, turn2])
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is True
+
+    def test_tc9_null_session_file_returns_false(self):
+        """TC9: session_file 为空字符串 → False"""
+        assert AgentSpawner._check_compact_in_progress_trajectory("") is False
+
+    def test_tc10_none_session_file_returns_false(self):
+        """TC10: session_file 为 None → False"""
+        assert AgentSpawner._check_compact_in_progress_trajectory(None) is False
+
+    def test_tc11_events_without_ts_returns_true(self, tmp_path):
+        """TC11: 事件有 type 但无 ts 字段 → 无法判断超时 → True（skip）"""
+        turns = [[
+            _make_trajectory_event("session.started"),  # 无 ts
+            _make_trajectory_event("context.compiled"),  # 无 ts
+            _make_trajectory_event("model.completed"),  # 无 ts
+        ]]
+        _write_trajectory(tmp_path, _SESSION_ID, turns)
+        session_file = str(tmp_path / _SESSION_ID)
+        assert AgentSpawner._check_compact_in_progress_trajectory(session_file) is True