Function execAsync

packages/cli/src/cli/utils/exec.ts:17–43

(
  fns: (() => Promise<any>)[],
  options: ExecAsyncOptions = ExecAsyncSchema.parse({}),
)

 * @param options Options
 */
export async function execAsync(
  fns: (() => Promise<any>)[],
  options: ExecAsyncOptions = ExecAsyncSchema.parse({}),
) {
  const limit = pLimit(options.concurrency);
  const limitedFns = fns.map((fn) => () => limit(fn));

  const resultPromises: Promise<any>[] = [];

  let completedCount = 0;
  options.onProgress?.(completedCount, limitedFns.length);

  for (let i = 0; i < limitedFns.length; i++) {
    const fn = limitedFns[i];
    const resultPromise = fn().then((result) => {
      completedCount++;
      options.onProgress?.(completedCount, limitedFns.length);
      return result;
    });
    resultPromises.push(resultPromise);

    await Promise.race([resultPromise, delay(options.delay)]);
  }

  const results = await Promise.all(resultPromises);
  return results;
}

export type ExecWithRetryOptions = Z.infer<typeof ExecWithRetrySchema>;