FastAPI

from fastapi import FastAPI
from superdialog import DialogMachine

app = FastAPI()
agent = DialogMachine("kyc.yaml", llm="openai/gpt-4.1-mini")  # any format

@app.post("/turn")
async def turn(payload: dict):
    reply = await agent.turn(payload["text"])
    return {"reply": reply.text}

from contextlib import asynccontextmanager
from fastapi import FastAPI
from superdialog import DialogMachine, SessionWorker, InMemorySessionStore

worker: SessionWorker

@asynccontextmanager
async def lifespan(app: FastAPI):
    global worker
    worker = SessionWorker(
        agent_factory=lambda: DialogMachine("booking.yaml", llm="openai/gpt-4.1-mini"),
        store=InMemorySessionStore(),    # swap for a distributed SessionStore in production
    )
    yield

app = FastAPI(lifespan=lifespan)

@app.post("/turn")
async def turn(payload: dict):
    async with worker.acquire(payload["session_id"]) as h:
        result = await h.turn(payload["text"])
    return {"reply": result.text}

from fastapi import FastAPI
from fastapi.responses import StreamingResponse
from superdialog import DialogMachine

app = FastAPI()
agent = DialogMachine("kyc.yaml", llm="anthropic/claude-haiku-4-5")

@app.post("/stream")
async def stream(payload: dict):
    async def generate():
        stream = await agent.turn(payload["text"], stream=True)
        async for chunk in stream:
            yield chunk.text

    return StreamingResponse(generate(), media_type="text/plain")

from fastapi import FastAPI
from superdialog import DialogMachine
from superdialog.adapters.fastapi import FastAPIRouter

agent = DialogMachine("kyc.yaml", llm="openai/gpt-4.1-mini")

app = FastAPI()
app.include_router(FastAPIRouter(agent), prefix="/dialog")
# Exposes: POST /dialog/turn, POST /dialog/stream, POST /dialog/reset

// POST /turn
{ "text": "Hello, I need to verify my KYC.", "session_id": "user-42" }

// Response
{ "reply": "Sure! Could you please provide the last 4 digits of your Aadhaar?" }