JamieMason/syncpack

import { Effect, pipe } from 'effect';
import type { Ctx } from '../get-context/index.js';
import type { GlobError } from '../io/glob-sync.js';
import type { Io } from '../io/index.js';
import type { ReadFileError } from '../io/read-file-sync.js';
import type { JsonParseError } from '../io/read-json-file-sync.js';
import { readJsonFileSync } from '../io/read-json-file-sync.js';
import type { NoSourcesFoundError } from './get-file-paths.js';
import { getFilePaths } from './get-file-paths.js';
import type { PackageJson } from './package-json-file.js';
import { PackageJsonFile } from './package-json-file.js';

/** Create an API for every package.json file needed. */
export function getPackageJsonFiles(
  io: Io,
  config: Ctx['config'],
): Effect.Effect<
  PackageJsonFile[],
  NoSourcesFoundError | GlobError | ReadFileError | JsonParseError
> {
  return pipe(
    getFilePaths(io, config),
    Effect.flatMap((filePaths) =>
      Effect.all(filePaths.map((filePath) => readJsonFileSync<PackageJson>(io, filePath))),
    ),
    Effect.map((files) => files.map((file) => new PackageJsonFile(file, config))),
    Effect.tap((files) => Effect.logDebug(`${files.length} package.json files found`)),
  );
}