Build on the Work Graph OS.

npm install @amqur/sdk
# or
pip install amqur
# or
<dependency>
  <groupId>com.amqur</groupId>
  <artifactId>amqur-sdk</artifactId>
</dependency>

import { WorkGraph } from "@amqur/sdk";

const leadToClose = new WorkGraph({
  name: "lead-to-close",
  version: "1.0.0",

  state: {
    leadId: { type: "string" },
    qualified: { type: "boolean" },
    dealValue: { type: "number" },
  },

  nodes: [
    {
      id: "qualify",
      type: "action",
      tool: "crm.qualifyLead",
      output: { qualified: "boolean", score: "number" },
    },
    {
      id: "inventory",
      type: "tool",
      tool: "dms.searchInventory",
      when: "state.qualified === true",
    },
    {
      id: "manager_review",
      type: "gate",
      policy: "deals_over_45k",
      when: "state.dealValue > 45000",
    },
  ],

  edges: [
    { from: "qualify", to: "inventory", when: "qualified" },
    { from: "inventory", to: "manager_review" },
  ],

  policy: {
    gates: ["deals_over_45k"],
    tools: ["crm", "dms"],
    observability: { sink: "amqur-events" },
  },
});

// Compile — produces immutable version hash
const compiled = await leadToClose.compile();
// => { hash: "7f3a2b1c", policy: {...}, schema: {...} }

// Run — streams events via SSE
const run = await compiled.run({
  input: { leadId: "lead-88421" },
  environment: "sandbox", // or "production"
});

// Subscribe to events
run.on("state_change", (event) => {
  console.log(event.nodeId, event.data);
});

run.on("gate_blocked", (event) => {
  console.log("Approval required:", event.data.policy);
});

// Or stream all events
for await (const event of run.events()) {
  console.log(event.type, event.nodeId, event.timestamp);
}