Claude Agent SDK

// npm install @flow-engineer/messaging @anthropic-ai/claude-agent-sdk
import { query } from "@anthropic-ai/claude-agent-sdk";
import { FlowMessaging, contentText } from "@flow-engineer/messaging";

const flow = new FlowMessaging();

for await (const event of flow.events.stream({ types: ["message.received"] })) {
  const run = query({
    prompt: contentText(event.data.message.content),
    options: {
      systemPrompt: "You are the assistant for Asha's Bakery. Answer customers in short messages.",
      tools: [], // no built-in tools (Bash, file access); list the ones your agent may use
      includePartialMessages: true, // stream text as it is written
    },
  });
  await event.conversation.reply(run); // sends the agent's text, skips tool and system messages
}

# pip install claude-agent-sdk 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 claude_agent_sdk import query, ClaudeAgentOptions, AssistantMessage, TextBlock

API = "https://api.flow.engineer"
HEADERS = {"Authorization": f"Bearer {os.environ['FLOW_MESSAGING_KEY']}"}

async def answer(event: dict):
    conversation = event["conversation"]["id"]
    text = event["data"]["message"]["content"].get("text", "")
    options = ClaudeAgentOptions(
        system_prompt="You are the assistant for Asha's Bakery. Answer in short messages.",
        tools=[],  # no built-in tools; list the ones your agent may use
    )
    i = 0
    async for message in query(prompt=text, options=options):
        if isinstance(message, AssistantMessage):
            for block in message.content:
                if isinstance(block, TextBlock) and block.text.strip():
                    requests.post(
                        f"{API}/v0/conversations/{conversation}/basic",
                        headers={**HEADERS, "Idempotency-Key": f"{event['id']}:{i}"},
                        json={"text": block.text},  # sent exactly as written: no markdown is rendered
                        timeout=30,
                    )
                    i += 1