Function waitForCompletion

src/job.ts:152–212

(
  jobId: string,
  argv: CliArguments,
  spinner: Spinner,
  logger: Logger,
  downloadFile: typeof downloadExportFile,
  cancellationSignal?: AbortSignal
)

}

async function waitForCompletion(
  jobId: string,
  argv: CliArguments,
  spinner: Spinner,
  logger: Logger,
  downloadFile: typeof downloadExportFile,
  cancellationSignal?: AbortSignal
): Promise<Job> {
  const cloudconvert = argv.cloudconvert;

  return await new Promise<Job>((resolve, reject) => {
    let settled = false;
    const isSettled = (): boolean => settled;
    const isCancelled = (): boolean => cancellationSignal?.aborted ?? false;

    const stopWaiting = (): void => {
      if (settled) {
        return;
      }

      settled = true;
      stopPolling();
      cancellationSignal?.removeEventListener('abort', stopWaiting);
    };

    const finishJob = (finishedJob: Job): void => {
      if (isSettled() || isCancelled()) {
        return;
      }

      stopWaiting();
      void finishCompletedJob(finishedJob, argv, spinner, logger, downloadFile).then(resolve, reject);
    };

    const failJob = (failedJob?: Job): void => {
      if (isSettled() || isCancelled()) {
        return;
      }

      stopWaiting();
      closeCloudConvertSocket(cloudconvert);
      if (failedJob) {
        printFailedTaskMessages(failedJob.tasks, logger);
        printCommandTaskOutputs(failedJob.tasks, logger);
      }
      spinner.fail('Job failed!');
      reject(new Error('Job failed!'));
    };

    const callbacks: JobCompletionCallbacks = {
      isSettled,
      isCancelled,
      finishJob,
      failJob
    };
    const stopPolling = startJobStatusPolling(jobId, cloudconvert, logger, callbacks);

    cancellationSignal?.addEventListener('abort', stopWaiting, { once: true });