// src/utils/agentSwarmsEnabled.ts
export function isAgentSwarmsEnabled(): boolean {
  if (process.env.USER_TYPE === 'ant') return true; // Anthropic 内部：直接开

  if (!isEnvTruthy(process.env.CLAUDE_CODE_EXPERIMENTAL_AGENT_TEAMS) && !process.argv.includes('--agent-teams')) {
    return false; // 外部用户：必须 opt-in
  }

  // 服务端 killswitch，用户无法绕过
  if (!getFeatureValue_CACHED_MAY_BE_STALE('tengu_amber_flint', true)) {
    return false;
  }

  return true;
}

CLAUDE_CODE_EXPERIMENTAL_AGENT_TEAMS=true claude --agent-teams

~/.claude/teams/{团队名}/
  config.json
  inboxes/
    {成员名}.json          # 收件箱（TeammateMessage 数组）
    {成员名}.json.lock     # 自动生成的锁文件

~/.claude/tasks/{团队名}/  # TaskList 与 Team 1:1 对应

type TeammateMessage = {
  from: string;
  text: string;
  timestamp: number; // Unix 毫秒
  read: boolean;
  color?: string;
  summary?: string; // 用于 DM 摘要通知
};
// 文件内容是 TeammateMessage[]，追加写入

// src/utils/teammateMailbox.ts — writeToMailbox() 核心逻辑
async function writeToMailbox(inboxPath: string, message: TeammateMessage) {
  // 1. 加锁（10次重试，5-100ms 间隔）
  await lockfile.lock(inboxPath, {
    retries: 10,
    minTimeout: 5,
    maxTimeout: 100,
  });

  try {
    // 2. 重新读取（防止 lock 期间被其他进程修改）
    const existing = readMailboxSync(inboxPath);
    // 3. 追加消息
    existing.push(message);
    // 4. 写入
    await fs.writeFile(inboxPath, JSON.stringify(existing));
  } finally {
    // 5. 无论成功或失败都释放锁
    await lockfile.unlock(inboxPath);
  }
}
// 锁文件路径：{inboxPath}.lock

// src/tools/SendMessageTool/SendMessageTool.ts — 发送路由逻辑
async function sendMessage(to: string, message: TeammateMessage) {
  // 检查目标 Agent 是否在内存注册表（in-process 且正在运行）
  const agent = agentNameRegistry.get(to);

  if (agent) {
    // 路径 A：内存队列，0ms 延迟
    queuePendingMessage(agent, message);
    // 如果 Agent 已停止，唤醒它
    resumeAgentBackground(agent);
  } else {
    // 路径 B：文件信箱，0-500ms 延迟
    await writeToMailbox(getInboxPath(to), message);
  }
}
// 注意：即使是 in-process 模式，Teammate→Leader 方向仍走文件信箱
// 源码注释："for consistency with tmux teammates"

Your plain text output is NOT visible to other agents —
to communicate, you MUST call this tool.
Messages from teammates are delivered automatically;
you don't check an inbox.

Messages from teammates are automatically delivered to you.
You do NOT need to manually check your inbox.
These messages appear automatically as new conversation turns
(like user messages)

// src/utils/swarm/inProcessRunner.ts — 核心循环
const POLL_INTERVAL_MS = 500;
const PERMISSION_POLL_INTERVAL_MS = 500;

// Teammate 生命周期（fire-and-forget 启动）
void runInProcessTeammate(config).catch(handleError);

async function runInProcessTeammate(config) {
  while (!abort) {
    await runAgent(); // 执行一个 Agent 轮次

    setIsIdle(true);
    sendIdleNotification(); // 告知 Team Lead "我空闲了"

    // 等待下一条消息（优先级：shutdown > team-lead > peers > task）
    await waitForNextPromptOrShutdown();
  }
}

async function waitForNextPromptOrShutdown() {
  let firstIteration = true;
  while (true) {
    if (!firstIteration) await sleep(POLL_INTERVAL_MS); // 第一轮不等
    firstIteration = false;

    // 优先级检查（高→低）：
    if (hasShutdownRequest()) return handleShutdown(); // 最高优先级
    if (hasTeamLeadMessage()) return processMessage();
    if (hasPeerMessage()) return processMessage(); // FIFO
    if (hasTaskUpdate()) return processTask();
  }
}

Team Lead  →  shutdown_request  →  Teammate
                                      ↓
                                  模型自主决定
                                  能否安全关闭
                                      ↓
Teammate   →  shutdown_approved / shutdown_rejected  →  Team Lead

// src/utils/swarm/backends/registry.ts — 后端探测优先级
async function detectAndGetBackend() {
  if (await isInsideTmux()) return TmuxBackend; // 优先1：在 tmux session 内
  if (isInITerm2()) {
    if (await isIt2CliAvailable()) return ITermBackend; // 优先2：iTerm2 + it2 CLI
    if (await isTmuxAvailable()) return TmuxBackend; // 优先3：iTerm2 无 it2，tmux 回退
    throw new Error('需要安装 it2 或 tmux');
  }
  if (await isTmuxAvailable()) return TmuxBackend; // 优先4：外部 tmux session
  throw getTmuxInstallInstructions(); // 无法启动
}

// 强制 In-Process 的条件：
function isInProcessEnabled() {
  if (getIsNonInteractiveSession()) return true; // -p 非交互模式，强制 in-process
  if (mode === 'in-process') return true;
  if (mode === 'tmux') return false;
  // auto 模式：不在 tmux 且不在 iTerm2 时，才使用 in-process
  return !isInsideTmuxSync() && !isInITerm2();
}

// src/tasks/InProcessTeammateTask/types.ts
export const TEAMMATE_MESSAGES_UI_CAP = 50;

// 源码注释原文：
// ~20MB RSS per agent at 500+ turn sessions
// and ~125MB per concurrent agent in swarm bursts.
// Whale session 9a990de8 launched 292 agents in 2 minutes
// and reached 36.8GB

// Subagent 不能嵌套（代码抛异常，提示词无法绕过）
throw Error('Fork is not available inside a forked worker. Complete your task directly using your tools.');

// Teammate 不能生成 Teammate（代码抛异常）
throw Error(
  'Teammates cannot spawn other teammates — the team roster is flat. To spawn a subagent instead, omit the `name` parameter.'
);