WhatsApp | Trigger.dev

Send messages, images, video with WhatsApp.

Using the WhatsApp API with Trigger.dev

You can use Trigger.dev with any existing Node SDK or even just using fetch. Using io.runTask makes your WhatsApp background job resumable and appear in our dashboard.

Use io.runTask() and the official SDK or fetch.

Use our HTTP endpoint to subscribe to webhooks

Example code using WhatsApp

Below are some working code examples of how you can use WhatsApp with Trigger.dev. These samples are open source and maintained by the community, you can copy and paste them into your own projects.

A job that is triggered by a WhatsApp webhook.Send a message to a WhatsApp number

1
import { TriggerClient, eventTrigger } from "@trigger.dev/sdk";
2
import z from "zod";
3
// You have to need Whatsapp Business API account
4
// Get started https://developers.facebook.com/docs/whatsapp/cloud-api/get-started
5
// For Permanent token you have to create system user https://business.facebook.com/settings/system-users
6
// User need to first send message then you can send message to user via API. Only hello_world message is allowed for first message.
7
// Learn more about cloud-api https://developers.facebook.com/docs/whatsapp/cloud-api/reference
8
const endpointURL = `https://graph.facebook.com/v17.0/${process.env.WHATSAPP_PHONE_NUMBER_ID}/messages`;
9

10
// Create request options
11
const requestOptions: RequestInit = {
12
  method: "POST",
13
  headers: {
14
    Authorization: `Bearer ${process.env.WHATSAPP_BEARER_TOKEN}`,
15
    "content-type": "application/json",
16
  },
17
};
18

19
client.defineJob({
20
  id: "whatsapp-send-messages",
21
  name: "Whatsapp Send Messages",
22
  version: "1.0.0",
23
  trigger: eventTrigger({
24
    name: "whatsapp-send-messages",
25
    schema: z.object({
26
      text: z.string(),
27
      to: z.string(),
28
    }),
29
  }),
30
  run: async (payload, io, ctx) => {
31
    const { text, to } = payload;
32

33
    // Wrap an SDK call in io.runTask so it's resumable and displays in logs
34
    await io.runTask(
35
      "Whatsapp Send Messages",
36
      async () => {
37
        // Make request using Fetch API
38
        return await fetch(endpointURL, {
39
          ...requestOptions,
40
          body: JSON.stringify({
41
            messaging_product: "whatsapp",
42
            recipient_type: "individual",
43
            to,
44
            type: "text",
45
            text: {
46
              body: text,
47
            },
48
          }),
49
        }).then((response) => response.json());
50
      },
51

52
      // Add metadata to the task to improve the display in the logs
53
      { name: "Whatsapp Send Messages", icon: "whatsapp" }
54
    );
55
  },
56
});