Function fetchEventsFromAPI

src/lib/polymarket.ts:7–77

(locale?: string)

const API_BASE = "https://gamma-api.polymarket.com";

export async function fetchEventsFromAPI(locale?: string): Promise<PolymarketEvent[]> {
  const events: PolymarketEvent[] = [];
  const seen = new Set<string>();
  const BATCH = 100;
  const CONCURRENCY = 5;
  const localeSuffix = locale ? `&locale=${locale}` : "";

  // Fetch active events
  let offset = 0;
  let done = false;

  while (!done) {
    const offsets = Array.from({ length: CONCURRENCY }, (_, i) => offset + i * BATCH);
    const results = await Promise.all(
      offsets.map(async (off) => {
        const url = `${API_BASE}/events?active=true&closed=false&limit=${BATCH}&offset=${off}&order=volume24hr&ascending=false${localeSuffix}`;
        try {
          const res = await fetchWithRetry(url, { next: { revalidate: 30 }, signal: AbortSignal.timeout(10_000) } as RequestInit, 2);
          if (!res.ok) return [];
          return res.json();
        } catch {
          return [];
        }
      })
    );

    let pageHadData = false;
    for (const page of results) {
      const arr = Array.isArray(page)
        ? page
        : page?.data || page?.events || [];
      if (arr.length === 0) {
        done = true;
      } else {
        pageHadData = true;
        for (const e of arr) {
          if (e?.id && !seen.has(e.id)) {
            seen.add(e.id);
            events.push(e);
          }
        }
      }
    }

    if (!pageHadData) break;
    offset += CONCURRENCY * BATCH;
  }

  // Also fetch recently closed events (top 100 by volume) to update status
  if (!locale) {
    try {
      const closedUrl = `${API_BASE}/events?closed=true&limit=200&offset=0&order=volume24hr&ascending=false`;
      const res = await fetch(closedUrl, { next: { revalidate: 60 }, signal: AbortSignal.timeout(15_000) });
      if (res.ok) {
        const data = await res.json();
        const arr = Array.isArray(data) ? data : data?.data || data?.events || [];
        for (const e of arr) {
          if (e?.id && !seen.has(e.id)) {