Webhooks

async function syncIncremental({ token, recurso, ultimoSync }) {
  let pagina = 0
  const limite = 100
  let novoCursor = ultimoSync

  while (true) {
    const params = new URLSearchParams({
      pagina: String(pagina),
      limite: String(limite),
      // O nome do filtro de período varia por endpoint —
      // confira na Referência da API o nome correto.
      // Exemplos comuns: dataInicio, atualizadoDe, criadoDe.
      atualizadoDe: ultimoSync,
    })

    const resp = await fetch(
      `https://api.pontua.com.br/${recurso}?${params}`,
      { headers: { Authorization: `Bearer ${token}` } },
    )
    const { resultados, totalRegistros } = await resp.json()

    for (const item of resultados) {
      await processar(item)
      // Atualiza cursor para o item mais recente processado
      if (item.atualizadoEm && item.atualizadoEm > novoCursor) {
        novoCursor = item.atualizadoEm
      }
    }

    if ((pagina + 1) * limite >= totalRegistros) break
    pagina++
  }

  return novoCursor
}