Durable Workflows

// workflows/onboarding.ts
import { workflow } from "@pylonsync/functions";

export default workflow("onboarding", async (wf, ctx) => {
  // A completed step returns its recorded output during replay.
  const user = await wf.step("load-user", () =>
    ctx.runQuery("getUser", { id: wf.input.userId }),
  );

  await wf.step("send-welcome", () =>
    ctx.email.send({
      to: user.email,
      subject: "Welcome!",
      text: "Glad you're here.",
    }),
  );

  // Pauses the workflow. No machine time is spent waiting.
  await wf.sleep("24h");

  // Pauses until POST /api/workflows/<id>/event delivers this event.
  const confirmation = await wf.waitForEvent("email_confirmed");

  return { done: true, confirmation };
});

// functions/onSignup.ts
export default mutation({
  async handler(ctx, args) {
    const user = await ctx.db.insert("User", args);
    const { id } = await ctx.workflows.start("onboarding", {
      userId: user.id,
    });
    return { userId: user.id, onboardingWorkflow: id };
  },
});

await ctx.workflows.sendEvent(workflowId, "email_confirmed", { ok: true });

export default workflow("sync-crm", handler, { maxRetries: 5 });