Examples

async def run():
    key = x_secrets.get("OPENROUTER_API_KEY", "")
    count = int(float(x_contact["attributes"].get("other_messages_count") or 0))
    if not key:
        return {"status": "error", "message": "Add OPENROUTER_API_KEY in Settings > Secrets"}
    state = {
        "latest_message": x_message["text"],
        "recent_chat": [{"from": m["role"], "text": m["text"]} for m in x_history[-9:-1]],
    }
    questions = {
        "outside_flow": {"type": "noul", "instructions": (
            "Does `latest_message` ask a question that needs an answer, rather than just moving "
            "the sales chat forward (a greeting, yes, no, ok, a tapped button, saying it is paid)?")},
    }
    async with httpx.AsyncClient(timeout=8) as client:
        resp = await client.post(
            "https://openrouter.ai/api/alpha/decisions",
            json={"model": "typesafe/jev-1.13", "state": state, "questions": questions},
            headers={"Authorization": f"Bearer {key}"},
        )
    if resp.status_code >= 400:
        return {"status": "error", "message": f"Jev HTTP {resp.status_code}"}
    p = float(resp.json()["answers"]["outside_flow"]["noul"])
    if p < 0.5:
        return {"action": "agent", "count": count}
    count += 1
    await update_contact_custom({"other_messages_count": count})
    return {"action": "link" if count > 5 else "agent", "count": count}