[codex] Add NovelPro author workbench enhancements

.env.example

@@ -32,6 +32,10 @@ EMBEDDING_USE_GPU=true
 # ── Vector Store Configuration ──
 VECTOR_STORE_TYPE=chromadb
 
+# ── NovelPro Obsidian Long-Term Memory ──
+# 留空时默认写入 data/obsidian-vault；如需接入自己的 Obsidian Vault，填绝对路径并重启后端。
+# PLOTPILOT_OBSIDIAN_VAULT=/Users/you/Documents/Obsidian/PlotPilot
+
 # 日志配置
 LOG_LEVEL=INFO  # DEBUG, INFO, WARNING, ERROR, CRITICAL
 LOG_FILE=logs/aitext.log

.github/workflows/backend-ci.yml

@@ -1,29 +1,50 @@
 name: Backend CI
 
 on:
+  push:
+    paths:
+      - "**.py"
+      - "requirements*.txt"
+      - "pyproject.toml"
+      - "pytest.ini"
+      - ".github/workflows/backend-ci.yml"
   pull_request:
     paths:
       - "**.py"
       - "requirements*.txt"
       - "pyproject.toml"
       - "pytest.ini"
+      - ".github/workflows/backend-ci.yml"
+  workflow_dispatch:
 
 jobs:
   test:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@v6
 
-      - uses: actions/setup-python@v5
+      - uses: actions/setup-python@v6
         with:
           python-version: "3.11"
           cache: "pip"
 
       - name: Install dependencies
         run: pip install -r requirements.txt
 
-      - name: Run unit tests
-        run: pytest tests/unit -q --tb=short
+      - name: Run verified backend workflow tests
+        run: >
+          pytest
+          tests/unit/application/services/test_continuity_overview_service.py
+          tests/unit/application/services/test_power_system_service.py
+          tests/integration/interfaces/api/v1/test_continuity_api.py
+          tests/integration/interfaces/api/v1/test_power_system_api.py
+          tests/unit/infrastructure/persistence/database/test_sqlite_chapter_candidate_draft_repository.py
+          tests/unit/application/services/test_chapter_candidate_draft_service.py
+          tests/unit/application/services/test_chapter_service.py
+          tests/unit/application/services/test_chronicles_service.py
+          tests/integration/interfaces/api/v1/test_chapter_candidate_drafts_api.py
+          -q
+          --tb=short
         env:
           # 单测不需要真实 key，用占位值防止启动时报错
           ANTHROPIC_API_KEY: "test-placeholder"

.github/workflows/frontend-ci.yml

@@ -1,9 +1,15 @@
 name: Frontend CI
 
 on:
+  push:
+    paths:
+      - "frontend/**"
+      - ".github/workflows/frontend-ci.yml"
   pull_request:
     paths:
       - "frontend/**"
+      - ".github/workflows/frontend-ci.yml"
+  workflow_dispatch:
 
 jobs:
   build:
@@ -13,9 +19,9 @@ jobs:
         working-directory: frontend
 
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@v6
 
-      - uses: actions/setup-node@v4
+      - uses: actions/setup-node@v6
         with:
           node-version: "20"
           cache: "npm"

.gitignore

@@ -17,6 +17,7 @@ __pycache__/
 .hypothesis/
 .venv/
 venv/
+/uv.lock
 *.egg-info/
 .eggs/
 dist/
@@ -39,6 +40,9 @@ frontend/dist/
 .playwright-mcp/
 .claude/
 .trae/
+.worktrees/
+agent_memory/
+LOCAL_DEVELOPMENT.md
 
 # ── 覆盖率 / 测试产物 ──
 .coverage
@@ -88,6 +92,11 @@ scripts/evaluation/results/
 data/chromadb/
 data/logs/
 data/llm_configs.json
+data/obsidian-vault/
+data/obsidian-vault-backups/
+.obsidian-sync.lock/
+scripts/sync_obsidian_from_server.sh
+scripts/launchd/com.plotpilot.novelpro.obsidian-sync.plist
 
 # ── 日志 ──
 logs/
@@ -114,6 +123,7 @@ base_library.zip
 
 # ── 临时 / 无关文件 ──
 =++Contribution Value Roster++=
+# Contributors: xibian-YQ, JamesGoslings
 
 # ── PlotPilot 残留 ──
 PlotPilot-master/
@@ -123,8 +133,12 @@ llm_profiles.json
 aitext.lock
 scripts/aitext.lock
 
-# ── Tauri 桌面壳（仅本机打包用，勿提交；协作者 clone 后无此目录，不影响 npm run dev） ──
-frontend/src-tauri/
+# ── Tauri 桌面壳 ──
+# 提交源码，忽略构建产物
+frontend/src-tauri/target/
+frontend/src-tauri/Cargo.lock
+frontend/src-tauri/scripts/
+frontend/src-tauri/tools/
 
 # ── 仅本机 Windows 打包链路（协作者只需 npm run dev + 后端） ──
 scripts/build_installer.py
