Sync leads to your CRM or database

const BASE_URL = process.env.VYOSTRA_API_URL
const API_KEY = process.env.VYOSTRA_API_KEY

const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms))

async function fetchLeadPage(cursor) {
  const url = new URL('/v1/leads', BASE_URL)
  url.searchParams.set('limit', '200')
  if (cursor) url.searchParams.set('cursor', cursor)

  while (true) {
    const response = await fetch(url, { headers: { Authorization: `Bearer ${API_KEY}` } })
    if (response.ok) return response.json()

    if (response.status === 429) {
      await sleep(Number(response.headers.get('Retry-After') ?? 60) * 1000)
      continue
    }

    const { error } = await response.json()
    throw new Error(`${response.status} ${error.code}: ${error.message}`)
  }
}

async function syncLeads(saveLeads) {
  let cursor = null
  let saved = 0

  do {
    const page = await fetchLeadPage(cursor)

    if (page.incompleteSources) {
      throw new Error(`Leads from ${page.incompleteSources.join(', ')} could not be read. Try again later.`)
    }

    await saveLeads(page.data)
    saved += page.data.length
    cursor = page.nextCursor
  } while (cursor)

  return saved
}

// Replace this with an upsert into your CRM or database, keyed on lead.id.
async function saveLeads(leads) {
  for (const lead of leads) {
    console.log(lead.id, lead.source, lead.name, lead.phone, lead.email)
  }
}

console.log(`Synced ${await syncLeads(saveLeads)} leads`)

import os
import time
import requests

BASE_URL = os.environ["VYOSTRA_API_URL"]
HEADERS = {"Authorization": f"Bearer {os.environ['VYOSTRA_API_KEY']}"}


def fetch_lead_page(cursor=None):
    params = {"limit": 200}
    if cursor:
        params["cursor"] = cursor

    while True:
        response = requests.get(f"{BASE_URL}/v1/leads", params=params, headers=HEADERS, timeout=30)
        if response.status_code == 429:
            time.sleep(int(response.headers.get("Retry-After", 60)))
            continue
        response.raise_for_status()
        return response.json()


def sync_leads(save_leads):
    cursor = None
    saved = 0

    while True:
        page = fetch_lead_page(cursor)
        if page.get("incompleteSources"):
            raise RuntimeError(f"Could not read leads from {page['incompleteSources']}. Try again later.")

        save_leads(page["data"])
        saved += len(page["data"])
        cursor = page["nextCursor"]
        if cursor is None:
            return saved


def save_leads(leads):
    # Replace with an upsert into your CRM or database, keyed on lead["id"].
    for lead in leads:
        print(lead["id"], lead["source"], lead["name"], lead["phone"], lead["email"])


print("Synced", sync_leads(save_leads), "leads")