Idempotência

async function upsertColaborador(dados) {
  // 1. Tenta buscar por CPF
  const buscaResp = await fetch(
    `https://api.pontua.com.br/colaborador/${dados.cpf}/cpf`,
    { headers: { Authorization: `Bearer ${TOKEN}` } },
  )

  if (buscaResp.ok) {
    // Já existe — atualiza
    const existente = await buscaResp.json()
    return fetch(`https://api.pontua.com.br/colaborador/${existente.id}`, {
      method: 'PATCH',
      headers: {
        Authorization: `Bearer ${TOKEN}`,
        'Content-Type': 'application/json',
      },
      body: JSON.stringify(dados),
    })
  }

  // 2. Não existe — cria
  return fetch('https://api.pontua.com.br/colaborador', {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${TOKEN}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify(dados),
  })
}

async function criarRegistroPontoIdempotente(dados) {
  const idempotencyKey = crypto.randomUUID()

  // 1. Persiste intenção localmente
  await db.intencao.create({
    data: {
      idempotencyKey,
      operacao: 'criar_registro_ponto',
      payload: dados,
      status: 'pendente',
    },
  })

  // 2. Envia
  try {
    const resp = await fetch('https://api.pontua.com.br/registro-ponto', {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${TOKEN}`,
        'Content-Type': 'application/json',
      },
      body: JSON.stringify(dados),
    })

    if (resp.ok) {
      const { id } = await resp.json()
      await db.intencao.update({
        where: { idempotencyKey },
        data: { status: 'sucesso', recursoId: id },
      })
      return id
    }
    throw new Error(`HTTP ${resp.status}`)
  } catch (err) {
    await db.intencao.update({
      where: { idempotencyKey },
      data: { status: 'erro', erro: String(err) },
    })
    throw err
  }
}

// Antes de retentar, verifique a intenção
async function criarRegistroPontoComRetry(dados) {
  const intencaoExistente = await db.intencao.findFirst({
    where: { operacao: 'criar_registro_ponto', payload: dados, status: 'sucesso' },
  })
  if (intencaoExistente) return intencaoExistente.recursoId

  return criarRegistroPontoIdempotente(dados)
}

async function comBackoff(fn, maxAttempts = 5) {
  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    try {
      return await fn()
    } catch (err) {
      const isRetriable = err.status >= 500 || err.code === 'ETIMEDOUT'
      if (!isRetriable || attempt === maxAttempts - 1) throw err

      // 1s, 2s, 4s, 8s, 16s + jitter aleatório
      const delayMs = Math.pow(2, attempt) * 1000 + Math.random() * 500
      await new Promise((r) => setTimeout(r, delayMs))
    }
  }
}