Node-based agents

import os, httpx

API = "https://sandbox.voice.miraiminds.co"
auth = {"Authorization": f"Bearer {os.environ['MIRAI_API_KEY']}"}

BRIEF = (
    "Call customers of Acme Retail to confirm the delivery slot for their order. "
    "Speak everyday Hindi and say you are an AI assistant. "
    "First confirm you are speaking to the customer by name; if it is someone else, "
    "apologise and end the call without mentioning the order. "
    "Then give the order number, delivery date and time window, and ask whether "
    "someone will be at home. If yes, thank them and end. If not, ask which day in "
    "the next seven days suits them, read it back, and end once they confirm. "
    "Record whether they confirmed who they are, whether they accepted the slot, "
    "and the new day if they chose one."
)

r = httpx.post(
    f"{API}/v2/agents/flow/generate",
    headers=auth,
    json={"brief": BRIEF, "language": "hi", "model": "gemini-3.8-flash"},
    timeout=300,  # allow a few minutes
)
if r.status_code in (429, 503):
    raise RuntimeError(f"retry in {r.headers.get('Retry-After')} s")
if r.status_code == 422:  # charged: the body carries id, usage and cost
    for problem in r.json()["details"]:
        print(problem["path"], "-", problem["message"])
draft = r.raise_for_status().json()
print(draft["id"], draft["model"], draft["cost"]["amount_inr"])
print([v["name"] for v in draft["variables"]])

const API = "https://sandbox.voice.miraiminds.co";
const auth = { Authorization: `Bearer ${process.env.MIRAI_API_KEY}` };

const BRIEF = [
  "Call customers of Acme Retail to confirm the delivery slot for their order.",
  "Speak everyday Hindi and say you are an AI assistant.",
  "First confirm you are speaking to the customer by name; if it is someone else,",
  "apologise and end the call without mentioning the order.",
  "Then give the order number, delivery date and time window, and ask whether",
  "someone will be at home. If yes, thank them and end. If not, ask which day in",
  "the next seven days suits them, read it back, and end once they confirm.",
  "Record whether they confirmed who they are, whether they accepted the slot,",
  "and the new day if they chose one.",
].join(" ");

const res = await fetch(`${API}/v2/agents/flow/generate`, {
  method: "POST",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify({ brief: BRIEF, language: "hi", model: "gemini-3.8-flash" }),
  signal: AbortSignal.timeout(300_000), // allow a few minutes
});
const draft = await res.json();
if (!res.ok) {
  if (res.status === 429 || res.status === 503) {
    throw new Error(`retry in ${res.headers.get("Retry-After")} s`);
  }
  for (const { path, message } of draft.details ?? []) console.error(path, "-", message);
  throw new Error(draft.error?.code ?? draft.error);
}
console.log(draft.id, draft.model, draft.cost.amount_inr);
console.log(draft.variables.map((v) => v.name));

agent = httpx.post(
    f"{API}/v2/agents",
    headers=auth,
    json={
        "name": "Delivery slot confirmation",
        "voice": {"voice_id": "neha", "language": "hi-IN"},
        "language": "hi-IN",
        "max_duration_secs": 240,
        "flow": draft["flow"],
        "input_schema": draft["input_schema"],
    },
    timeout=30,
).raise_for_status().json()
print(agent["id"], agent["revision"])

const created = await fetch(`${API}/v2/agents`, {
  method: "POST",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify({
    name: "Delivery slot confirmation",
    voice: { voice_id: "neha", language: "hi-IN" },
    language: "hi-IN",
    max_duration_secs: 240,
    flow: draft.flow,
    input_schema: draft.input_schema,
  }),
});
const agent = await created.json();
if (!created.ok) throw new Error(JSON.stringify(agent));
console.log(agent.id, agent.revision);

agent_id = "agt_01K8C4D6F8H0J2K4M6N8P0Q2RS"
current = httpx.get(
    f"{API}/v2/agents/{agent_id}/flow", headers=auth, timeout=30
).raise_for_status().json()

