Mastra

// 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
}