Mastra agents on Telegram and iMessage

This page puts a Mastra agent on Telegram and iMessage: Flow delivers each message, and reply() sends the agent’s stream back as chat bubbles. iMessage is for replies only, on a line the Flow team sets up for your app; WhatsApp is coming (it waits on Meta’s approval) and will use the same code.

TypeScript

// npm install @flow-engineer/messaging @mastra/core @ai-sdk/openai
import { Agent } from "@mastra/core/agent";
import { openai } from "@ai-sdk/openai";
import { FlowMessaging, contentText } from "@flow-engineer/messaging";

const flow = new FlowMessaging();
const agent = new Agent({
  id: "bakery-assistant",
  name: "Bakery assistant",
  instructions: "You help customers of Asha's Bakery with orders and delivery. Keep answers short.",
  model: openai("gpt-4.1-mini"),
});

for await (const event of flow.events.stream({ types: ["message.received"] })) {
  const stream = await agent.stream(contentText(event.data.message.content));
  await event.conversation.reply(stream); // reads stream.textStream
}

How it fits

reply() reads the stream’s textStream, keeps typing on and sends a bubble at each paragraph break.
Mastra memory: use the Flow conversation.id as the thread ID and conversation.contact (the contact’s ID) as the resource ID, so each person keeps their own history.
In a Mastra server, receive Flow webhooks on a custom route and call the same code; verify signatures with flow.webhooks.constructEvent(rawBody, signatureHeader, secret), which returns the typed event with event.conversation ready to reply on. See Events and webhooks.

Full example

examples/mastra on GitHub.

Get started

Concepts

Channel guides

Agent frameworks

Compare

Mastra agents on Telegram and iMessage

How it fits

Full example

​How it fits

​Full example

How it fits

Full example