LangChain agents on Telegram and iMessage

// npm install @flow-engineer/messaging @langchain/openai
import { ChatOpenAI } from "@langchain/openai";
import { FlowMessaging, contentText } from "@flow-engineer/messaging";

const flow = new FlowMessaging();
const model = new ChatOpenAI({ model: "gpt-4.1-mini" });

for await (const event of flow.events.stream({ types: ["message.received"] })) {
  const stream = await model.stream([
    ["system", "You are the assistant for Asha's Bakery. Answer in short messages."],
    ["human", contentText(event.data.message.content)],
  ]);
  await event.conversation.reply(stream); // reads each chunk's content
}

# pip install langchain-openai fastapi
# There is no Python SDK yet (only TypeScript is published); this answers in the webhook response.
from fastapi import FastAPI, Request
from langchain_openai import ChatOpenAI

model = ChatOpenAI(model="gpt-4.1-mini")
app = FastAPI()

@app.post("/flow")
async def flow_webhook(request: Request):
    event = await request.json()  # verify Flow-Signature first: see Events and webhooks
    if event["type"] != "message.received":
        return {}
    text = event["data"]["message"]["content"].get("text", "")
    answer = await model.ainvoke([("system", "You are the assistant for Asha's Bakery."), ("human", text)])
    return {"reply": {"type": "text", "text": answer.content, "format": "markdown"}, "fallback": "auto"}