Webhook → email transacional

Zhex
  ↓ POST webhook signed (HMAC)
seu /api/webhook (responde 2xx rápido, menos de 30s)
  ↓ enqueue BullMQ/SQS/Cloud Tasks
worker
  ↓ fetch template + variáveis
SendGrid/Resend/SES
  ↓ delivery
caixa do cliente

import { Worker } from 'bullmq';

new Worker('emails', async (job) => {
  const { eventData: event } = job.data;
  const intent = event.data?.object;

  switch (event.type) {
    case 'payment_intent.succeeded':
      return sendReceipt(intent);
    case 'payment_intent.payment_failed':
      return sendDunning(intent);
    case 'charge.dispute.created':
      return sendChargebackNotice(intent);
    default:
      return; // tipos não cobertos: ignora
  }
}, { connection: { host: process.env.REDIS_HOST } });

import Zhex from '@zhexio/node';
const zhex = new Zhex(process.env.ZHEX_SECRET_KEY);

async function sendReceipt(intent) {
  const customer = await zhex.customers.retrieve(intent.customer);
  return sendEmail({
    to: customer.email,
    template: 'receipt',
    data: {
      customerName: customer.name,
      amount: formatBRL(intent.amount),
      paymentIntentId: intent.id,
      receiptUrl: `https://meusite.com/recibo/${intent.id}`,
    },
  });
}

npm install @sendgrid/mail

import sgMail from '@sendgrid/mail';
sgMail.setApiKey(process.env.SENDGRID_API_KEY);

const TEMPLATE_IDS = {
  receipt: 'd-abc123',
  dunning: 'd-def456',
  chargeback: 'd-xyz789',
};

export async function sendEmail({ to, template, data }) {
  await sgMail.send({
    to,
    from: { email: 'cobranca@meusite.com', name: 'MeuSite Pagamentos' },
    templateId: TEMPLATE_IDS[template],
    dynamicTemplateData: data,
  });
}

npm install resend

import { Resend } from 'resend';
const resend = new Resend(process.env.RESEND_API_KEY);

export async function sendEmail({ to, template, data }) {
  await resend.emails.send({
    from: 'MeuSite <cobranca@meusite.com>',
    to,
    subject: SUBJECTS[template],
    react: TEMPLATES[template](data),     // React Email components
  });
}

npm install postmark

import { ServerClient } from 'postmark';
const client = new ServerClient(process.env.POSTMARK_TOKEN);

export async function sendEmail({ to, template, data }) {
  await client.sendEmailWithTemplate({
    From: 'cobranca@meusite.com',
    To: to,
    TemplateAlias: template,
    TemplateModel: data,
  });
}

npm install @aws-sdk/client-sesv2

import { SESv2Client, SendEmailCommand } from '@aws-sdk/client-sesv2';
const ses = new SESv2Client({ region: 'us-east-1' });

export async function sendEmail({ to, template, data }) {
  await ses.send(new SendEmailCommand({
    FromEmailAddress: 'cobranca@meusite.com',
    Destination: { ToAddresses: [to] },
    Content: {
      Template: {
        TemplateName: template,
        TemplateData: JSON.stringify(data),
      },
    },
  }));
}

Olá, {{customerName}}!

Seu pagamento de {{amount}} foi aprovado.

[ Acessar produto ]({{accessUrl}})
[ Ver recibo ]({{receiptUrl}})

Qualquer dúvida, é só responder este email.

Oi, {{customerName}}.

Tentamos cobrar {{amount}} mas o cartão recusou ({{declineMessage}}).

O que fazer:
1. Verifique saldo/limite no app do banco
2. Ou tente outro cartão: [Tentar de novo]({{retryUrl}})

A oferta fica disponível por 24h.

Olá, {{customerName}}.

Vimos que você abriu uma disputa no seu cartão e o valor de {{amount}} foi estornado para sua conta.

Se foi um engano, é só responder este email — abrimos um novo pedido sem custo extra.

Se foi proposital, está tudo certo. Acesso ao produto foi removido.

await sgMail.send({
  to: customer.email,
  from: '...',
  templateId: 'd-receipt',
  dynamicTemplateData: data,
  customArgs: {
    zhex_event_id: event.id,    // dedup do lado do SendGrid
  },
});

async function sendOnce(eventId, to, template, data) {
  const existing = await db.sentEmails.findFirst({
    where: { eventId, to, template },
  });
  if (existing) return; // já mandei

  await sendEmail({ to, template, data });
  await db.sentEmails.create({ data: { eventId, to, template, sentAt: new Date() } });
}

if (process.env.NODE_ENV === 'production' && !event.livemode) return;