Handle escalations

// Call after verifying the webhook signature (see Handle revocations).
export async function onEvent(event: { type: string; data: { object: any } }) {
  if (event.type !== "check.resolved") return;
  const check = event.data.object;
  const job = await jobs.findByCheck(check.id);
  if (!job || job.state !== "pending") return; // duplicate or cancelled

  if (check.decision === "allow") {
    await jobs.start(job.id, { token: check.authorization.token, obligations: check.obligations });
  } else {
    await jobs.fail(job.id, check.reasons.map((r: { sentence: string }) => r.sentence));
  }
}

# Call after verifying the webhook signature (see Handle revocations).
def on_event(event):
    if event["type"] != "check.resolved":
        return
    check = event["data"]["object"]
    job = jobs.find_by_check(check["id"])
    if not job or job.state != "pending":
        return  # duplicate or cancelled

    if check["decision"] == "allow":
        jobs.start(job.id, token=check["authorization"]["token"], obligations=check["obligations"])
    else:
        jobs.fail(job.id, [r["sentence"] for r in check["reasons"]])

curl https://app.reflections.ai/v1/checks/chk_r6s9t0wxyhk5zba2q8v1m3n7p4 \
  -H "Authorization: Bearer rk_test_…" \
  -H "Reflections-Version: 2026-10-15"

async function waitForCheck(id: string) {
  let delay = 5_000; // never poll faster than every 5 seconds
  for (;;) {
    const check = await fetch(`https://app.reflections.ai/v1/checks/${id}`, {
      headers: {
        Authorization: `Bearer ${process.env.REFLECTIONS_KEY}`,
        "Reflections-Version": "2026-10-15",
      },
    }).then((r) => r.json());
    if (check.status !== "escalated") return check;
    await new Promise((resolve) => setTimeout(resolve, delay));
    delay = Math.min(delay * 2, 300_000);
  }
}

import os, time, requests

def wait_for_check(check_id):
    delay = 5  # never poll faster than every 5 seconds
    while True:
        check = requests.get(
            f"https://app.reflections.ai/v1/checks/{check_id}",
            headers={
                "Authorization": f"Bearer {os.environ['REFLECTIONS_KEY']}",
                "Reflections-Version": "2026-10-15",
            },
        ).json()
        if check["status"] != "escalated":
            return check
        time.sleep(delay)
        delay = min(delay * 2, 300)