import { serve } from "@upstash/workflow/nextjs"; export const { POST } = serve<string>(async (context) => { const { orderId, processingResult } = context.requestPayload; await context.run("process-order", async () => { // ... }) const { notifyResponse } = await context.notify( "notify-processing-complete", `order-${orderId}`, { orderId, status: "completed", result: processingResult, completedAt: new Date().toISOString() } ); });
import { Client } from "@upstash/workflow"; const client = new Client({ token: "<WORKFLOW_TOKEN>" }); await client.notify({ eventId: "order-completed-123", eventData: { orderId: "123", status: "completed", deliveryTime: "2 days", trackingNumber: "TRK123456" } });
Was this page helpful?