fix: cleanup dead code + extend diff to all nodes

- Remove unused validate_chat_article_markdown() from validators.py
- Remove _sync_chat_to_state residual comment block
- Add 'writer' to _node_official_artifact_path() mapping
- Extend /runs/{run_id}/diff endpoint with ?node= param for all nodes
- Save .prev files for all artifact nodes in review chat (not just writer)
- Delegate api.py _node_session_key to nodes.py (single source of truth)

Author: PPPPanda

scripts/validators.py

@@ -338,46 +338,6 @@ def validate_writer_markdown(text: str, min_chars: int = 1200) -> ValidationResu
     return ValidationResult(ok=True, parsed=raw, normalized_text=raw + "\n")
 
 
-def validate_chat_article_markdown(text: str, min_chars: int = 800) -> ValidationResult:
-    raw = _strip_code_fence(text).strip()
-    details: list[str] = []
-    bad_markers = [
-        "微信文章无法直接提取",
-        "基于",
-        "我直接修改",
-        "根据你的要求",
-        "下面是修改后的",
-        "以下是修改后的",
-        "我会按这个风格",
-        "已按",
-        "我已经根据",
-        "让我根据",
-        "已重写",
-        "主要调整",
-        "风格特点是",
-    ]
-
-    if len(raw) < min_chars:
-        details.append(f"content too short: {len(raw)} chars (< {min_chars})")
-
-    head = raw[:500]
-    for marker in bad_markers:
-        if marker in head:
-            details.append(f"meta marker near opening: {marker}")
-
-    paragraphs = [p.strip() for p in re.split(r"\n\s*\n", raw) if p.strip()]
-    if len(paragraphs) < 4:
-        details.append(f"too few paragraphs: {len(paragraphs)}")
-
-    heading_count = sum(1 for line in raw.splitlines() if line.strip().startswith("## "))
-    if heading_count < 2:
-        details.append(f"too few section headings: {heading_count}")
-
-    if details:
-        return ValidationResult(ok=False, message="chat article failed quality checks", details=details)
-    return ValidationResult(ok=True, parsed=raw, normalized_text=raw + "\n")
-
-
 def validate_de_ai_markdown(text: str, original_text: str) -> ValidationResult:
     raw = _strip_code_fence(text).strip()
     details: list[str] = []

scripts/web/routes/api.py

@@ -54,6 +54,7 @@ def _node_official_artifact_path(run_id: str, node_id: str) -> Path | None:
     mapping = {
         "scout": run_dir / "topic.yaml",
         "researcher": run_dir / "research.yaml",
+        "writer": run_dir / "article_edited.md",
         "director": run_dir / "visual_plan.json",
         "formatter": run_dir / "formatted.html",
     }
@@ -486,27 +487,45 @@ async def api_save_article(run_id: str, body: dict):
 
 
 @router.get("/runs/{run_id}/diff")
-async def api_get_diff(run_id: str):
-    """获取文章改动 diff（当前 vs 上一版本）"""
+async def api_get_diff(run_id: str, node: str | None = None):
+    """获取节点改动 diff（当前 vs 上一版本）。
+
+    ?node=scout  → topic.yaml diff
+    ?node=writer → article_edited.md diff (default)
+    ?node=researcher → research.yaml diff
+    ?node=director → visual_plan.json diff
+    ?node=formatter → formatted.html diff
+    """
     import difflib
 
     run_dir = Path(__file__).parent.parent.parent.parent / "output" / "runs" / run_id
-    current_path = run_dir / "article_edited.md"
-    prev_path = run_dir / "article_edited.md.prev"
-    draft_path = run_dir / "article_draft.md"
+
+    # 确定要 diff 的文件
+    if node and node != "writer":
+        artifact_path = _node_official_artifact_path(run_id, node)
+        if not artifact_path:
+            return JSONResponse({"error": f"未知节点: {node}"}, status_code=400)
+        current_path = artifact_path
+        prev_path = run_dir / f"{artifact_path.name}.prev"
+        draft_path = None
+    else:
+        # 默认: writer article
+        current_path = run_dir / "article_edited.md"
+        prev_path = run_dir / "article_edited.md.prev"
+        draft_path = run_dir / "article_draft.md"
 
     if not current_path.exists():
-        return JSONResponse({"error": "当前文章不存在"}, status_code=404)
+        return JSONResponse({"error": f"当前产物不存在: {current_path.name}"}, status_code=404)
 
-    # 优先用 .prev（上一次审核改稿前的版本），fallback 用 article_draft.md（初稿）
+    # 优先用 .prev，fallback 用 draft（仅 writer）
     if prev_path.exists():
         base_path = prev_path
         from_label = "上一版本"
-    elif draft_path.exists():
+    elif draft_path and draft_path.exists():
         base_path = draft_path
         from_label = "初稿"
     else:
-        return JSONResponse({"diff": None, "message": "暂无历史版本"})
+        return JSONResponse({"diff": None, "has_diff": False, "message": "暂无历史版本"})
 
     current = current_path.read_text(encoding="utf-8").splitlines(keepends=True)
     previous = base_path.read_text(encoding="utf-8").splitlines(keepends=True)
@@ -518,7 +537,7 @@ async def api_get_diff(run_id: str):
         lineterm=""
     )
     diff_text = "\n".join(diff)
-    return {"diff": diff_text}
+    return {"diff": diff_text, "has_diff": bool(diff_text.strip())}
 
 
 # ── 节点数据 ──────────────────────────────────────────────────
@@ -1276,12 +1295,6 @@ async def api_update_settings_form(request: Request):
     )
 
 
-# ── 审核对话同步 ──────────────────────────────────────────────
-
-# 旧的 _sync_chat_to_state 链路已退役：
-# 审核聊天现在直接由节点主 session 修改正式产物，再由 Python 读回并提交。
-
-
 # ── 内部函数 ──────────────────────────────────────────────────
 
 async def _execute_pipeline(run_id: str):