Class FsService

packages/agent-core/src/services/fs/fsService.ts:46–424

const MACOS_NOISE = new Set(['.DS_Store', '.AppleDouble', '.LSOverride']);

export class FsService extends Disposable implements IFsService {
  readonly _serviceBrand: undefined;

  protected gitignoreCache = new Map<string, Ignore>();

  constructor(@ISessionService protected readonly sessions: ISessionService) {
    super();
  }

  override dispose(): void {
    this.gitignoreCache.clear();
    super.dispose();
  }

  async list(sessionId: string, req: FsListRequest): Promise<FsListResponse> {
    const session = await this.sessions.get(sessionId);
    const cwd = session.metadata.cwd;
    const safe = await resolveSafePath(cwd, req.path);

    let topStat: import('node:fs').Stats;
    try {
      topStat = await fs.stat(safe.absolute);
    } catch (err) {
      throw mapStatError(err, req.path);
    }
    if (!topStat.isDirectory()) {

      throw new FsPathNotFoundError(req.path);
    }

    const realCwd = await fs.realpath(cwd);
    const matcher = req.follow_gitignore ? await this.matcher(realCwd) : undefined;

    const items: FsEntry[] = [];
    const childrenByPath: Record<string, FsEntry[]> = {};
    let truncated = false;

    interface QueueEntry {
      absPath: string;

      relPath: string;
      depthRemaining: number;
    }
    const queue: QueueEntry[] = [
      {
        absPath: safe.absolute,
        relPath: safe.relative === '.' ? '' : safe.relative,
        depthRemaining: req.depth,
      },
    ];

    while (queue.length > 0) {
      const entry = queue.shift()!;
      let dirents: import('node:fs').Dirent[];
      try {
        dirents = await fs.readdir(entry.absPath, { withFileTypes: true });
      } catch (err) {