Transcriptions

import os

import httpx

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

with open("call.wav", "rb") as f:
    r = httpx.post(
        f"{API}/v2/transcriptions",
        headers={**auth, "Idempotency-Key": "call-2026-10-02-0412"},
        files={"file": ("call.wav", f, "audio/wav")},
        data={
            "context": "A call to a university admissions desk about a course and its fees",
            "vocabulary": "Mira University, BBA, Aadhaar",
        },
        timeout=600,  # the answer comes after the whole file is uploaded
    )
job = r.json()
if r.status_code != 202:
    raise RuntimeError(f"{job['error']['code']}: {job['error']['message']}")
print(job["id"], job["status"])  # trn_01M3XRSFXW77RHEQ85979AJXAF queued

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

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

const form = new FormData();
form.append("file", new Blob([await readFile("call.wav")], { type: "audio/wav" }), "call.wav");
form.append("context", "A call to a university admissions desk about a course and its fees");
form.append("vocabulary", "Mira University, BBA, Aadhaar");

const res = await fetch(`${API}/v2/transcriptions`, {
  method: "POST",
  headers: { ...auth, "Idempotency-Key": "call-2026-10-02-0412" },
  body: form,
});
const job = await res.json();
if (res.status !== 202) throw new Error(`${job.error.code}: ${job.error.message}`);
console.log(job.id, job.status); // trn_01M3XRSFXW77RHEQ85979AJXAF queued

r = httpx.post(
    f"{API}/v2/transcriptions",
    headers={**auth, "Idempotency-Key": "call-2026-10-02-0413"},
    json={
        "url": presigned_url,  # from your storage, valid for a few minutes
        "context": "A call to a university admissions desk about a course and its fees",
        "vocabulary": ["Mira University", "BBA", "Aadhaar"],
        "language": "hi",
        "words": True,
    },
    timeout=600,  # we download the recording before answering
)
job = r.json()
if r.status_code != 202:
    raise RuntimeError(f"{job['error']['code']}: {job['error']['message']}")

const res = await fetch(`${API}/v2/transcriptions`, {
  method: "POST",
  headers: { ...auth, "Content-Type": "application/json", "Idempotency-Key": "call-2026-10-02-0413" },
  body: JSON.stringify({
    url: presignedUrl, // from your storage, valid for a few minutes
    context: "A call to a university admissions desk about a course and its fees",
    vocabulary: ["Mira University", "BBA", "Aadhaar"],
    language: "hi",
    words: true,
  }),
});
const job = await res.json();
if (res.status !== 202) throw new Error(`${job.error.code}: ${job.error.message}`);

import time

def wait_for_transcript(transcription_id: str, timeout_secs: int = 3600) -> dict:
    deadline = time.monotonic() + timeout_secs
    delay = 1.0
    while time.monotonic() < deadline:
        r = httpx.get(f"{API}/v2/transcriptions/{transcription_id}", headers=auth, timeout=30)
        if r.status_code in (429, 503):
            time.sleep(float(r.headers.get("Retry-After", "5")))
            continue
        job = r.raise_for_status().json()
        if job["status"] in ("completed", "failed"):
            return job
        time.sleep(delay)
        delay = min(delay * 1.5, 5)  # quick at first, then every 5 seconds
    raise TimeoutError(transcription_id)

job = wait_for_transcript("trn_01M3XRSFXW77RHEQ85979AJXAF")
if job["status"] == "failed":
    print(job["error"]["code"], job["error"]["message"])
else:
    for seg in job.get("segments", []):
        print(f"{seg['start']:7.2f}  {seg.get('speaker_id', '-')}  {seg['speaker']}: {seg['text']}")

const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

async function waitForTranscript(id, timeoutMs = 3_600_000) {
  const deadline = Date.now() + timeoutMs;
  let delay = 1000;
  while (Date.now() < deadline) {
    const res = await fetch(`${API}/v2/transcriptions/${id}`, { headers: auth });
    if (res.status === 429 || res.status === 503) {
      await sleep(Number(res.headers.get("retry-after") ?? 5) * 1000);
      continue;
    }
    const job = await res.json();
    if (!res.ok) throw new Error(`${job.error.code}: ${job.error.message}`);
    if (job.status === "completed" || job.status === "failed") return job;
    await sleep(delay);
    delay = Math.min(delay * 1.5, 5000); // quick at first, then every 5 seconds
  }
  throw new Error(`timed out waiting for ${id}`);
}

const job = await waitForTranscript("trn_01M3XRSFXW77RHEQ85979AJXAF");
if (job.status === "failed") console.log(job.error.code, job.error.message);
else for (const seg of job.segments ?? []) console.log(seg.start, seg.speaker_id, seg.speaker, seg.text);

def all_transcriptions(status: str | None = None):
    params = {"limit": 100, **({"status": status} if status else {})}
    while True:
        page = httpx.get(f"{API}/v2/transcriptions", headers=auth, params=params, timeout=30)
        page = page.raise_for_status().json()
        yield from page["data"]
        if not page["has_more"]:
            return
        params["cursor"] = page["next_cursor"]

spent = sum(job["cost"]["amount_inr"] for job in all_transcriptions("completed"))

async function* allTranscriptions(status) {
  const params = new URLSearchParams({ limit: "100", ...(status ? { status } : {}) });
  while (true) {
    const res = await fetch(`${API}/v2/transcriptions?${params}`, { headers: auth });
    const page = await res.json();
    if (!res.ok) throw new Error(`${page.error.code}: ${page.error.message}`);
    yield* page.data;
    if (!page.has_more) return;
    params.set("cursor", page.next_cursor);
  }
}

let spent = 0;
for await (const job of allTranscriptions("completed")) spent += job.cost.amount_inr;