Events

import { createClient } from "@duraton/sdk/client";

const client = createClient({ url, apiKey: "dtn_sk_..." });

await client.events.send({ name: "order/paid", data: { orderId: "o_1" } });
await client.events.sendMany([
  { name: "order/paid", data: { orderId: "o_2" } },
  { name: "order/paid", data: { orderId: "o_3" } },
]);

const { data } = await client.events.list({ name: "order/paid", source: "api" });
const event = await client.events.get(data[0].id);

defineWorkflow({
  name: "fulfil-order",
  triggers: [{ event: "order/paid", if: 'event.data.currency == "EUR"' }],
  handler: async ({ event, step }) => {
    // ...
  },
});

const shipped = await step.waitForEvent("wait-for-shipping", {
  event: "order/shipped",
  timeout: "7d",
  if: `event.data.orderId == "${event.data.orderId}"`,
});