Function uploadFiles

src/job.ts:302–335

(
  job: Job,
  uploadFilesByTaskName: UploadFilesByTaskName,
  argv: CliArguments,
  spinner: Spinner,
  cancellationSignal?: AbortSignal
)

}

async function uploadFiles(
  job: Job,
  uploadFilesByTaskName: UploadFilesByTaskName,
  argv: CliArguments,
  spinner: Spinner,
  cancellationSignal?: AbortSignal
): Promise<void> {
  const uploadTasks = job.tasks.filter(task => task.operation === 'import/upload');

  for (const task of uploadTasks) {
    throwIfCancelled(cancellationSignal);
    const file = uploadFilesByTaskName[task.name];

    if (!file) {
      throw new Error(`Upload task ${task.name} has no matching input file.`);
    }

    const uploadFile = resolveUploadFilePath(file);
    const { size } = statSync(uploadFile);

    spinner.text = `Uploading ${uploadFile}`;
    const stream = createReadStream(uploadFile);
    const destroyStream = (): void => {
      stream.destroy(new Error(JOB_CANCELLED_MESSAGE));
    };

    cancellationSignal?.addEventListener('abort', destroyStream, { once: true });
    try {
      await argv.cloudconvert.tasks.upload(task, stream, basename(uploadFile), size);
    } finally {
      cancellationSignal?.removeEventListener('abort', destroyStream);
    }
  }
}

function createJobCancellation(
  jobId: string,