OpenWorkflow

import { defineWorkflow } from "openworkflow";

export const processOrder = defineWorkflow(
  { name: "process-order" },
  async ({ input, step }) => {
    // if the server crashes after this step, the card is NOT charged again
    await step.run({ name: "charge-card" }, async () => {
      await payments.charge(input.orderId);
    });

    await step.run({ name: "send-confirmation" }, async () => {
      await emails.send({ to: input.email, subject: "Order confirmed!" });
    });
  },
);