Webhooks

curl --request POST \
  --url 'https://api.uvvipague.com.br/uvvi/v1/webhook-register' \
  --header 'x-api-key: SUA_API_KEY_AQUI' \
  --header 'Content-Type: application/json' \
  --data '{
    "url": "https://sua-api.com.br/webhook/uvvipague"
  }'

const express = require('express');
const app = express();

app.use(express.json());

// Endpoint para receber webhooks
app.post('/webhook/uvvipague', async (req, res) => {
  try {
    // 1. Retorne 200 imediatamente
    res.status(200).json({ received: true });
    
    // 2. Processe o webhook de forma assíncrona
    processWebhookAsync(req.body);
    
  } catch (error) {
    console.error('Erro ao receber webhook:', error);
    res.status(500).json({ error: 'Internal server error' });
  }
});

async function processWebhookAsync(payload) {
  const { type, transactionId, externalId } = payload;
  
  console.log(`Webhook recebido: ${type}`);
  console.log(`Transaction ID: ${transactionId}`);
  console.log(`External ID: ${externalId}`);
  
  // Processar baseado no tipo
  switch (type) {
    case 'debts':
      await handleDebtsFound(payload);
      break;
      
    case 'VehicleWithoutDebts':
      await handleNoDebts(payload);
      break;
      
    case 'VehicleNotFound':
      await handleVehicleNotFound(payload);
      break;
      
    case 'search-error-event':
      await handleSearchError(payload);
      break;
      
    case 'payment-status-update':
      await handlePaymentUpdate(payload);
      break;
      
    default:
      console.warn(`Tipo de webhook desconhecido: ${type}`);
  }
}

async function handleDebtsFound(payload) {
  const { transactionId, debts } = payload;
  
  // Salvar débitos no banco de dados
  await database.debts.create({
    transactionId,
    debts: debts,
    status: 'found',
    receivedAt: new Date()
  });
  
  // Notificar cliente
  await notifyClient(transactionId, 'Débitos encontrados');
}

async function handlePaymentUpdate(payload) {
  const { paymentId, status, liquidationStatus } = payload;
  
  // Atualizar status do pagamento
  await database.payments.update(
    { paymentId },
    { 
      status, 
      liquidationStatus,
      updatedAt: new Date() 
    }
  );
  
  // Se pago e liquidado, liberar serviço
  if (status === 'paid' && liquidationStatus === 'settled') {
    await releaseService(paymentId);
  }
}

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

curl --request POST \
  --url 'https://api.uvvipague.com.br/uvvi/v1/payment/status' \
  --header 'x-api-key: SUA_API_KEY_AQUI' \
  --header 'Content-Type: application/json' \
  --data '{
    "paymentId": "pay_abc123def456"
  }'