Get results after every call

curl -X PATCH "$MIRAI_API/v2/agents/agt_01M6AW976AVW3ZGE4EPSF2RYX0" \
  -H "Authorization: Bearer $MIRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "analysis": {
      "enabled": true,
      "prompt": "Summarise the call in two sentences: did the customer confirm the order, and what did they ask for?",
      "success_criteria": "The customer confirmed the order.",
      "output_schema": {
        "type": "object",
        "properties": {
          "order_confirmed": {
            "type": ["boolean", "null"],
            "description": "Did the customer confirm the order?"
          },
          "payment_method": {
            "type": ["string", "null"],
            "description": "How the customer will pay: cash on delivery or online"
          },
          "callback_time": {
            "type": ["string", "null"],
            "description": "The callback date and time requested by the caller."
          }
        },
        "required": ["order_confirmed", "payment_method"]
      }
    }
  }'

import os, httpx

API = os.environ["MIRAI_API"]
auth = {"Authorization": f"Bearer {os.environ['MIRAI_API_KEY']}"}

analysis = {
    "enabled": True,
    "prompt": "Summarise the call in two sentences: did the customer confirm the order, and what did they ask for?",
    "success_criteria": "The customer confirmed the order.",
    "output_schema": {
        "type": "object",
        "properties": {
            "order_confirmed": {"type": ["boolean", "null"], "description": "Did the customer confirm the order?"},
            "payment_method": {"type": ["string", "null"], "description": "How the customer will pay: cash on delivery or online"},
            "callback_time": {"type": ["string", "null"], "description": "The callback date and time requested by the caller."},
        },
        "required": ["order_confirmed", "payment_method"],
    },
}

agent = httpx.patch(
    f"{API}/v2/agents/agt_01M6AW976AVW3ZGE4EPSF2RYX0",
    headers=auth,
    json={"analysis": analysis},
    timeout=30,
).raise_for_status().json()
print(agent["revision"], agent["analysis"]["enabled"])

const API = process.env.MIRAI_API;
const auth = { Authorization: `Bearer ${process.env.MIRAI_API_KEY}` };

const analysis = {
  enabled: true,
  prompt: "Summarise the call in two sentences: did the customer confirm the order, and what did they ask for?",
  success_criteria: "The customer confirmed the order.",
  output_schema: {
    type: "object",
    properties: {
      order_confirmed: { type: ["boolean", "null"], description: "Did the customer confirm the order?" },
      payment_method: { type: ["string", "null"], description: "How the customer will pay: cash on delivery or online" },
      callback_time: { type: ["string", "null"], description: "The callback date and time requested by the caller." },
    },
    required: ["order_confirmed", "payment_method"],
  },
};

const res = await fetch(`${API}/v2/agents/agt_01M6AW976AVW3ZGE4EPSF2RYX0`, {
  method: "PATCH",
  headers: { ...auth, "Content-Type": "application/json" },
  body: JSON.stringify({ analysis }),
});
if (!res.ok) throw new Error(JSON.stringify(await res.json()));
const agent = await res.json();
console.log(agent.revision, agent.analysis.enabled);

import hashlib, hmac, json, os, time
from flask import Flask, request

app = Flask(__name__)
SECRET = os.environ["MIRAI_WEBHOOK_SECRET"]  # the whsec_… you copied
seen = set()  # use your database in production

def verified(raw: bytes, header: str) -> bool:
    parts = dict(p.split("=", 1) for p in header.split(",") if "=" in p)
    t = int(parts.get("t", "0"))
    if not t or abs(time.time() - t) > 300:
        return False
    expected = hmac.new(SECRET.encode(), f"{t}.".encode() + raw, hashlib.sha256).hexdigest()
    return hmac.compare_digest(expected, parts.get("v1", ""))

@app.post("/webhooks/mirai")
def mirai():
    raw = request.get_data()
    if not verified(raw, request.headers.get("X-Mirai-Signature", "")):
        return "bad signature", 401
    event = json.loads(raw)
    if event["id"] in seen:          # a retry of one we already handled
        return "", 200
    seen.add(event["id"])
    if event["type"] == "call.analysis.completed" and not event["test"]:
        result = event["data"]["analysis"]
        call = event["data"]["call"]
        print(call["id"], result["success"], result["summary"], result["data"])
        # save it to your CRM, sheet or database here
    return "", 200

import crypto from "node:crypto";
import express from "express";

const app = express();
const SECRET = process.env.MIRAI_WEBHOOK_SECRET; // the whsec_… you copied
const seen = new Set(); // use your database in production

function verified(raw, header = "") {
  const parts = Object.fromEntries(header.split(",").map((p) => p.split("=")));
  const t = Number(parts.t);
  if (!t || Math.abs(Date.now() / 1000 - t) > 300) return false;
  const expected = crypto.createHmac("sha256", SECRET).update(`${t}.`).update(raw).digest();
  const given = Buffer.from(parts.v1 ?? "", "hex");
  return given.length === expected.length && crypto.timingSafeEqual(given, expected);
}

app.post("/webhooks/mirai", express.raw({ type: "application/json" }), (req, res) => {
  if (!verified(req.body, req.get("X-Mirai-Signature"))) return res.sendStatus(401);
  const event = JSON.parse(req.body);
  if (seen.has(event.id)) return res.sendStatus(200); // a retry of one we already handled
  seen.add(event.id);
  if (event.type === "call.analysis.completed" && !event.test) {
    const { summary, success, data } = event.data.analysis;
    console.log(event.data.call.id, success, summary, data);
    // save it to your CRM, sheet or database here
  }
  res.sendStatus(200);
});

app.listen(3000);