bun add @questpie/workflows

import { workflow } from "@questpie/workflows";
import z from "zod";

export default workflow({
	name: "order-fulfillment",
	schema: z.object({
		orderId: z.string(),
		customerId: z.string(),
	}),
	timeout: "24h",
	handler: async ({ input, step }) => {
		// Each step is automatically cached and replayed on restart
		const order = await step.run("validate-order", async () => {
			const o = await db.orders.findOne({ id: input.orderId });
			if (!o) throw new Error("Order not found");
			return o;
		});

		await step.run("charge-payment", async () => {
			await stripe.charges.create({
				amount: order.total,
				customer: input.customerId,
			});
		});

		await step.run("send-confirmation", async () => {
			await email.send({
				to: order.email,
				template: "order-confirmed",
				data: { orderId: order.id },
			});
		});

		// Wait up to 7 days for shipping label scan
		const shipment = await step.waitForEvent("shipment-scanned", {
			event: "shipment.label.scanned",
			match: { orderId: input.orderId },
			timeout: "7d",
		});

		await step.run("notify-shipped", async () => {
			await email.send({
				to: order.email,
				template: "order-shipped",
				data: { trackingNumber: shipment.trackingNumber },
			});
		});

		return { status: "fulfilled", orderId: order.id };
	},
});

import { runtimeConfig } from "questpie";
import { workflowsPlugin } from "@questpie/workflows/server";

export default runtimeConfig({
	plugins: [workflowsPlugin()],
	db: { url: process.env.DATABASE_URL! },
	app: { url: process.env.APP_URL! },
});

import { workflowsModule } from "@questpie/workflows/server";

export default [workflowsModule] as const;

import { route } from "questpie";
import z from "zod";

export default route()
	.post()
	.schema(z.object({ orderId: z.string(), customerId: z.string() }))
	.handler(async ({ input, workflows }) => {
		const result = await workflows.trigger("order-fulfillment", {
			orderId: input.orderId,
			customerId: input.customerId,
		});
		return { instanceId: result.instanceId };
	});