Registros de turno

from niadra import Niadra, phone

niadra = Niadra(channel="whatsapp")


@Niadra.tool("search_products", provenance=lambda r: [{"ref": f"product:store:{r['sku']}", "fields": r["prices"]}])
def search_products(sku: str) -> dict:
    return catalog.find(sku)


with niadra.conversation("wa-8812", subject=phone("+5511900005678"), agent_id="store") as conversation:
    conversation.customer(text)
    with conversation.turn(build=Niadra.build(prompts={"store": "v3"}, model="gpt-4.1-mini")):
        context = conversation.context()
        product = search_products("PX-4471")  # recorded: arguments, result, latency, the objects it showed
        reply = model(prompt_with(context, product))
        conversation.agent(reply)  # the record points at this event; the text is never repeated

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

const niadra = new Niadra();
const searchProducts = Niadra.tool("search_products", async (sku: string) => catalog.find(sku), {
  provenance: (r) => [{ ref: `product:store:${r.sku}`, fields: r.prices }],
});

const convo = niadra.conversation({ subject: handles.phone("+5511900005678"), channel: "whatsapp", conversation_id: "wa-8812" });
convo.customer(text, { idempotency_key: inbound.id });
await convo.turn({ build: Niadra.build({ prompts: { store: "v3" }, model: "gpt-4.1-mini" }) }, async () => {
  const ctx = await convo.context();
  const product = await searchProducts("PX-4471"); // recorded: arguments, result, latency, the objects it showed
  convo.agent(await model(promptWith(ctx, product))); // the record points at this event; the text is never repeated
});