Add an Instagram Creator

const ingestionStatusPath = /^\/v1\/creators\/[0-9a-f-]+$/i;

function pollingDelay(retryAfter: string | null) {
  if (retryAfter === null) {
    return 60_000;
  }
  const seconds = Number(retryAfter);
  const requested = Number.isFinite(seconds) ? seconds * 1000 : Date.parse(retryAfter) - Date.now();
  return Math.max(60_000, Number.isFinite(requested) ? requested : 0);
}

export async function waitForProfile(statusUrl: string) {
  if (!ingestionStatusPath.test(statusUrl)) {
    throw new Error('Use the status_url returned by creator ingestion.');
  }
  const deadline = Date.now() + 10 * 60_000;
  for (let attempt = 0; attempt < 5; attempt++) {
    const response = await fetch(`https://api.influship.com${statusUrl}?include=profiles`, {
      headers: { 'X-API-Key': process.env.INFLUSHIP_API_KEY ?? '' },
      signal: AbortSignal.timeout(Math.min(10_000, Math.max(1, deadline - Date.now()))),
    });
    if (response.ok) {
      const record = await response.json();
      if (
        record.data.profiles?.some(
          (profile: { data_updated_at: string | null }) => profile.data_updated_at
        )
      ) {
        return record.data;
      }
    } else if (![404, 429, 500, 503].includes(response.status)) {
      throw new Error(`Profile read failed (${response.status}); stop polling.`);
    }
    if (attempt === 4) {
      break;
    }

    const delay = pollingDelay(response.headers.get('retry-after'));
    if (Date.now() + delay >= deadline) {
      break;
    }
    await new Promise((resolve) => setTimeout(resolve, delay));
  }
  throw new Error('Profile is still incomplete. Stop this job and check again later.');
}