workflow

import { start, sleep } from 'workflow'; // workflows/emailWorkflow.ts export async function sendWelcomeEmailWorkflow(userId: string) { 'use workflow'; // Marks this as a durable workflow console.log(`[Workflow] Starting welcome email for user: ${userId}`); const emailContent = await fetchEmailContentStep(userId); await sleep('10s'); // Simulate waiting for a pre-configured delay or external event await sendEmailStep(userId, emailContent.subject, emailContent.body); console.log(`[Workflow] Welcome email process completed for user: ${userId}`); } async function fetchEmailContentStep(userId: string) { 'use step'; // Marks this as a durable, retriable step console.log(`[Step] Fetching email content for user: ${userId}`); // In a real application, this would fetch from a database or template service return { subject: `Welcome to Our Service, User ${userId}!`, body: `Dear User ${userId},\n\nThank you for joining!` }; } async function sendEmailStep(userId: string, subject: string, body: string) { 'use step'; // Marks this as a durable, retriable step console.log(`[Step] Sending email to user: ${userId} with subject: ${subject}`); // Simulate an external API call for sending emails await new Promise(resolve => setTimeout(resolve, 2000)); // Simulate async email API call console.log(`[Step] Email sent to ${userId}.`); // In a real application, this would call an email service API like: // await fetch('https://api.emailservice.com/send', { method: 'POST', body: JSON.stringify({ to: userId, subject, body }) }); } // api/trigger-email.ts (Example of how to trigger the workflow) // This could be an API route, a serverless function, or a CLI command async function triggerWorkflow(userId: string) { console.log(`[Client] Triggering workflow for user: ${userId}`); const run = await start(sendWelcomeEmailWorkflow, { input: userId }); console.log(`[Client] Workflow started with Run ID: ${run.id}, Status: ${run.status}`); return run; } // Example execution (e.g., in a main script or test) async function main() { const userToOnboard = 'user-123'; await triggerWorkflow(userToOnboard); } main().catch(console.error);