WhatsApp

// app/api/whatsapp/route.ts (Next.js). npm install @flow-engineer/messaging ai @ai-sdk/openai
import { FlowMessaging, contentText } from "@flow-engineer/messaging";
import { streamText } from "ai";
import { openai } from "@ai-sdk/openai";

const flow = new FlowMessaging();

export const POST = flow.webhooks.handler({
  onEvent: async (event) => {
    if (event.type !== "message.received") return;
    const question = contentText(event.data.message.content); // text, caption or a tapped button's label
    // Answer after the webhook returns: reply() keeps typing on and sends bubbles as they are ready.
    void event.conversation.reply(
      streamText({ model: openai("gpt-4.1-mini"), system: "You are the assistant for Asha's Bakery.", prompt: question }),
      { idempotencyKey: event.id },
    );
  },
});

export const POST = flow.webhooks.handler({
  onEvent: async (event) => {
    if (event.type !== "message.received") return;
    return await answer(contentText(event.data.message.content)); // a string, a kind object, or a list of up to 11
  },
});

{ "reply": { "kind": "basic", "text": "Yes, we deliver to 560103. Delivery takes about 40 minutes." } }

import { buttons } from "@flow-engineer/messaging";

await event.conversation.send(buttons("How would you like to pay?", [
  { id: "upi", label: "UPI" },
  { id: "card", label: "Card" },
  { id: "cod", label: "Cash on delivery" },
]));

import { template } from "@flow-engineer/messaging";

// Follow up two days later: only a template may go.
await flow.conversation(conversationId).send(
  template("tpl_01JB8ZC3K5M7P9R1T3V5X7Z9B1", "en", { body: ["Asha", "order 1042"] }),
);