Function startJobStatusPolling

src/job.ts:234–273

(
  jobId: string,
  cloudconvert: CloudConvertClient,
  logger: Logger,
  callbacks: JobCompletionCallbacks
)

}

function startJobStatusPolling(
  jobId: string,
  cloudconvert: CloudConvertClient,
  logger: Logger,
  callbacks: JobCompletionCallbacks
): () => void {
  let polling = false;
  const pollInterval = setInterval(() => {
    void pollJobStatus();
  }, JOB_STATUS_POLL_INTERVAL_MS);
  pollInterval.unref?.();

  async function pollJobStatus(): Promise<void> {
    if (callbacks.isSettled() || polling) {
      return;
    }

    polling = true;
    try {
      const currentJob = await cloudconvert.jobs.get(jobId);

      if (currentJob.status === 'finished') {
        callbacks.finishJob(currentJob);
        return;
      }

      if (currentJob.status === 'error' || currentJob.status === 'failed') {
        callbacks.failJob(currentJob);
      }
    } catch (error) {
      if (!callbacks.isSettled() && error instanceof Error) {
        logger.error(`Job status polling failed: ${error.message}`);
      }
    } finally {
      polling = false;
    }
  }

  return () => clearInterval(pollInterval);
}

function subscribeToJobEvents(
  jobId: string,