OpenAI Agents SDK

// npm install @flow-engineer/messaging @openai/agents
import { Agent, run } from "@openai/agents";
import { FlowMessaging, contentText } from "@flow-engineer/messaging";

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

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

# pip install openai-agents fastapi requests
# Plain HTTP, no Flow SDK; the Python SDK (pip install flow-messaging) wraps the same calls. This calls the HTTP API.
import os, requests
from fastapi import FastAPI, Request, BackgroundTasks
from agents import Agent, Runner

API = "https://api.flow.engineer"
HEADERS = {"Authorization": f"Bearer {os.environ['FLOW_MESSAGING_KEY']}"}
agent = Agent(name="Bakery assistant", instructions="You help customers of Asha's Bakery. Keep answers short.")
app = FastAPI()

async def answer(event: dict):
    text = event["data"]["message"]["content"].get("text", "")
    result = await Runner.run(agent, text)
    requests.post(
        f"{API}/v0/conversations/{event['conversation']['id']}/basic",
        headers={**HEADERS, "Idempotency-Key": event["id"]},
        json={"text": result.final_output},  # sent exactly as written: no markdown is rendered
        timeout=30,
    )

@app.post("/flow")
async def flow_webhook(request: Request, tasks: BackgroundTasks):
    event = await request.json()  # verify Flow-Signature first: see Events and webhooks
    if event["type"] == "message.received":
        tasks.add_task(answer, event)
    return {}