revised = httpx.post(
    f"{API}/v2/agents/flow/generate",
    headers=auth,
    json={
        "brief": "If the customer is busy right now, offer to call back later and end politely.",
        "language": "hi",
        "flow": current["flow"],
    },
    timeout=300,
).raise_for_status().json()

r = httpx.patch(
    f"{API}/v2/agents/{agent_id}",
    headers=auth,
    json={
        "if_revision": current["agent_revision"],
        "flow": revised["flow"],
        "input_schema": revised["input_schema"],
    },
    timeout=30,
)
if r.status_code == 409:
    raise RuntimeError("the agent changed since it was read; read the flow again")
print(r.raise_for_status().json()["revision"])

const agentId = "agt_01K8C4D6F8H0J2K4M6N8P0Q2RS";
const current = await fetch(`${API}/v2/agents/${agentId}/flow`, { headers: auth })
  .then((r) => r.json());

const gen = await fetch(`${API}/v2/agents/flow/generate`, {
  method: "POST",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify({
    brief: "If the customer is busy right now, offer to call back later and end politely.",
    language: "hi",
    flow: current.flow,
  }),
  signal: AbortSignal.timeout(300_000),
});
const revised = await gen.json();
if (!gen.ok) throw new Error(JSON.stringify(revised));

const res = await fetch(`${API}/v2/agents/${agentId}`, {
  method: "PATCH",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify({
    if_revision: current.agent_revision,
    flow: revised.flow,
    input_schema: revised.input_schema,
  }),
});
if (res.status === 409) throw new Error("the agent changed since it was read; read the flow again");
const agent = await res.json();
if (!res.ok) throw new Error(JSON.stringify(agent));
console.log(agent.revision);

import json, os, httpx

API = "https://sandbox.voice.miraiminds.co"
auth = {"Authorization": f"Bearer {os.environ['MIRAI_API_KEY']}"}

with open("delivery-flow.json", encoding="utf-8") as f:
    flow = json.load(f)

r = httpx.post(f"{API}/v2/agents/flow/validate", headers=auth, json=flow, timeout=30)
if r.status_code == 400 and r.json().get("error") == "invalid_flow":
    for problem in r.json()["details"]:
        print(problem["path"], "-", problem["message"])
r.raise_for_status()
print(r.json())  # {'ok': True, 'flow_revision': 'ffe29d96cc606b2c53ba', 'nodes': 6, 'edges': 5}

import { readFile } from "node:fs/promises";

const API = "https://sandbox.voice.miraiminds.co";
const auth = { Authorization: `Bearer ${process.env.MIRAI_API_KEY}` };
const flow = JSON.parse(await readFile("delivery-flow.json", "utf8"));

const res = await fetch(`${API}/v2/agents/flow/validate`, {
  method: "POST",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify(flow),
});
const out = await res.json();
if (!res.ok) {
  for (const { path, message } of out.details ?? []) console.error(path, "-", message);
  throw new Error(out.error?.code ?? out.error);
}
console.log(out); // { ok: true, flow_revision: "ffe29d96cc606b2c53ba", nodes: 6, edges: 5 }

agent = httpx.post(
    f"{API}/v2/agents",
    headers=auth,
    json={
        "name": "Delivery slot confirmation",
        "voice": {"voice_id": "neha", "language": "hi-IN"},
        "language": "hi-IN",
        "max_duration_secs": 240,
        "voicemail": {"action": "hangup"},
        "flow": flow,
    },
    timeout=30,
).raise_for_status().json()

print(agent["id"], agent["revision"])

const created = await fetch(`${API}/v2/agents`, {
  method: "POST",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify({
    name: "Delivery slot confirmation",
    voice: { voice_id: "neha", language: "hi-IN" },
    language: "hi-IN",
    max_duration_secs: 240,
    voicemail: { action: "hangup" },
    flow,
  }),
});
const agent = await created.json();
if (!created.ok) throw new Error(JSON.stringify(agent));
console.log(agent.id, agent.revision);

