npm install alchemy

import alchemy from "alchemy";
import { Worker, Workflow } from "alchemy/cloudflare";

const app = await alchemy("cloudflare-worker");

export const worker = await Worker("worker", {
  name: `${app.name}-${app.stage}-worker`,
  entrypoint: "./src/worker.ts",
  bindings: {
    WORKFLOW: Workflow("OFACWorkflow", {
      className: "OFACWorkflow",
      workflowName: "ofac-workflow",
    }),
  },
  url: true,
});

await app.finalize();

import { WorkflowEntrypoint, WorkflowStep } from "cloudflare:workers";

export class OFACWorkflow extends WorkflowEntrypoint {
  async run(event: unknown, step: WorkflowStep) {
    // Step 1: Validate input
    const validated = await step.do("validate", async () => {
      console.log("Validating OFAC data...");
      return { valid: true };
    });

    if (!validated.valid) {
      return { status: "failed", reason: "validation" };
    }

    // Step 2: Check OFAC database
    const result = await step.do("check-ofac", async () => {
      console.log("Checking OFAC database...");
      // Simulate OFAC check
      await step.sleep("wait-for-response", 1000);
      return { match: false };
    });

    // Step 3: Process result
    const processed = await step.do("process", async () => {
      if (result.match) {
        return { status: "blocked", reason: "OFAC match" };
      }
      return { status: "approved" };
    });

    return processed;
  }
}

import { env } from "cloudflare:workers";

export default {
  async fetch(request: Request) {
    // Start a new workflow instance
    const instance = await env.WORKFLOW.create({
      id: crypto.randomUUID(),
    });

    // Get workflow status
    const status = await instance.status();

    return new Response(
      JSON.stringify({
        instanceId: instance.id,
        status: status,
      }),
      {
        headers: { "Content-Type": "application/json" },
      }
    );
  },
};

npm exec tsx alchemy.run.ts