Webhooks

const express = require('express');
const app = express();
app.use(express.json());

const WEBHOOK_SECRET = process.env.PRONTTUS_WEBHOOK_SECRET;

// Armazenar IDs processados para idempotência
const processedWebhooks = new Set();

// Endpoint para receber webhooks
app.post('/webhooks/pronttus', (req, res) => {
  const webhookSecret = req.headers['x-webhook-secret'];
  const correlationId = req.headers['x-correlation-id'];
  const payload = req.body;

  // Valida secret
  if (webhookSecret !== WEBHOOK_SECRET) {
    console.error('Secret inválido');
    return res.status(401).send('Não autorizado');
  }

  // Implementa idempotência usando correlation-id
  if (processedWebhooks.has(correlationId)) {
    console.log('Webhook já processado:', correlationId);
    return res.status(200).send('OK');
  }

  // Processa o evento
  const { webhookId, type, data } = payload;

  try {
    switch (type) {
      case 'transactions.receive':
        console.log('Pagamento recebido:', data.transaction_id);
        // Atualiza banco de dados, envia e-mail, etc.
        break;

      case 'transactions.transfer':
        console.log('Transferência concluída:', data.transfer_id);
        break;

      case 'transactions.chargeback':
        console.log('Estorno recebido:', data.chargeback_id);
        break;

      default:
        console.log('Evento desconhecido:', type);
    }

    // Marca como processado
    processedWebhooks.add(correlationId);

    // IMPORTANTE: Retorna 200 para confirmar recebimento
    res.status(200).json({ status: 'processed' });
  } catch (error) {
    console.error('Erro ao processar webhook:', error);
    // Mesmo com erro, retorna 200 para evitar retry desnecessário
    // se for um erro de lógica de negócio (não de infraestrutura)
    res.status(200).json({ status: 'error', message: error.message });
  }
});

app.listen(3000, () => {
  console.log('Servidor rodando na porta 3000');
});