test_vars = {
    "customer_name": "Rahul",
    "order_id": "AC-88213",
    "delivery_date": "Friday, 3 October",
    "delivery_window": "10 AM and 1 PM",
}
call = httpx.post(
    f"{API}/v2/calls",
    headers={**auth, "Idempotency-Key": "delivery-flow-test-1"},
    json={
        "agent_id": agent["id"],
        "channel": "web",
        "variables": test_vars,
        "final_results": True,
        "webhook_url": "https://example.com/mirai/webhook",
    },
    timeout=30,
).raise_for_status().json()
# Hand only these two links to the page.
links = {"ws_url": call["ws_url"], "events_url": call["events_url"]}

const testVars = {
  customer_name: "Rahul",
  order_id: "AC-88213",
  delivery_date: "Friday, 3 October",
  delivery_window: "10 AM and 1 PM",
};
const res = await fetch(`${API}/v2/calls`, {
  method: "POST",
  headers: {
    ...auth,
    "Content-Type": "application/json",
    "Idempotency-Key": "delivery-flow-test-1",
  },
  body: JSON.stringify({
    agent_id: agent.id,
    channel: "web",
    variables: testVars,
    final_results: true,
    webhook_url: "https://example.com/mirai/webhook",
  }),
});
const call = await res.json();
if (!res.ok) throw new Error(`${call.error.code}: ${call.error.message}`);
// Hand only these two links to the page.
const links = { ws_url: call.ws_url, events_url: call.events_url };

call = httpx.post(
    f"{API}/v2/calls",
    headers={**auth, "Idempotency-Key": "order-AC-88213-slot-1"},
    json={
        "agent_id": agent["id"],
        "to": "+919876543210",
        "variables": test_vars,
        "metadata": {"order_id": "AC-88213"},
        "final_results": True,
        "webhook_url": "https://example.com/mirai/webhook",
    },
    timeout=30,
).raise_for_status().json()
print(call["id"], call["status"])  # call_… queued

const dial = await fetch(`${API}/v2/calls`, {
  method: "POST",
  headers: {
    ...auth,
    "Content-Type": "application/json",
    "Idempotency-Key": "order-AC-88213-slot-1",
  },
  body: JSON.stringify({
    agent_id: agent.id,
    to: "+919876543210",
    variables: testVars,
    metadata: { order_id: "AC-88213" },
    final_results: true,
    webhook_url: "https://example.com/mirai/webhook",
  }),
});
const placed = await dial.json();
if (!dial.ok) throw new Error(`${placed.error.code}: ${placed.error.message}`);
console.log(placed.id, placed.status); // call_… queued

agent_id = "agt_01K8C4D6F8H0J2K4M6N8P0Q2RS"
current = httpx.get(
    f"{API}/v2/agents/{agent_id}/flow", headers=auth, timeout=30
).raise_for_status().json()

flow = current["flow"]
for node in flow["nodes"]:
    if node["id"] == "goodbye":
        node["data"]["allow_interrupt"] = True  # let the caller interrupt the close

r = httpx.put(
    f"{API}/v2/agents/{agent_id}/flow",
    params={"if_revision": current["agent_revision"]},
    headers=auth,
    json=flow,
    timeout=30,
)
if r.status_code == 409:
    raise RuntimeError("the agent changed since it was read; read the flow again")
agent = r.raise_for_status().json()
print(agent["revision"])  # 2

const agentId = "agt_01K8C4D6F8H0J2K4M6N8P0Q2RS";
const current = await fetch(`${API}/v2/agents/${agentId}/flow`, { headers: auth })
  .then((r) => r.json());

const flow = current.flow;
const close = flow.nodes.find((n) => n.id === "goodbye");
close.data.allow_interrupt = true; // let the caller interrupt the close

const res = await fetch(
  `${API}/v2/agents/${agentId}/flow?if_revision=${current.agent_revision}`,
  {
    method: "PUT",
    headers: { ...auth, "Content-Type": "application/json" },
    body: JSON.stringify(flow),
  }
);
if (res.status === 409) throw new Error("the agent changed since it was read; read the flow again");
const agent = await res.json();
if (!res.ok) throw new Error(JSON.stringify(agent));
console.log(agent.revision); // 2