Pare de reconstruir DLQ, reprocessamento e captura de payload do zero.

const { DlqWrapper } = require('@rebound-dlq/node');

const dlq = new DlqWrapper({
  projectSecret: process.env.REBOUND_PROJECT_SECRET // Chave disponível no painel de projetos da Rebound
});

async function processarPagamento(dados) {
  if (dados.valor > 10000) {
    throw new Error('Limite excedido na operadora');
  }

  return 'aprovado';
}

async function run() {
  const dados = {
    userId: 'u-123',
    valor: 15000
  };

  try {
    const resultado = await dlq.execute(
      () => processarPagamento(dados),
      dados,
      {
        flowKey: 'pagarme-payments',
        flowLabel: 'Integração Pagarme',
        flowStep: 'create_charge'
      }
    );

    console.log('Deu tudo certo:', resultado);
  } catch (error) {
    console.log('Erro local tratado:', error.message);
    // O SDK já registrou o evento em background
  }
}

run();