Function jsLineSearch

src/utils/ripgrep.ts:123–182

(cwd: string, opts: LineSearchOptions)

/** Pure-JS line search. Exported for direct testing. Emits absolute `file:line:content`. */
export async function jsLineSearch(cwd: string, opts: LineSearchOptions): Promise<string> {
  const exts = opts.language ? (TYPE_EXT[opts.language.toLowerCase()] ?? null) : null;
  // Use a non-global clone so `.test()` doesn't advance lastIndex across lines.
  const re = new RegExp(opts.regex.source, opts.regex.flags.replace(/g/g, ''));
  const out: string[] = [];
  let count = 0;

  async function walk(dir: string): Promise<void> {
    if (count >= opts.maxCount || opts.signal?.aborted) return;
    let entries: any[];
    try {
      entries = await fs.readdir(dir, { withFileTypes: true });
    } catch { return; }

    for (const entry of entries) {
      if (count >= opts.maxCount || opts.signal?.aborted) return;
      if (entry.name.startsWith('.') && entry.name !== '.env') continue;
      const full = path.join(dir, entry.name);
      if (entry.isDirectory()) {
        if (IGNORED_DIRS.has(entry.name)) continue;
        await walk(full);
      } else if (entry.isFile()) {
        if (exts && !exts.includes(path.extname(full).toLowerCase())) continue;
        let buf: Buffer;
        try {
          const st = await fs.stat(full);
          if (st.size > MAX_FILE_SIZE) continue;
          buf = await fs.readFile(full);
        } catch { continue; }
        if (isBinaryBuffer(buf)) continue;
        const lines = buf.toString('utf-8').split('\n');
        for (let i = 0; i < lines.length; i++) {
          if (re.test(lines[i]!)) {
            out.push(`${full}:${i + 1}:${lines[i]}`);
            count++;
            if (count >= opts.maxCount) break;
          }
        }
      }
    }
  }

  // Allow searching a single file path too (matches ripgrep's behaviour).
  try {
    const st = await fs.stat(cwd);
    if (st.isFile()) {
      const buf = await fs.readFile(cwd);
      if (!isBinaryBuffer(buf)) {
        const lines = buf.toString('utf-8').split('\n');
        for (let i = 0; i < lines.length && count < opts.maxCount; i++) {
          if (re.test(lines[i]!)) { out.push(`${cwd}:${i + 1}:${lines[i]}`); count++; }
        }
      }
      return out.join('\n');
    }
  } catch { return ''; }

  await walk(cwd);