SDKs

import os, requests

GATEWAY = "http://127.0.0.1:9470"
HEADERS = {"Authorization": f"Bearer {os.environ['WARDEN_API_KEY']}"}

def execute(statement, params=None, *, reason, idempotency_key=None, mode=None):
    body = {"statement": statement, "params": params or [], "reason": reason}
    if idempotency_key:
        body["idempotency_key"] = idempotency_key
    if mode:
        body["mode"] = mode
    r = requests.post(f"{GATEWAY}/api/v1/gateway/execute", json=body, headers=HEADERS)
    return r.json()

result = execute(
    "UPDATE orders SET status = $1 WHERE id = $2",
    ["refunded", order_id],
    reason="Customer requested refund",
    idempotency_key=f"{task_id}:{step}:{order_id}",
)

match result["status"]:
    case "committed":
        approver = (result.get("approval") or {}).get("by")
        done(approved_by=approver)          # say a human approved it, if one did
    case "rejected":  escalate(result["message"])   # a person said no
    case "expired":   retry_later()                 # nobody answered; nothing ran
    case "stale":     refresh_and_repropose()       # data moved under us
    case "denied":    give_up(result["code"])       # policy forbids it
    case "proposed":  poll(result["operation_id"])  # async: a human has it

const GATEWAY = "http://127.0.0.1:9470";
const headers = {
  Authorization: `Bearer ${process.env.WARDEN_API_KEY}`,
  "Content-Type": "application/json",
};

async function execute(body: Record<string, unknown>) {
  const res = await fetch(`${GATEWAY}/api/v1/gateway/execute`, {
    method: "POST",
    headers,
    body: JSON.stringify(body),
  });
  return res.json();
}

const result = await execute({
  statement: "UPDATE orders SET status = $1 WHERE id = $2",
  params: ["refunded", orderId],
  reason: "Customer requested refund",
  idempotency_key: `${taskId}:${step}:${orderId}`,
});

switch (result.status) {
  case "committed": return done(result.approval?.by);
  case "rejected":  return escalate(result.message);
  case "expired":   return retryLater();
  case "stale":     return refreshAndRepropose();
  case "denied":    return giveUp(result.code);
  case "proposed":  return poll(result.operation_id);
}