Rate limits and pagination

async function sendBatch(batches: SendPayload[], keyFor: (batch: SendPayload) => string) {
  for (const batch of batches) {
    let delay = 500;

    for (let attempt = 1; attempt <= 5; attempt += 1) {
      const response = await fetch("https://api.sendozi.com/v1/sms/bulk", {
        method: "POST",
        headers: {
          Authorization: `Bearer ${process.env.SENDOZI_API_KEY}`,
          "Content-Type": "application/json",
          "Idempotency-Key": keyFor(batch),
        },
        body: JSON.stringify(batch),
      });

      const body = await response.json();
      if (body.success) break;

      if (response.status !== 429 && response.status < 500) {
        throw new Error(`${body.error.code}: ${body.error.message}`);
      }

      // Jitter stops a fleet of workers retrying in lockstep.
      await new Promise((resolve) => setTimeout(resolve, delay + Math.random() * 250));
      delay *= 2;
    }
  }
}

curl "https://api.sendozi.com/v1/messages?limit=100" \
  -H "Authorization: Bearer $SENDOZI_API_KEY"

{
  "success": true,
  "data": {
    "data": [ ],
    "has_more": true,
    "next_cursor": "2026-08-21T09:14:22.117Z"
  },
  "request_id": "req_8ecdcb4ce2ae4290"
}

export async function* allMessages() {
  let cursor;

  do {
    const url = new URL("https://api.sendozi.com/v1/messages");
    url.searchParams.set("limit", "100");
    if (cursor) url.searchParams.set("cursor", cursor);

    const response = await fetch(url, {
      headers: { Authorization: `Bearer ${process.env.SENDOZI_API_KEY}` },
    });
    const body = await response.json();
    if (!body.success) throw new Error(body.error.code);

    yield* body.data.data;
    cursor = body.data.has_more ? body.data.next_cursor : undefined;
  } while (cursor);
}