Polling Strategies

async function pollStatus(checkFunction, options = {}) {
  const {
    maxAttempts = 60,
    interval = 5000,
    finalStates = ["FULFILLED", "REFUNDED"],
  } = options;

  for (let attempt = 1; attempt <= maxAttempts; attempt++) {
    const result = await checkFunction();

    if (finalStates.includes(result.status)) {
      return result;
    }

    if (attempt < maxAttempts) {
      await new Promise((resolve) => setTimeout(resolve, interval));
    }
  }

  throw new Error("Polling timeout");
}

// Usage
const result = await pollStatus(() => checkTopupStatus(topupId), {
  maxAttempts: 60,
  interval: 5000,
});

async function pollMobileTopup(topupId) {
  return await pollStatus(() => checkMobileStatus(topupId), {
    maxAttempts: 60,
    interval: 5000,
    finalStates: ["FULFILLED", "REFUNDED", "UNKNOWN_ERROR"],
  });
}

async function pollInternetTopup(topupId) {
  return await pollStatus(() => checkInternetStatus(topupId), {
    maxAttempts: 60,
    interval: 5000,
    finalStates: ["FULFILLED", "REFUNDED", "QUEUED"],
  });
}

async function pollGiftCardOrder(orderId) {
  return await pollStatus(() => checkGiftCardOrder(orderId), {
    maxAttempts: 120,
    interval: 5000,
    finalStates: ["FULFILLED", "PARTIALLY_FILLED", "REFUNDED"],
  });
}