Integração com Webhooks

const processedEvents = new Set(); // Use um cache persistente em produção

app.post('/webhook/rcs', express.json(), (req, res) => {
  // Responda 200 imediatamente
  res.status(200).send('OK');

  const { data } = req.body;
  const eventKey = `${data.dispatchId}:${data.status}`;

  // Idempotência
  if (processedEvents.has(eventKey)) return;
  processedEvents.add(eventKey);

  // Processe de forma assíncrona
  processEvent(data).catch(console.error);
});

async function processEvent(data) {
  const { uid, status, phone, failureReason } = data;

  await db.query(
    `UPDATE mensagens
     SET status = $1, updated_at = NOW(), failure_reason = $2
     WHERE external_id = $3`,
    [status, failureReason, uid]
  );

  // Notifique seus sistemas internos
  if (status === 'failed') {
    await notifyFailure(uid, phone, failureReason);
  }
}