Calls

import os, httpx

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

r = httpx.post(
    f"{API}/v2/calls",
    headers={**auth, "Idempotency-Key": "order-8842-confirm-1"},
    json={
        "agent_id": "agt_01JZQ8F3K7M2N5P9R4T6V8W0XZ",
        "to": "+919876543210",
        "variables": {"customer_name": "Rahul", "order_id": "8842"},
        "webhook_url": "https://example.com/mirai/webhook",
        "max_duration_secs": 240,
    },
    timeout=30,
)
if r.status_code == 402:
    raise RuntimeError(r.json()["error"]["message"])  # top up the wallet
call = r.raise_for_status().json()
print(call["id"], call["status"])  # call_01JZQ9B4M8N3P6R2S5T7V9W1YA queued

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

const res = await fetch(`${API}/v2/calls`, {
  method: "POST",
  headers: {
    ...auth,
    "Content-Type": "application/json",
    "Idempotency-Key": "order-8842-confirm-1",
  },
  body: JSON.stringify({
    agent_id: "agt_01JZQ8F3K7M2N5P9R4T6V8W0XZ",
    to: "+919876543210",
    variables: { customer_name: "Rahul", order_id: "8842" },
    webhook_url: "https://example.com/mirai/webhook",
    max_duration_secs: 240,
  }),
});
const body = await res.json();
if (!res.ok) throw new Error(`${body.error.code}: ${body.error.message}`);
console.log(body.id, body.status); // call_01JZQ9B4M8N3P6R2S5T7V9W1YA queued

import time

TERMINAL = {"completed", "voicemail", "no_answer", "busy", "failed", "timeout", "aborted"}

def wait_for_call(call_id: str, timeout_secs: int = 600) -> dict:
    """Prefer webhooks. Poll only when you cannot host an endpoint."""
    deadline = time.monotonic() + timeout_secs
    while time.monotonic() < deadline:
        call = httpx.get(f"{API}/v2/calls/{call_id}", headers=auth, timeout=30) \
                    .raise_for_status().json()
        if call["status"] in TERMINAL:
            return call
        time.sleep(5)
    raise TimeoutError(call_id)

const TERMINAL = new Set([
  "completed", "voicemail", "no_answer", "busy", "failed", "timeout", "aborted",
]);

async function waitForCall(callId, timeoutMs = 600_000) {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const call = await fetch(`${API}/v2/calls/${callId}`, { headers: auth })
      .then((r) => r.json());
    if (TERMINAL.has(call.status)) return call;
    await new Promise((r) => setTimeout(r, 5000));
  }
  throw new Error(`timed out waiting for ${callId}`);
}