Anthropic

pip install 'niadra[anthropic]'   # anthropic 1.8 or newer, below 2

npm install @niadra/sdk @anthropic-ai/sdk   # @niadra/sdk/anthropic

"""Anthropic's Messages API with the customer's context in the system prompt."""

from anthropic import Anthropic

from niadra import Niadra, phone
from niadra.integrations.anthropic import wrap

niadra = Niadra(channel="chat")
claude = wrap(Anthropic())

with niadra.conversation("thread-81", subject=phone("+5511912345678")) as conversation:
    conversation.customer("Where is my replacement lid?")
    message = claude.messages.create(
        model="claude-sonnet-4-5",
        max_tokens=512,
        system=[{"type": "text", "text": "You are Acme's agent.", "cache_control": {"type": "ephemeral"}}],
        messages=[{"role": "user", "content": "Where is my replacement lid?"}],
    )
    print(message.content[0].text)

import Anthropic from "@anthropic-ai/sdk";
import { Niadra, handles } from "@niadra/sdk";
import { wrapAnthropic } from "@niadra/sdk/anthropic";

const niadra = new Niadra();
const anthropic = new Anthropic();

/** One customer message in; `userId` comes from your session, never from the model. */
export async function reply(userId: string, chatId: string, text: string): Promise<string> {
  const convo = niadra.conversation({ subject: handles.appUserId(userId), channel: "web_chat", conversation_id: chatId });
  const claude = wrapAnthropic(anthropic, convo, { verify: { method: "login", level: "V2" } });
  const message = await claude.messages.create({
    model: "claude-sonnet-4-5",
    max_tokens: 1024,
    system: "You are Acme's support agent. Be brief.",
    messages: [{ role: "user", content: text }],
  });
  return message.content.map((block) => (block.type === "text" ? block.text : "")).join("");
}