diff --git a/.claude/skills/db/scripts/sync_agent_registry.py b/.claude/skills/db/scripts/sync_agent_registry.py new file mode 100644 index 0000000..77a50b9 --- /dev/null +++ b/.claude/skills/db/scripts/sync_agent_registry.py @@ -0,0 +1,97 @@ +#!/usr/bin/env python3 +"""智能体/技能登记脚本——把 Git 侧的 agent/skill 元数据影子进库,供看板只读。 + +落库设计 §2.10 的 A 方案: +- Git 侧(.claude/agents/*.md、.claude/skills/*/SKILL.md)仍是配置权威; +- 本脚本抽取 frontmatter(name/description/model/tools)+ 尽力抽取涉及的表名, + upsert 进 example_agent_role / example_skill; +- 看板只读登记表、不读 Git。幂等可重跑(upsert),配置变更后重跑即同步。 + +跑法(仓库根目录):.venv/bin/python .claude/skills/db/scripts/sync_agent_registry.py +""" +import json +import re +from pathlib import Path + +from db import connect # 复用锁死的 DSN(与 db.py 同目录,脚本目录自动在 sys.path) + +ROOT = Path(__file__).resolve().parents[4] # .claude/skills/db/scripts → 仓库根 +AGENTS_DIR = ROOT / ".claude" / "agents" +SKILLS_DIR = ROOT / ".claude" / "skills" +TABLE_RE = re.compile(r"\b(muse_[a-z_]+|example_[a-z_]+)\b") + + +def parse_frontmatter(text: str) -> dict: + """解析开头 --- 围栏内的 frontmatter 为 key->字符串(每行按第一个冒号切,值可含冒号/逗号)。""" + lines = text.splitlines() + if not lines or lines[0].strip() != "---": + return {} + fm = {} + for line in lines[1:]: + if line.strip() == "---": + break + if ":" in line: + k, _, v = line.partition(":") + fm[k.strip()] = v.strip() + return fm + + +def sync_roles(conn) -> int: + n = 0 + for md in sorted(AGENTS_DIR.glob("*.md")): + fm = parse_frontmatter(md.read_text(encoding="utf-8")) + role = fm.get("name") or md.stem + desc = fm.get("description", "") + display = desc.split("——", 1)[0].strip() or None # "网文写手——…" 取破折号前作显示名 + tools_raw = fm.get("tools") + tools = json.dumps([t.strip() for t in tools_raw.split(",") if t.strip()], + ensure_ascii=False) if tools_raw else None + conn.execute( + """INSERT INTO example_agent_role + (role, display_name, model, tools, responsibility, source_ref, synced_at, creator, updater) + VALUES (%s,%s,%s,%s::jsonb,%s,%s,CURRENT_TIMESTAMP,'sync_agent_registry','sync_agent_registry') + ON CONFLICT (tenant_id, role) DO UPDATE SET + display_name=EXCLUDED.display_name, model=EXCLUDED.model, tools=EXCLUDED.tools, + responsibility=EXCLUDED.responsibility, source_ref=EXCLUDED.source_ref, + synced_at=CURRENT_TIMESTAMP, updater='sync_agent_registry'""", + (role, display, fm.get("model"), tools, desc or None, str(md.relative_to(ROOT)))) + n += 1 + return n + + +def sync_skills(conn) -> int: + n = 0 + for sk in sorted(SKILLS_DIR.glob("*/SKILL.md")): + text = sk.read_text(encoding="utf-8") + fm = parse_frontmatter(text) + name = fm.get("name") or sk.parent.name + tables = sorted(set(TABLE_RE.findall(text))) # 尽力抽取涉及的表名(不区分读写,待人工核) + model_used = None + if "MiniMax" in text: + model_used = "MiniMax-M3" + elif re.search(r"\bopus\b", text): + model_used = "opus" + conn.execute( + """INSERT INTO example_skill + (skill_name, purpose, reads, model_used, source_ref, synced_at, creator, updater) + VALUES (%s,%s,%s::jsonb,%s,%s,CURRENT_TIMESTAMP,'sync_agent_registry','sync_agent_registry') + ON CONFLICT (tenant_id, skill_name) DO UPDATE SET + purpose=EXCLUDED.purpose, reads=EXCLUDED.reads, model_used=EXCLUDED.model_used, + source_ref=EXCLUDED.source_ref, synced_at=CURRENT_TIMESTAMP, updater='sync_agent_registry'""", + (name, fm.get("description"), + json.dumps(tables, ensure_ascii=False) if tables else None, + model_used, str(sk.relative_to(ROOT)))) + n += 1 + return n + + +def main(): + with connect() as conn: + nr = sync_roles(conn) + ns = sync_skills(conn) + conn.commit() + print(f"已登记 {nr} 个角色、{ns} 个技能 → example_agent_role / example_skill") + + +if __name__ == "__main__": + main() diff --git a/db/ddl/102-example智能体技能登记.sql b/db/ddl/102-example智能体技能登记.sql new file mode 100644 index 0000000..5a25a24 --- /dev/null +++ b/db/ddl/102-example智能体技能登记.sql @@ -0,0 +1,52 @@ +-- 智能体与技能登记表:example_agent_role(5 角色)+ example_skill(24 技能)。 +-- 设计拍板 2026-07-30(docs/2026-07-30-落库与看板设计.md §2.10,A 方案)。 +-- 用途:看板"智能体"空间的数据源。这些元数据的**权威在 Git 侧**(.claude/agents/*.md、 +-- .claude/skills/*/SKILL.md);本表是 Git 权威在库内的**影子**(类比 muse_meta_function_chain +-- 是 meta/chains 的库内影子),由登记脚本 sync_agent_registry.py 从 Git 抽取 upsert, +-- 看板只读本表、不读 Git(守住看板只读库的合同)。Git 仍是配置权威。 +-- 两表都是可变表(配置变更=更新行),带公共列六件套 + updated_at 触发器。 +-- 全部对象 IF NOT EXISTS / OR REPLACE,重复 apply 幂等。 + +-- ══ example_agent_role:角色登记(writer/planner/extractor/detector/judge)══ +CREATE TABLE IF NOT EXISTS example_agent_role ( + id BIGINT GENERATED ALWAYS AS IDENTITY PRIMARY KEY, + role VARCHAR(32) NOT NULL, -- 角色标识(writer/planner/extractor/detector/judge) + display_name VARCHAR(64), -- 显示名(从 description 的"——"前截取) + model VARCHAR(64), -- 模型归属(opus/其它,见 AGENTS §6 角色模型归属) + effort VARCHAR(16), -- 推理力度(可配置项,暂空) + budget_usd NUMERIC(14,8), -- 预算(可配置项,暂空) + tools JSONB, -- 可用工具(如 ["Read","Write","Grep","Glob"]) + responsibility TEXT, -- 职责白话描述(= frontmatter description) + source_ref VARCHAR(256), -- Git 侧 .md 路径(出处可溯) + synced_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, -- 最近一次从 Git 同步时间 + creator VARCHAR(64) NOT NULL DEFAULT '', + create_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, + updater VARCHAR(64) NOT NULL DEFAULT '', + update_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, + deleted BOOLEAN NOT NULL DEFAULT FALSE, + tenant_id BIGINT NOT NULL DEFAULT 0, + CONSTRAINT uk_example_agent_role UNIQUE (tenant_id, role) +); +CREATE OR REPLACE TRIGGER trg_example_agent_role_updated_at BEFORE UPDATE ON example_agent_role FOR EACH ROW EXECUTE FUNCTION update_updated_at_column(); + +-- ══ example_skill:技能登记(24 个 skill)══ +CREATE TABLE IF NOT EXISTS example_skill ( + id BIGINT GENERATED ALWAYS AS IDENTITY PRIMARY KEY, + skill_name VARCHAR(64) NOT NULL, -- 技能标识(= skill 目录名 / frontmatter name) + purpose TEXT, -- 一句话用途(= frontmatter description) + consumer VARCHAR(64), -- 给谁用(主会话/某角色/其它 skill,暂空待补) + reads JSONB, -- 读哪些表(登记脚本自动抽取表名,待人工核读写方向) + writes JSONB, -- 写哪些表(待人工核;自动抽取不区分读写,暂空) + red_lines TEXT, -- 红线(待人工补) + model_used VARCHAR(64), -- 用模型则记(MiniMax-M3/opus…),确定性工具为空 + source_ref VARCHAR(256), -- SKILL.md 路径(出处可溯) + synced_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, + creator VARCHAR(64) NOT NULL DEFAULT '', + create_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, + updater VARCHAR(64) NOT NULL DEFAULT '', + update_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, + deleted BOOLEAN NOT NULL DEFAULT FALSE, + tenant_id BIGINT NOT NULL DEFAULT 0, + CONSTRAINT uk_example_skill UNIQUE (tenant_id, skill_name) +); +CREATE OR REPLACE TRIGGER trg_example_skill_updated_at BEFORE UPDATE ON example_skill FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();