Agent = 大模型 + harness

export async function runAgent(userInput, messages, depth = 0) {
  messages.push({ role: "user", content: userInput });
  while (true) {
    await compactIfNeeded(messages);          // ⑥ 太长先压缩
    const res = await withRetry(async () => {  // ⑩ 失败自动重试
      const stream = client.messages.stream({
        model: MODEL, system: buildSystemPrompt(),  // ④人设+⑦记忆
        messages, tools: toolSchemas,
      });
      stream.on("text", (c) => process.stdout.write(c)); // ⑤流式
      return await stream.finalMessage();
    });
    messages.push({ role: "assistant", content: res.content });
    if (res.stop_reason !== "tool_use") return finalText;  // 没工具→完成
    // …执行工具(②③⑧⑨⑫)，把结果喂回 messages，进下一轮…
  }
}

// prompt.js —— 你是谁
export const SYSTEM_PROMPT = `你是一个谨慎、靠谱的命令行助手。
行为准则：
1. 动手前先说清楚你打算做什么，再调工具。
2. 涉及写文件 / 删除 / 跑命令，明确告诉用户风险点。`;

// memory.js —— 每轮把「人设 + 长期记忆」拼起来喂模型
export function buildSystemPrompt() {
  const memory = loadMemory();              // ⑦ 读 memory.md
  if (!memory) return SYSTEM_PROMPT;
  return `${SYSTEM_PROMPT}\n\n## 你的长期记忆\n${memory}`;
}

export const permissionRules = [
  { tool: "run_bash",
    match: (i) => /^\s*git\s+(status|diff|log)\b/.test(i.command),
    action: "allow" },          // 只读 git 自动放行
  { tool: "run_bash",
    match: (i) => /\bsudo\b/.test(i.command),
    action: "deny" },           // sudo 直接拒，连问都不问
];
export function matchRule(toolName, input) {
  for (const rule of permissionRules) {     // 从头扫，第一条命中即返回
    if (rule.tool !== toolName) continue;
    if (rule.match && !rule.match(input)) continue;
    return rule.action;
  }
  return null;
}

export async function withRetry(fn, opts = {}) {
  const { retries = 3, baseDelay = 500,
          isRetriable = isRetriableError } = opts;
  for (let attempt = 0; attempt <= retries; attempt++) {
    try { return await fn(); }
    catch (err) {
      if (attempt >= retries || !isRetriable(err)) throw err;
      const delay = baseDelay * Math.pow(2, attempt)
                  + Math.floor(Math.random() * 100);  // 指数退避+抖动
      await new Promise((r) => setTimeout(r, delay));
    }
  }
}