MCP com qualquer LLM

from niadra import Niadra, phone

niadra = Niadra()

token = niadra.subject_token(
    phone("+14155550123"),
    conversation_id="call-4471",
    verification="V1",
)
headers = {"Authorization": f"Bearer {NIADRA_API_KEY}", **token.headers}

import { Niadra, handles } from "@niadra/sdk";

const niadra = new Niadra();

const { data: token } = await niadra.subjectToken({
  subject: handles.phone("+14155550123"),
  conversation_id: "call-4471",
  verification: "V1",
});
const headers = {
  Authorization: `Bearer ${process.env.NIADRA_API_KEY}`,
  "Niadra-Subject-Token": token!.token,
};

curl -X POST "https://acme-prod.us-east-1.api.niadra.com/v1/subject-tokens" \
  -H "Authorization: Bearer $NIADRA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "subject": { "type": "phone_e164", "value": "+14155550123" },
    "conversation_id": "call-4471",
    "verification": "V1"
  }'

from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

async with streamablehttp_client(niadra.mcp_url, headers=headers) as (read, write, _):
    async with ClientSession(read, write) as session:
        await session.initialize()
        tools = await session.list_tools()
        ctx = await session.call_tool("get_customer_context", {"view": "voice"})

import { Client } from "@modelcontextprotocol/sdk/client/index.js";
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";

const transport = new StreamableHTTPClientTransport(
  new URL("https://acme-prod.us-east-1.api.niadra.com/mcp"),
  { requestInit: { headers } },
);
const client = new Client({ name: "voice-agent", version: "1.0.0" });
await client.connect(transport);

const { tools } = await client.listTools();
const ctx = await client.callTool({ name: "get_customer_context", arguments: { view: "voice" } });

kit = niadra.tools(phone("+14155550123"), conversation_id="call-4471", verification="V1")

response = anthropic.messages.create(
    model=MODEL,
    max_tokens=1024,
    system=[{"type": "text", "text": AGENT_INSTRUCTIONS}, {"type": "text", "text": ctx.system_block}],
    tools=kit.anthropic_definitions(),
    messages=messages,
)
for block in response.content:
    if block.type == "tool_use":
        output = kit.call(block.name, block.input)
        messages.append({"role": "user", "content": [{"type": "tool_result", "tool_use_id": block.id, "content": output}]})

const kit = niadra.tools(handles.phone("+14155550123"), { conversation_id: "call-4471", verification: "V1" });

const reply = await openai.chat.completions.create({ model: MODEL, messages, tools: kit.definitions });
for (const call of reply.choices[0].message.tool_calls ?? []) {
  const output = await kit.call(call.function.name, call.function.arguments);
  messages.push({ role: "tool", tool_call_id: call.id, content: output });
}

curl "https://acme-prod.us-east-1.api.niadra.com/v1/history/tools" \
  -H "Authorization: Bearer $NIADRA_API_KEY"