Function sync

scripts/sync.ts:37–70

(options: SyncOptions)

await program.parseAsync();

async function sync(options: SyncOptions): Promise<void> {
  const sourceFiles = await selectSourceFiles(options.input, options.provider);
  const writes: string[] = [];
  const cache = new FetchCache(options.cache);

  await mkdir(options.output, { recursive: true });

  for (const sourceFile of sourceFiles) {
    const provider = await loadSourceProvider(sourceFile);
    const normalized = await buildProviderData(provider, path.dirname(sourceFile), {
      fetcher: (url) => cache.fetch(url),
      cache
    });
    const outPath = path.join(options.output, `${provider.provider}.yaml`);

    await writeFile(outPath, stringifyProviderData(normalized), "utf8");
    writes.push(outPath);
  }

  for (const filePath of writes) {
    console.log(filePath);
  }

  if (isFullSync(options.provider)) {
    const removed = await cache.pruneOrphans();
    if (removed.length > 0) {
      const isGithubActions = process.env.GITHUB_ACTIONS === "true";
      const tag = isGithubActions ? "::notice::" : "[notice] ";
      console.log(`${tag}Pruned ${removed.length} orphan cache entry/entries.`);
    }
  }

  reportCacheWarnings(cache);
}

function reportCacheWarnings(cache: FetchCache): void {
  const warnings = cache.getWarnings();