Retrieve Onboarding Status

{
  "statusCode": 400,
  "message": "Invalid onboarding reference number format",
  "error": "Bad Request",
  "details": {
    "refNumReceived": "invalid-uuid"
  }
}

{
  "statusCode": 400,
  "message": "Onboarding record does not exist",
  "error": "Bad Request"
}

{
  "statusCode": 400,
  "message": "Onboarding reference number mismatch",
  "error": "Bad Request",
  "details": {
    "refNumReceived": "550e8400-e29b-41d4-a716-446655440000"
  }
}

{
  "statusCode": 401,
  "message": "Account not found",
  "error": "Unauthorized"
}

async function pollOnboardingStatus(refNo, maxAttempts = 30) {
  let attempts = 0;
  const pollInterval = 30000; // 30 seconds

  const poll = async () => {
    if (attempts >= maxAttempts) {
      console.log('  Polling timeout reached');
      return;
    }

    attempts++;
    console.log(`Checking status (attempt ${attempts}/${maxAttempts})...`);

    try {
      const status = await getOnboardingStatus(refNo);

      if (status.onboardingStatus === 'APPROVED') {
        console.log(' Onboarding approved!');
        return status;
      } else if (status.onboardingStatus === 'DECLINED') {
        console.log(' Onboarding declined');
        return status;
      }

      // Continue polling if NEW or PENDING
      setTimeout(poll, pollInterval);
    } catch (error) {
      console.error('Polling error:', error.message);
      setTimeout(poll, pollInterval);
    }
  };

  await poll();
}

async function pollWithBackoff(refNo, maxAttempts = 20) {
  let attempts = 0;
  let delay = 10000; // Start with 10 seconds
  const maxDelay = 300000; // Max 5 minutes

  const poll = async () => {
    if (attempts >= maxAttempts) return;

    attempts++;
    const status = await getOnboardingStatus(refNo);

    if (['APPROVED', 'DECLINED'].includes(status.onboardingStatus)) {
      return status;
    }

    // Exponential backoff with max delay cap
    delay = Math.min(delay * 1.5, maxDelay);
    setTimeout(poll, delay);
  };

  await poll();
}

const statusCache = new Map();
const CACHE_TTL = 30000; // 30 seconds

async function getCachedStatus(refNo) {
  const cached = statusCache.get(refNo);

  if (cached && (Date.now() - cached.timestamp) < CACHE_TTL) {
    return cached.data;
  }

  const status = await getOnboardingStatus(refNo);
  statusCache.set(refNo, {
    data: status,
    timestamp: Date.now()
  });

  return status;
}

const TERMINAL_STATUSES = ['APPROVED', 'DECLINED'];

async function pollUntilTerminal(refNo) {
  const interval = setInterval(async () => {
    const status = await getOnboardingStatus(refNo);

    if (TERMINAL_STATUSES.includes(status.onboardingStatus)) {
      clearInterval(interval);
      console.log(`Terminal status reached: ${status.onboardingStatus}`);

      // Trigger appropriate action
      if (status.onboardingStatus === 'APPROVED') {
        onApproved(status);
      } else {
        onDeclined(status);
      }
    }
  }, 30000);

  return interval;
}