Examples

1import express from 'express';
2import { createWhatsAppHandler } from './whatsapp-handler';
3 
4const app = express();
5app.use(express.json());
6 
7const whatsapp = createWhatsAppHandler({
8  token: process.env.WHATSAPP_TOKEN!,
9  phoneNumberId: process.env.WHATSAPP_PHONE_NUMBER_ID!,
10  webhookVerifyToken: process.env.WHATSAPP_WEBHOOK_VERIFY_TOKEN!
11});
12 
13// Set up handlers
14whatsapp.setWebhookHandlers({
15  onMessage: async (message, metadata) => {
16    const text = message.text?.body;
17    const from = metadata.waId!;
18 
19    if (!text) return;
20 
21    // Echo bot
22    if (text.toLowerCase() === 'hello') {
23      await whatsapp.sendMessage(from, 'Hello! How can I help you?');
24    }
25    else if (text.toLowerCase() === 'help') {
26      await whatsapp.sendMessage(from, 
27        'Available commands:\n- hello\n- help\n- history'
28      );
29    }
30    else if (text.toLowerCase() === 'history') {
31      const history = await whatsapp.getConversationHistory(from, 5);
32      await whatsapp.sendMessage(from, 
33        `You have ${history.length} recent messages`
34      );
35    }
36    else {
37      await whatsapp.sendMessage(from, `You said: ${text}`);
38    }
39  },
40 
41  onVoice: async (voice, metadata) => {
42    const from = metadata.waId!;
43    await whatsapp.sendMessage(from, 'Thanks for the voice message!');
44  },
45 
46  onLocation: async (location, metadata) => {
47    const from = metadata.waId!;
48    const { latitude, longitude } = location.location!;
49    await whatsapp.sendMessage(from, 
50      `Got your location: ${latitude}, ${longitude}`
51    );
52  }
53});
54 
55// Webhook endpoint
56app.use('/webhook', whatsapp.expressMiddleware());
57 
58// Start server
59app.listen(3000, () => {
60  console.log('Bot running on port 3000');
61});

1whatsapp.setWebhookHandlers({
2  onMessage: async (message, metadata) => {
3    const text = message.text?.body;
4    const from = metadata.waId!;
5    
6    // Get conversation state
7    const state = whatsapp.getConversationState(from);
8    const step = state?.currentStep || 'start';
9 
10    switch (step) {
11      case 'start':
12        await whatsapp.sendMessage(from, 'What\'s your name?');
13        whatsapp.updateConversationContext(from, { currentStep: 'name' });
14        break;
15 
16      case 'name':
17        whatsapp.updateConversationContext(from, { 
18          currentStep: 'email',
19          userName: text 
20        });
21        await whatsapp.sendMessage(from, `Nice to meet you, ${text}! What\'s your email?`);
22        break;
23 
24      case 'email':
25        const context = whatsapp.getConversationState(from)?.context;
26        whatsapp.updateConversationContext(from, { 
27          currentStep: 'completed',
28          userEmail: text 
29        });
30        await whatsapp.sendMessage(from, 
31          `Thanks ${context?.userName}! We've saved your email: ${text}`
32        );
33        break;
34 
35      case 'completed':
36        await whatsapp.sendMessage(from, 
37          'Your registration is complete! Type "restart" to start over.'
38        );
39        if (text?.toLowerCase() === 'restart') {
40          whatsapp.updateConversationContext(from, { currentStep: 'start' });
41        }
42        break;
43    }
44  }
45});

1// Send bulk messages with queue
2const recipients = ['1111111111', '2222222222', '3333333333'];
3 
4for (const recipient of recipients) {
5  await whatsapp.sendMessage(recipient, 'Bulk message', {
6    queueIfBusy: true,
7    priority: 0
8  });
9}
10 
11// Listen for queue events
12whatsapp.on('queuedMessageSent', (data) => {
13  console.log(`Queued message sent: ${data.messageId}`);
14});
15 
16whatsapp.on('queuedMessageFailed', (data) => {
17  console.error(`Queued message failed after ${data.attempts} attempts`);
18});
19 
20// Monitor queue
21setInterval(() => {
22  const stats = whatsapp.getQueueStats();
23  console.log(`Queue: ${stats.size}/${stats.maxSize} (${stats.usagePercentage.toFixed(2)}%)`);
24}, 5000);