Webhooks

// Receba o webhook, salve na fila e responda 200 imediatamente
app.post('/webhook', (req, res) => {
  const event = req.body;
  const webhookCode = req.headers['x-webhook-code'];

  // Valide a autenticidade
  if (webhookCode !== process.env.PLUGGOU_WEBHOOK_CODE) {
    return res.status(401).json({ error: 'Código de webhook inválido' });
  }

  // Salve na fila para processamento assíncrono
  queue.add('process-event', event);

  // Responda 200 imediatamente
  return res.status(200).json({ received: true });
});

// Exemplo de verificação de idempotência
app.post('/webhook', async (req, res) => {
  const eventId = req.headers['x-webhook-event-id'];

  // Verifique se já processou este evento
  const alreadyProcessed = await db.webhookEvents.findOne({ eventId });
  if (alreadyProcessed) {
    return res.status(200).json({ received: true, duplicate: true });
  }

  // Registre o evento como processado
  await db.webhookEvents.create({ eventId, processedAt: new Date() });

  // Processe o evento
  queue.add('process-event', req.body);

  return res.status(200).json({ received: true });
});

Evento ocorre → Pluggou detecta mudança → Webhook enviado
                                                │
                                                ▼
                                         Webhooks ativos
                                      (cadastrados na conta)
                                                │
                                                ▼
                                          Seu servidor
                                        (responde 200)