Asynchronous tasks

const successStates = new Set(["succeeded", "success", "completed"]);
const failureStates = new Set(["failed", "failure", "cancelled", "canceled"]);
const retryableStatuses = new Set([429, 502, 503, 504]);

async function pollTask(taskUrl, timeoutMs = 5 * 60 * 1000) {
  const deadline = Date.now() + timeoutMs;
  let delay = 2000;

  while (Date.now() < deadline) {
    const response = await fetch(taskUrl, {
      headers: { Authorization: `Bearer ${process.env.MAXAPI_API_KEY}` },
    });

    if (!response.ok && !retryableStatuses.has(response.status)) {
      throw new Error(`Task query failed with HTTP ${response.status}`);
    }

    if (response.ok) {
      const task = await response.json();
      const status = String(task.status).toLowerCase();

      if (successStates.has(status)) return task;
      if (failureStates.has(status)) {
        throw new Error(task.fail_reason || `Task ended with status: ${status}`);
      }
    }

    const jitter = Math.floor(Math.random() * 500);
    await new Promise((resolve) => setTimeout(resolve, delay + jitter));
    delay = Math.min(Math.round(delay * 1.5), 10000);
  }

  throw new Error("Task polling timed out");
}