Sub-workspaces API: one workspace per brand

import os, httpx

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

def brand(external_id: str) -> dict:
    return {**auth, "Mirai-Workspace": external_id}

call = httpx.post(
    f"{API}/v2/calls",
    headers=brand("acme-skincare"),
    json={
        "to": "+919876543210",
        "agent_id": "agt_01K7Q9F3K7M2N5P9R4T6V8W0XZ",
        "webhook_url": "https://example.com/mirai/webhook",
    },
    timeout=30,
).raise_for_status().json()
print(call["id"], call["status"])  # call_01K7Q9B4M8N3P6R2S5T7V9W1YA queued

const API = "https://prod.voice.miraiminds.co";
const auth = { Authorization: `Bearer ${process.env.MIRAI_API_KEY}` };
const brand = (externalId) => ({ ...auth, "Mirai-Workspace": externalId });

const call = await fetch(`${API}/v2/calls`, {
  method: "POST",
  headers: { ...brand("acme-skincare"), "Content-Type": "application/json" },
  body: JSON.stringify({
    to: "+919876543210",
    agent_id: "agt_01K7Q9F3K7M2N5P9R4T6V8W0XZ",
    webhook_url: "https://example.com/mirai/webhook",
  }),
}).then((r) => r.json());
console.log(call.id, call.status); // call_01K7Q9B4M8N3P6R2S5T7V9W1YA queued

def ensure_brand(external_id: str, name: str) -> dict:
    """Create the brand's sub-workspace, or return it if a retry already did."""
    r = httpx.post(
        f"{API}/v2/workspaces",
        headers=auth,
        json={"name": name, "external_id": external_id, "kind": "shopify"},
        timeout=30,
    )
    if r.status_code == 201:
        return r.json()
    body = r.json()
    err = body["error"]
    if err["code"] == "workspace_exists" and body["workspace"]["external_id"] == external_id:
        return body["workspace"]
    raise RuntimeError(f'{err["code"]}: {err["message"]}')

ws = ensure_brand("acme-skincare", "Acme Skincare")
print(ws["id"])  # ws_5e0c7a1f9b3d2e6a4c8f0b17

// Create the brand's sub-workspace, or return it if a retry already did.
async function ensureBrand(externalId, name) {
  const r = await fetch(`${API}/v2/workspaces`, {
    method: "POST",
    headers: { ...auth, "Content-Type": "application/json" },
    body: JSON.stringify({ name, external_id: externalId, kind: "shopify" }),
  });
  const body = await r.json();
  if (r.status === 201) return body;
  const err = body.error;
  if (err.code === "workspace_exists" && body.workspace.external_id === externalId) {
    return body.workspace;
  }
  throw new Error(`${err.code}: ${err.message}`);
}

const ws = await ensureBrand("acme-skincare", "Acme Skincare");
console.log(ws.id); // ws_5e0c7a1f9b3d2e6a4c8f0b17

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

for ws in active_brands():
    s = httpx.get(
        f"{API}/v2/calls/summary",
        headers={**auth, "Mirai-Workspace": ws["id"]},
        params={"from": "2026-11-01T00:00:00Z"},
        timeout=30,
    ).raise_for_status().json()
    print(f'{ws["name"]}: {s["total"]} calls, {s["duration_secs"] // 60} min')

async function* activeBrands() {
  let cursor = null;
  for (;;) {
    const qs = new URLSearchParams({ status: "active", limit: "100", ...(cursor ? { cursor } : {}) });
    const page = await fetch(`${API}/v2/workspaces?${qs}`, { headers: auth }).then((r) => r.json());
    yield* page.data;
    if (!page.has_more) return;
    cursor = page.next_cursor;
  }
}

for await (const ws of activeBrands()) {
  const qs = new URLSearchParams({ from: "2026-11-01T00:00:00Z" });
  const s = await fetch(`${API}/v2/calls/summary?${qs}`, {
    headers: { ...auth, "Mirai-Workspace": ws.id },
  }).then((r) => r.json());
  console.log(`${ws.name}: ${s.total} calls, ${Math.floor(s.duration_secs / 60)} min`);
}