const API_KEY = "REPLACE_ME";
const BASE_URL = "https://aisafegate.com";

const res = await fetch(BASE_URL + "/api/validate", {
  method: "POST",
  headers: {
    "content-type": "application/json",
    authorization: "Bearer " + API_KEY,
  },
  body: JSON.stringify({
    ai_output: aiOutput,
    context: { actionKind: "data.write", workflow: "Refunds" },
  }),
});

if (!res.ok) {
  // Fail-closed: do not execute.
  throw new Error("Validation failed");
}

const decision = await res.json();

if (decision.outcome === "PASS") {
  await executeAction();
} else if (decision.outcome === "WARN") {
  await waitForApproval(decision.decision_id);
  throw new Error("Approval required");
} else {
  // BLOCK
  throw new Error("Blocked by safety policy");
}

import requests

API_KEY = "REPLACE_ME"
BASE_URL = "https://aisafegate.com"

res = requests.post(
  BASE_URL + "/api/validate",
  headers={
    "content-type": "application/json",
    "authorization": "Bearer " + API_KEY,
  },
  json={
    "ai_output": ai_output,
    "context": {"actionKind": "data.write", "workflow": "Refunds"},
  },
  timeout=10,
)

if res.status_code != 200:
  # Fail-closed
  raise Exception("Validation failed")

decision = res.json()

if decision.get("outcome") == "PASS":
  execute_action()
elif decision.get("outcome") == "WARN":
  wait_for_approval(decision.get("decision_id"))
  raise Exception("Approval required")
else:
  raise Exception("Blocked by safety policy")

// Poll approval state
const API_KEY = "REPLACE_ME";
const BASE_URL = "https://aisafegate.com";

const poll = await fetch(
  BASE_URL + "/api/decisions/" + decisionId + "/approval",
  { headers: { authorization: "Bearer " + API_KEY, "x-approval-token": approvalToken } }
);

if (!poll.ok) throw new Error("Approval poll failed");
const { approved } = await poll.json();

if (approved) {
  await executeAction();
} else {
  // still waiting
}