@@ -150,3 +164,9 @@ mcps/
 *.rs.bk
 *.orig
 *.rej
+
+# ── 本地执行计划 / Agent 过程文档 ──
+docs/superpowers/plans/2026-04-27-p1-candidate-drafts.md
+docs/superpowers/plans/2026-04-29-topic-idea-incubation.md
+docs/superpowers/plans/2026-04-29-topic-idea-report.md
+docs/superpowers/specs/2026-04-29-topic-idea-incubation-design.md

=++Contribution Value Roster++=

@@ -17,3 +17,8 @@
 16	wfnysse		https://github.com/wfnysse
 17 https://github.com/Kobe9312  1Kobe9312   
 18 https://github.com/zeroranyi zeroranyi
+19	bugmaker2		https://github.com/bugmaker2
+20	haoziyouxia		https://github.com/haoziyouxia
+21	LuoFengXiaoXiao		https://github.com/LuoFengXiaoXiao
+22	droid-Q		https://github.com/droid-Q
+23	semir0037-source		https://github.com/semir0037-source

README.md

@@ -18,6 +18,7 @@
 - **知识图谱**：自动提取故事三元组，语义检索历史内容。
 - **伏笔台账**：追踪并自动闭合叙事钩子。
 - **风格分析**：作者声音漂移检测与文体指纹。
+- **NovelPro 作者工作台**：选题立项、候选稿、连续性巡检、战力系统、Obsidian 长期记忆与监控中心。详见 [docs/NOVELPRO_README.md](docs/NOVELPRO_README.md)。
 - **节拍表与故事结构**：三幕式、章节节拍规划。
 - **DDD 四层架构**：`domain` / `application` / `infrastructure` / `interfaces`
 

application/ai/embedding_config_service.py

@@ -157,8 +157,9 @@ def update_config(self, **kwargs) -> EmbeddingConfigModel:
         params.append("default")  # WHERE id = ?
 
         sql = f"UPDATE embedding_config SET {', '.join(set_clauses)} WHERE id = ?"
-        db.execute(sql, params)
-        db.get_connection().commit()
+        conn = db.get_connection()
+        conn.execute(sql, tuple(params))
+        conn.commit()
 
         logger.info("EmbeddingConfigService: 配置已更新，字段: %s", list(kwargs.keys()))
         return self.get_config()

application/ai/llm_json_extract.py

@@ -89,7 +89,7 @@ def _do_repair(s: str) -> str:
 
         if in_string:
             res += '"'
-        res = res.strip()
+        res = ''.join(res).strip()
         while res.endswith(','):
             res = res[:-1].strip()
         while stack:

application/analyst/services/coc_canon_service.py

