Reenviar webhook

app.post('/webhooks/garu', async (req, res) => {
  const event = req.body;

  // Dedup pelo `payload.id`. Funciona perfeitamente para
  // auto-retries (mesma `evt_…` se repete entre tentativas).
  // Quebra para reenvios manuais: o clone carrega o MESMO
  // `payload.id` do original, então depois do original ter
  // sido processado, o resend é descartado aqui como duplicata.
  // É exatamente esse drop silencioso que o novo `Idempotency-Key`
  // (`resend_<uuid>`) existe para evitar — mas só se o seu dedup
  // olhar para o header, não para o `payload.id`.
  if (await cache.has(event.id)) {
    return res.status(200).json({ deduped: true });
  }
  await cache.set(event.id, true, { ttl: '7d' });

  await processar(event);
  res.status(200).json({ received: true });
});

app.post('/webhooks/garu', async (req, res) => {
  // `evt_…` para entregas/auto-retries; `resend_<uuid>` para reenvios
  // manuais. As duas chaves são distintas — o resend passa como
  // entrega nova naturalmente, sem caso especial.
  const key = req.headers['idempotency-key'];

  if (await cache.has(key)) {
    return res.status(200).json({ deduped: true });
  }
  await cache.set(key, true, { ttl: '7d' });

  await processar(req.body);
  res.status(200).json({ received: true });
});

app.post('/webhooks/garu', async (req, res) => {
  const event = req.body;
  const key = req.headers['idempotency-key'];
  const isManualResend = key?.startsWith('resend_');

  // Reenvios manuais são deliberados — bypass do dedup de header.
  if (!isManualResend && (await cache.has(event.id))) {
    return res.status(200).json({ deduped: true });
  }
  await cache.set(event.id, true, { ttl: '7d' });

  await processar(event);
  res.status(200).json({ received: true });
});

@app.route('/webhooks/garu', methods=['POST'])
def webhook():
    event = request.json
    key = request.headers.get('Idempotency-Key', '')
    is_manual_resend = key.startswith('resend_')

    if not is_manual_resend and cache.has(event['id']):
        return jsonify({'deduped': True}), 200
    cache.set(event['id'], True, ttl=7 * 24 * 3600)

    processar(event)
    return jsonify({'received': True}), 200