import { createWorkflow } from "@stepflowjs/core";

export const welcomeWorkflow = createWorkflow(
  {
    id: "welcome-user",
    retries: 3,
  },
  async ({ event, step, sleep }) => {
    const { userId, email } = event.data;

    // Step 1: Send welcome email
    await step.run("send-welcome", async () => {
      await sendEmail(email, "Welcome!");
    });

    // Wait 3 days
    await sleep("wait-for-followup", "3d");

    // Step 2: Send follow-up
    await step.run("send-followup", async () => {
      await sendEmail(email, "How are you finding things?");
    });

    return { status: "completed", userId };
  },
);

import { Stepflow } from "@stepflowjs/core";
import { MemoryStorageAdapter } from "@stepflowjs/storage-memory";

const stepflow = new Stepflow({
  storage: new MemoryStorageAdapter(),
  logging: true,
});

stepflow.register(welcomeWorkflow);
await stepflow.start();

const { runId, publicAccessToken } = await stepflow.trigger("welcome-user", {
  userId: "user_123",
  email: "user@example.com",
});

console.log("Workflow started:", runId);