Pagination

type Pagination = {
  limit: number          // page size used for this response
  cursor?: string        // opaque token — pass back as `?cursor=…` to get the next page
  hasMore: boolean       // true when more rows exist
}

type ListResponse<Row> = {
  [collectionName: string]: Array<Row>     // e.g. `contacts`, `runs`
  pagination?: Pagination
}

async function* paginateAllContacts() {
  let cursor: string | undefined
  while (true) {
    const url = new URL('https://brew.new/api/v1/contacts')
    url.searchParams.set('limit', '100')
    if (cursor) url.searchParams.set('cursor', cursor)

    const res = await fetch(url, {
      headers: { Authorization: `Bearer ${process.env.BREW_API_KEY!}` },
    })
    if (!res.ok) throw new Error(`HTTP ${res.status}: ${await res.text()}`)
    const body = (await res.json()) as {
      contacts: Array<{ email: string }>
      pagination: { limit: number; cursor?: string; hasMore: boolean }
    }

    for (const contact of body.contacts) yield contact
    if (!body.pagination.hasMore) return
    cursor = body.pagination.cursor
  }
}

for await (const contact of paginateAllContacts()) {
  console.log(contact.email)
}

import { createBrewClient } from '@brew.new/sdk'

const brew = createBrewClient({ apiKey: process.env.BREW_API_KEY! })

let cursor: string | undefined
do {
  const page = await brew.contacts.list({ limit: 100, cursor })
  for (const contact of page.contacts) {
    console.log(contact.email)
  }
  cursor = page.pagination?.hasMore ? page.pagination.cursor : undefined
} while (cursor)

GET /v1/contacts?search=jane&sort=createdAt&order=desc&limit=50
GET /v1/contacts?logic=and&filters=[{"field":"plan","operator":"eq","value":"pro"}]&limit=100

GET /v1/automation/runs?automationId=auto_abc&status=completed&from=2026-04-01T00:00:00.000Z&to=2026-04-08T00:00:00.000Z&limit=100&include=logs