Function watchMirrow

packages/cli/src/runner.ts:170–207

(
  options: CliOptions,
  signal?: AbortSignal
)

}

export async function watchMirrow(
  options: CliOptions,
  signal?: AbortSignal
): Promise<void> {
  const { input, output, depth } = options;
  const abortSignal = signal ?? new AbortController().signal;

  const inputStats = await fs.stat(input).catch(() => {
    throw new Error(`Input not found: ${input}`);
  });

  const outputStats = await fs.stat(output).catch(() => undefined);

  if (inputStats.isDirectory()) {
    if (outputStats && !outputStats.isDirectory()) {
      throw new Error("Input is a directory, but output is not");
    }
  } else if (outputStats && outputStats.isDirectory()) {
    throw new Error("Input is a file, but output is a directory");
  }

  await runMirrow(options);
  console.log(
    `Watching ${formatPath(input)} (depth: ${depth === Infinity ? "unbound" : depth
    })`
  );
  console.log("Press Ctrl+C to stop.\n");

  const enqueue = createTaskQueue();

  if (inputStats.isDirectory()) {
    await watchDirectory(input, output, depth, abortSignal, enqueue);
  } else {
    await watchFile(input, output, abortSignal, enqueue);
  }

  console.log("Watcher stopped.");
}

async function watchDirectory(
  inputDir: string,