@@ -0,0 +1,195 @@
+"""CoC 正典注册表服务。"""
+from __future__ import annotations
+
+from typing import Any, Mapping, Optional
+
+
+class CocCanonService:
+    """管理 CoC 正典条目与章节证据。"""
+
+    def __init__(self, repository):
+        self.repository = repository
+
+    def get_overview(self, novel_id: str) -> dict[str, Any]:
+        entries = self.repository.list_entries(novel_id)
+        events = self.repository.list_events(novel_id, limit=100)
+        return {
+            "novel_id": novel_id,
+            "entries": entries,
+            "recent_events": events,
+            "cognition_layers": self.get_cognition_layers(novel_id),
+        }
+
+    def get_cognition_layers(self, novel_id: str) -> dict[str, list[str]]:
+        entries = [
+            item
+            for item in self.repository.list_entries(novel_id)
+            if str(item.get("status") or "").strip() != "archived"
+        ]
+        author_truth: list[str] = []
+        reader_known: list[str] = []
+        author_truth_snippets: list[str] = []
+        for item in entries:
+            title = str(item.get("title") or "").strip() or "未命名条目"
+            public_facts = str(item.get("public_facts") or "").strip()
+            hidden_truth = str(item.get("hidden_truth") or "").strip()
+            if public_facts:
+                reader_known.append(f"{title}：{public_facts}")
+            if hidden_truth:
+                author_truth.append(f"{title}：{hidden_truth}")
+                if len(hidden_truth) >= 8 and hidden_truth not in author_truth_snippets:
+                    author_truth_snippets.append(hidden_truth[:80])
+        return {
+            "author_truth": author_truth[:24],
+            "reader_known": reader_known[:24],
+            "author_truth_snippets": author_truth_snippets[:40],
+        }
+
+    def upsert_entry(
+        self,
+        *,
+        novel_id: str,
+        canon_type: str,
+        title: str,
+        public_facts: str = "",
+        hidden_truth: str = "",
+        lock_level: str = "soft",
+        mutable_notes: str = "",
+        status: str = "active",
+        entry_id: Optional[str] = None,
+    ) -> dict[str, Any]:
+        clean_canon_type = canon_type.strip()
+        clean_title = title.strip()
+        if not clean_canon_type:
+            raise ValueError("canon_type is required")
+        if not clean_title:
+            raise ValueError("title is required")
+
+        existing = self.repository.get_entry_by_id(entry_id) if entry_id else self.repository.get_entry_by_key(
+            novel_id,
+            clean_canon_type,
+            clean_title,
+        )
+        if existing is not None and existing.get("novel_id") != novel_id:
+            raise ValueError("entry does not belong to novel")
+
+        incoming = {
+            "canon_type": clean_canon_type,
+            "title": clean_title,
+            "public_facts": public_facts.strip(),
+            "hidden_truth": hidden_truth.strip(),
+            "lock_level": self._normalize_lock_level(lock_level),
+            "mutable_notes": mutable_notes.strip(),
+            "status": self._normalize_status(status),
+        }
+        self.lock_guard_validate_patch(existing, incoming)
+        return self.repository.upsert_entry(
+            entry_id=existing["id"] if existing else None,
+            novel_id=novel_id,
+            canon_type=incoming["canon_type"],
+            title=incoming["title"],
+            public_facts=incoming["public_facts"],
+            hidden_truth=incoming["hidden_truth"],
+            lock_level=incoming["lock_level"],
+            mutable_notes=incoming["mutable_notes"],
+            status=incoming["status"],
+        )
+
+    def create_event(
+        self,
+        *,
+        novel_id: str,
+        entry_id: str = "",
+        title: str = "",
+        chapter_number: int,
+        event_type: str = "mention",
+        evidence: str = "",
+        notes: str = "",
+    ) -> dict[str, Any]:
+        clean_entry_id = str(entry_id or "").strip()
+        clean_title = str(title or "").strip()
+        chapter = int(chapter_number)
+        if chapter < 1:
+            raise ValueError("chapter_number must be greater than 0")
+        if not clean_entry_id and not clean_title:
+            raise ValueError("entry_id or title is required")
+
+        entry = None
+        if clean_entry_id:
+            entry = self.repository.get_entry_by_id(clean_entry_id)
+        elif clean_title:
+            entry = self.repository.get_entry_by_title(novel_id, clean_title)
+            if entry is None:
+                entry = self.upsert_entry(
+                    novel_id=novel_id,
+                    canon_type="other",
+                    title=clean_title,
+                    public_facts="",
+                    hidden_truth="",
+                    lock_level="soft",
+                    mutable_notes="自动创建：由事件记录补建条目。",
+                    status="draft",
+                )
+        if entry is None:
+            raise ValueError("entry not found")
+        if entry.get("novel_id") != novel_id:
+            raise ValueError("entry does not belong to novel")
+        return self.repository.create_event(
+            entry_id=str(entry.get("id") or clean_entry_id),
+            chapter_number=chapter,
+            event_type=(event_type or "mention").strip() or "mention",
+            evidence=evidence.strip(),
+            notes=notes.strip(),
+        )
+
+    @staticmethod
+    def lock_guard_validate_patch(
+        existing: Optional[Mapping[str, Any]],
+        incoming: Mapping[str, Any],
+    ) -> None:
+        if not existing:
+            return
+        if str(existing.get("lock_level") or "").strip() != "absolute":
+            return
+
+        protected_fields = ("public_facts", "hidden_truth", "title", "canon_type")
+        for field in protected_fields:
+            old_value = str(existing.get(field) or "")
+            new_value = str(incoming.get(field) or "")
+            if old_value != new_value:
+                raise ValueError(f"absolute lock forbids changing `{field}`")
+
+    def build_overlay(self, novel_id: str) -> str:
+        entries = [
+            item
+            for item in self.repository.list_entries(novel_id)
+            if str(item.get("status") or "active").strip() != "archived"
+        ]
+        if not entries:
+            return "【CoC正典（必须保持一致）】\n- 暂无已登记正典。"
+
+        lines = ["【CoC正典（必须保持一致）】"]
+        for item in entries:
+            lines.append(
+                f"- [{item.get('canon_type', '')}] {item.get('title', '')}（锁定：{item.get('lock_level', 'soft')}）"
+            )
+            public_facts = str(item.get("public_facts") or "").strip()
+            hidden_truth = str(item.get("hidden_truth") or "").strip()
+            mutable_notes = str(item.get("mutable_notes") or "").strip()
+            if public_facts:
+                lines.append(f"  公共事实：{public_facts}")
+            if hidden_truth:
+                lines.append(f"  隐藏真相：{hidden_truth}")
+            if mutable_notes:
+                lines.append(f"  可变备注：{mutable_notes}")
+        return "\n".join(lines)
+
+    @staticmethod
+    def _normalize_lock_level(value: str) -> str:
+        normalized = (value or "").strip().lower()
+        return normalized if normalized in {"soft", "strict", "absolute"} else "soft"
+
+    @staticmethod
+    def _normalize_status(value: str) -> str:
+        normalized = (value or "").strip().lower()
+        return normalized if normalized in {"active", "draft", "archived"} else "active"