if (!threadId) await startThread();
    const turn = { threadId, id: null, answers: new Map(), buffer: [], completed: Promise.withResolvers() };
    turn.completed.promise.catch(() => {});
    activeTurn = turn;
    const timer = setTimeout(() => fail(new Error("App Server 本轮调用超时；已停止连接，实际执行状态需检查日志，不自动重发。")), launch.timeoutMs);
    console.log("正在等待模型回复……");
    try {
      const result = await request("turn/start", {
        threadId, input: [{ type: "text", text: prompt, text_elements: [] }]
      });

      const selected = /^\d+$/.test(value) ? threads[Number(value) - 1] : undefined;
      if (!selected) { console.log("请输入列表中有效的会话编号。"); continue; }
      if (selected.id === threadId) { console.log("这就是当前会话，可以继续聊天。"); return false; }
      await ensureThreadDirectory(root, selected.cwd);
      const result = await request("thread/resume", {
        ...threadOptions, threadId: selected.id, cwd: selected.cwd, excludeTurns: true
      });
      selectThread(result);
      console.log("已恢复会话：", safeTitle(selected.name || selected.preview));
      console.log("后续消息沿用原会话历史，使用上面显示的当前配置模型。");

  async function runTurn(prompt) {
    if (!threadId) await startThread();
    const turn = { threadId, id: null, answers: new Map(), buffer: [], completed: Promise.withResolvers() };
    turn.completed.promise.catch(() => {});
    activeTurn = turn;
    const timer = setTimeout(() => fail(new Error("App Server 本轮调用超时；已停止连接，可重启后 /resume。")), launch.timeoutMs);
    console.log("正在等待模型回复……");
    try {
      const result = await request("turn/start", {
        threadId, input: [{ type: "text", text: prompt, text_elements: [] }]

{
  "schemaVersion": "1.0",
  "agent": {
    "id": "writing-assistant",
    "version": "1.0.0",
    "instructions": "roles/writing-assistant.md",
    "skills": [],
    "tools": { "allow": ["list_files", "read_file", "write_file", "search_web", "read_webpage"] },
    "dataBindings": [

      { "sourceRef": "originals", "actions": ["read"], "methods": ["files"], "required": true },
      { "sourceRef": "research", "actions": ["read", "create"], "methods": ["files"], "required": true },
      { "sourceRef": "drafts", "actions": ["read", "create"], "methods": ["files"], "required": true },
      { "sourceRef": "articles", "actions": ["read"], "methods": ["files"], "required": true }
    ],
    "executionRef": "restricted-local",
    "memory": { "use": false, "contribute": false },
    "outputs": { "directory": "outputs", "formats": ["md", "txt"], "writeMode": "create-only", "requiredChecks": ["file-exists", "format"] }
  },

export class ToolManager {
  constructor({ config, runtime, log, redact, files, agent, boundary = new ExecutionBoundary() }) {
    Object.assign(this, { config, runtime, log, redact, files, agent, boundary });
    this.configFile = codexPaths(config.root).configFile;
    this.token = randomBytes(32).toString("hex");
    this.status = "loading"; this.error = null;
    Object.assign(boundary, { pending: () => Boolean(this.pending), unavailable: () => this.closed || this.broken,
      refresh: async () => { try { this.scan(); } catch (error) { this.pending = null; this.report(error); } }, apply: () => this.apply() });
  }

  async open() {
    this.registry = await this.build(readToolSources(this.config.root));
    this.server = await createMcpToolServer({ token: this.token, redact: this.redact });
    this.server.registries.set(this.registry.version, this.registry);
    this.config.launch.env = { ...this.config.launch.env, PROJECT_MCP_TOKEN: this.token };
    this.status = "ready";
    return this;
  }

  "bindings": {
    "workspaceDir": "../workspace",
    "skills": {},
    "sources": {
      "originals": { "type": "files", "root": "inputs" },
      "research": { "type": "files", "root": "research" },

      "drafts": { "type": "files", "root": "drafts" },
      "articles": { "type": "files", "root": "outputs" }
    },
    "executions": { "restricted-local": { "sandbox": "read-only", "approvalPolicy": "never", "nativeShell": false, "nativeFileWrite": false } }
  }