CallGrid API

import { writeFileSync } from "fs";
import { join } from "path";

// ── Configuration ───────────────────────────────────────────────────────────

// Note: In production you should use a secret store
// or environment variables to store your API key
const API_KEY = "your_key_here";
const LOOKBACK_MINUTES = 10;
const PAGE_SIZE = 100;
const SLEEP_BETWEEN_PAGES = 500; // milliseconds
const REQUEST_TIMEOUT = 60_000; // milliseconds
const OUTPUT_DIR = ".";

// ─────────────────────────────────────────────────────────────────────────────

const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));

async function fetchCalls(start: string, end: string): Promise<any[]> {
  const endpoint = "https://api.callgrid.com/api/call";
  const allRows: any[] = [];
  let searchAfter: unknown = null;
  let page = 0;

  while (true) {
    page++;
    const params = new URLSearchParams({
      startDate: start,
      endDate: end,
      maxItems: String(PAGE_SIZE),
      useCursor: "true",
      reportTimeZone: "US/Eastern",
      // use optional filters.
      // filters: '{"items":[{"operator":"AND","rules":[{"tagName":"CampaignId","values":["cmgn0asdl0gl6in04nkw6txyz"],"condition":"equals"}]}]}'
    });
    if (searchAfter !== null) {
      params.set("searchAfter", JSON.stringify(searchAfter));
    }

    const resp = await fetch(`${endpoint}?${params}`, {
      headers: {
        Accept: "application/json",
        Authorization: `Bearer ${API_KEY}`,
      },
      signal: AbortSignal.timeout(REQUEST_TIMEOUT),
    });

    if (!resp.ok) {
      const body = await resp.text();
      throw new Error(`HTTP ${resp.status}: ${body.slice(0, 1500)}`);
    }

    const payload = await resp.json();

    const data = payload.data ?? [];
    const rows: any[] = Array.isArray(data) ? data : (data.items ?? []);
    allRows.push(...rows);

    const hasMore = payload.hasMore ?? false;
    const nextCursor = payload.nextCursor ?? null;

    console.log(`Page ${page}: ${rows.length} rows (total: ${allRows.length})`);

    if (!hasMore || nextCursor === null) break;

    searchAfter = nextCursor;
    await sleep(SLEEP_BETWEEN_PAGES);
  }

  return allRows;
}

async function main() {
  const now = new Date();
  const start = new Date(now.getTime() - LOOKBACK_MINUTES * 60_000);

  const startStr = start.toISOString();
  const endStr = now.toISOString();

  console.log(`Fetching calls from ${startStr} to ${endStr}`);
  const rows = await fetchCalls(startStr, endStr);

  const filename = `calls_${start.toISOString().replace(/[:.]/g, "-")}.json`;
  const filepath = join(OUTPUT_DIR, filename);

  writeFileSync(filepath, JSON.stringify(rows, null, 2));
  console.log(`Saved ${rows.length} calls to ${filepath}`);
}

main();

HTTP/1.1 429 Too Many Requests
RateLimit-Limit: 80
RateLimit-Remaining: 0
RateLimit-Reset: 42

{
  "code": 5001,
  "message": "Rate limit exceeded. Please try again later."
}