Bulk Sending

import { Convoup, ConvoupError } from 'convoup';

const client = new Convoup({
  apiKey: process.env.CONVOUP_API_KEY!,
});

const customers = [
  { phone: '+918851479441', invoiceId: 'INV-001', amount: 'Rs. 2,500', pdfUrl: 'https://api.example.com/invoices/INV-001.pdf' },
  { phone: '+919876543210', invoiceId: 'INV-002', amount: 'Rs. 4,800', pdfUrl: 'https://api.example.com/invoices/INV-002.pdf' },
  // ... 498 more customers
];

let sent = 0;
let failed = 0;

for (const customer of customers) {
  try {
    await client.sendInvoice({
      to: customer.phone,
      template: 'test_welcome_template',
      params: [customer.invoiceId, customer.amount],
      pdfUrl: customer.pdfUrl,
    });
    sent++;
  } catch (err) {
    failed++;
    if (err instanceof ConvoupError) {
      console.error(`Failed for ${customer.phone}: ${err.code} - ${err.message}`);
      if (err.code === 'TEMPLATE_NOT_FOUND') {
        console.error('Template not found. Aborting batch.');
        break;
      }
    } else {
      console.error(`Unexpected error for ${customer.phone}:`, err);
    }
  }
}

console.log(`Done. Sent: ${sent}, Failed: ${failed}`);

function delay(ms: number): Promise<void> {
  return new Promise(resolve => setTimeout(resolve, ms));
}

for (const customer of customers) {
  try {
    await client.sendInvoice({
      to: customer.phone,
      template: 'test_welcome_template',
      params: [customer.invoiceId, customer.amount],
      pdfUrl: customer.pdfUrl,
    });
    sent++;
  } catch (err) {
    failed++;
    if (err instanceof ConvoupError && err.code === 'TEMPLATE_NOT_FOUND') break;
  }

  // 100ms delay (conservative; platform supports up to 100 msg/sec for campaigns)
  await delay(100);
}

async function bulkSendWithConcurrency(
  customers: Customer[],
  concurrency: number,
): Promise<{ sent: number; failed: number }> {
  let sent = 0;
  let failed = 0;

  const chunks: Customer[][] = [];
  for (let i = 0; i < customers.length; i += concurrency) {
    chunks.push(customers.slice(i, i + concurrency));
  }

  for (const chunk of chunks) {
    const results = await Promise.allSettled(
      chunk.map(c =>
        client.sendInvoice({
          to: c.phone,
          template: 'test_welcome_template',
          params: [c.invoiceId, c.amount],
          pdfUrl: c.pdfUrl,
        })
      )
    );

    for (const result of results) {
      if (result.status === 'fulfilled') sent++;
      else failed++;
    }

    // 500ms between chunks to stay within rate limits
    await delay(500);
  }

  return { sent, failed };
}

const results = await bulkSendWithConcurrency(customers, 10);
console.log(`Sent: ${results.sent}, Failed: ${results.failed}`);