Node.js SDK

const { data, error, headers } = await rqe.emails.send({ /* ... */ });

if (error) {
  switch (error.statusCode) {
    case 401: /* Invalid API key */ break;
    case 429: /* Rate limit — wait and retry */ break;
    default:  console.error(error);
  }
  return;
}

console.log(data.email_id);
console.log('Idempotency replayed:', headers['idempotency-replayed']);

// Single email
await rqe.emails.send({
  sender: 'support@brand.com',
  recipient: 'user@example.com',
  subject: 'Confirmation',
  html: '<p>Your order was received.</p>',
  attachments: [{ filename: 'invoice.pdf', content: base64Pdf }],
});

// Broadcast — one template to up to 10,000 recipients
await rqe.emails.sendBatch({
  sender: 'noreply@brand.com',
  subject: 'Hello {{name}}',
  html: '<p>Hello {{name}}, your {{plan}} plan renews soon.</p>',
  recipients: [
    { email: 'a@x.com', data: { name: 'Alice', plan: 'Pro' } },
    { email: 'b@x.com', data: { name: 'Bob', plan: 'Free' } },
  ],
});

// Upsert by email
await rqe.leads.upsert({
  email: 'user@example.com',
  data: { plan: 'pro', signup_date: '2026-04-30' },
  segment_ids: ['seg-uuid-1'],
});

// Bulk up to 1000
await rqe.leads.upsertMany({
  leads: [
    { email: 'a@x.com', data: { plan: 'pro' } },
    { email: 'b@x.com' },
  ],
});

// Tags by email
await rqe.leads.addTags('user@example.com', ['vip', 'beta']);
const { data } = await rqe.leads.getTags('user@example.com');

// Custom attributes (raw body, NOT wrapped)
await rqe.leads.setAttributes('user@example.com', {
  total_orders: 42,
  last_order_date: '2026-04-30',
});

// List with pagination
const page = await rqe.leads.list({ page: 1, per_page: 50, search: 'pro' });

// Get / update / delete by UUID
const { data: { lead } } = await rqe.leads.get('lead-uuid');
await rqe.leads.update('lead-uuid', { data: { plan: 'enterprise' } });
await rqe.leads.delete('lead-uuid');

// Idempotent enroll — pass trigger_reference_id so that multiple calls
// with the same external_id do NOT create duplicate runs, but instead update the existing run
await rqe.automations.enroll('automation-uuid', {
  email: 'user@example.com',
  data: { first_name: 'Adriano', plan: 'pro' },
  trigger_reference_id: 'order-12345',
});

// Manual enroll (UI-style bulk)
await rqe.automations.manualEnroll('automation-uuid', {
  emails: ['a@x.com', 'b@x.com'],
});

// Cancel by recipient
await rqe.automations.cancel('automation-uuid', {
  email: 'user@example.com',
  reason: 'payment_succeeded',
});

// Cancel by external_id (when you don't have the email)
await rqe.automations.cancelByExternalId('automation-uuid', {
  external_id: 'order-12345',
});

// Single event
await rqe.events.track({
  email: 'user@example.com',
  event: 'offer_accepted',
  properties: { offer_id: 'xyz', amount_usd: 5000 },
});

// Bulk up to 1000
await rqe.events.bulk([
  { email: 'a@b.com', event: 'page_view', properties: { url: '/pricing' } },
  { email: 'c@d.com', event: 'page_view', properties: { url: '/features' } },
]);

// List with filters + offset pagination
const { data } = await rqe.events.list({
  email: 'user@example.com',
  event: 'offer_accepted',
  since: '2026-04-01T00:00:00Z',
  per_page: 50,
});

const rqe = new RQE({
  apiKey: process.env.RQE_API_KEY,
  projectId: process.env.RQE_PROJECT_ID,
});

// List all senders
const { data } = await rqe.senders.list();
// data.senders = [{ email, sender_name, status, type, ... }, ...]

// Filter only verified ones
const { data: verified } = await rqe.senders.list({ status: 'verified' });

// Choose a sender at runtime based on context
const transactionalSender = verified.senders.find(s => s.email.startsWith('noreply@'));
await rqe.emails.send({
  sender: transactionalSender.email,
  recipient: 'user@example.com',
  subject: 'Confirmation',
  html: '<p>...</p>',
});

// Verify a new sender (a magic link is sent to the email)
await rqe.senders.verifyEmail({ email: 'support@brand.com' });

// Check the status of a specific sender
const { data: st } = await rqe.senders.status('support@brand.com');
// st.status: 'Success' | 'Pending' | 'Failed' | 'NotStarted'

await rqe.emails.send(
  {
    sender: 'support@brand.com',
    recipient: 'user@example.com',
    subject: 'Order #123',
    html: '<p>Confirmation</p>',
  },
  { idempotencyKey: 'order-123-confirmation' },
);

const { data, headers } = await rqe.emails.send(
  { /* ... */ },
  { idempotencyKey: 'unique-id' },
);
if (headers['idempotency-replayed'] === 'true') {
  console.log('Replay — the backend had already processed this request');
}