Class GitWorktreeChildExecutor

packages/storage/src/git-worktree-child-executor.ts:39–383

}

class GitWorktreeChildExecutor implements SubagentWorktreeExecutor {
  private readonly inFlight = new Map<string, Promise<SubagentWorkspaceBinding>>();
  private readonly repositoryTails = new Map<string, Promise<void>>();

  constructor(private readonly worktreeRoot: string) {}

  async isAvailable(
    input: Pick<ProvisionSubagentWorktreeInput, 'sourceCwd' | 'sourceProjectId'>,
  ): Promise<boolean> {
    try {
      const source = await resolveProjectLocation({ path: input.sourceCwd });
      return source.kind === 'git' && source.git !== undefined;
    } catch {
      return false;
    }
  }

  async provision(input: ProvisionSubagentWorktreeInput): Promise<SubagentWorkspaceBinding> {
    const suffix = leaseSuffix(input.leaseId);
    const existing = this.inFlight.get(input.leaseId);
    if (existing) return existing;
    const task = this.provisionOnce(input, suffix).finally(() => {
      if (this.inFlight.get(input.leaseId) === task) this.inFlight.delete(input.leaseId);
    });
    this.inFlight.set(input.leaseId, task);
    return task;
  }

  async ensure(binding: SubagentWorkspaceBinding): Promise<void> {
    if (!isSubagentWorkspaceBinding(binding)) {
      throw new Error('Invalid subagent worktree binding');
    }
    await this.assertOwnedBindingLocation(binding);
    const inspected = await this.inspectOwnedWorktree(binding.worktreePath);
    if (!inspected) {
      throw new Error(`Subagent worktree is unavailable: ${binding.worktreePath}`);
    }
    if (inspected.gitCommonDir !== normalize(binding.gitCommonDir)) {
      throw new Error(`Subagent worktree binding changed: ${binding.worktreePath}`);
    }
    const [lease, baseCommit] = await Promise.all([
      gitConfigGet(inspected.worktreePath, branchLeaseConfigKey(binding.branch)),
      gitConfigGet(inspected.worktreePath, branchBaseConfigKey(binding.branch)),
    ]);
    if (lease !== binding.leaseId || baseCommit !== binding.baseCommit) {
      throw new Error(`Subagent worktree lease changed: ${binding.worktreePath}`);
    }
  }

  async capturePatch(binding: SubagentWorkspaceBinding): Promise<Uint8Array> {
    await this.ensure(binding);
    return this.withRepositoryAllocation(binding.gitCommonDir, async () => {
      const temporary = await mkdtemp(join(tmpdir(), 'maka-subagent-patch-'));
      const indexPath = join(temporary, 'index');
      try {
        const currentIndex = (
          await runGit(binding.worktreePath, ['rev-parse', '--git-path', 'index'])
        ).trim();