Function processPackageDirectories

scripts/validate-publish.ts:71–77

(packagesDir: string)

  pipe(joinToPath(packagesDir, dir, 'package.json'), Effect.andThen(checkExistsAndRead(dir)));

const processPackageDirectories = (packagesDir: string) => (dirs: ReadonlyArray<string>) =>
  pipe(
    Effect.forEach(dirs, readPackageMetadata(packagesDir), {
      concurrency: 'unbounded',
    }),
    Effect.map((results) => results.flat())
  );

const readAndProcessPackages = (packagesDir: string) =>
  pipe(packagesDir, readDirectoryContents, Effect.andThen(processPackageDirectories(packagesDir)));