Do you know what your
AI agent is doing right now?

# Works with LangChain, CrewAI, AutoGen, or any agent
import requests

headers = {"Authorization": "Bearer dsg_live_<your-api-key>"}
result = requests.post("https://your-domain/api/execute", headers=headers, json={
    "workspace_id": "ws-001",
    "provider": "openai",
    "agent_id": "agent-finance",
    "action": "send_payment"
}).json()

# ok = transport success. Check 'decision' for the gate outcome.
# BLOCK or REVIEW also return ok=True — only execute on explicit ALLOW.
if result.get("ok") and result.get("decision") == "ALLOW":
    execute_action()       # gate returned ALLOW
elif result.get("decision") == "REVIEW":
    route_to_human()       # gate requires human oversight before proceeding
else:
    log_blocked(result)    # gate returned BLOCK — do NOT execute

import requests

HEADERS = {"Authorization": "Bearer dsg_live_<your-api-key>"}

def gate(workspace_id: str, agent_id: str, action: str) -> bool:
    r = requests.post("/api/execute", headers=HEADERS, json={
        "workspace_id": workspace_id,
        "provider": "openai",
        "agent_id": agent_id,
        "action": action,
    }).json()
    # Check 'decision' == 'ALLOW' — BLOCK/REVIEW also return ok=True
    return r.get("ok", False) and r.get("decision") == "ALLOW"

# Before every tool call:
if gate(ws_id, agent_id, tool_call.name):
    tool_call.execute()
# else: gate returned BLOCK or REVIEW — do NOT proceed

async function gate(workspaceId: string, agentId: string, action: string) {
  const r = await fetch("/api/execute", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      "Authorization": `Bearer ${process.env.DSG_API_KEY}`,
    },
    body: JSON.stringify({ workspace_id: workspaceId, provider: "openai", agent_id: agentId, action }),
  });
  const data = await r.json();
  // Check 'decision' — BLOCK/REVIEW return ok:true but decision !== 'ALLOW'
  return data.ok === true && data.decision === 'ALLOW';
}

// Before every agent action — only execute if gate explicitly allows:
if (await gate(workspaceId, agentId, action)) execute();