Framework

1import { workflow, CronExpression } from '@novu/framework';
2import { z } from 'zod';
3import { render } from '@react-email/components';
4
5const weeklyComments = workflow('weekly-comments', async (event) => {
6  await event.step.inApp('inbox-notification', async () => ({
7    subject: `**${event.payload.userName}** commented in project`,
8    body: event.payload.comment,
9  }));
10
11  const digest = await event.step.digest('digest-comments', (controls) => ({
12    cron: controls.schedule
13  }), { controlSchema: z.object({ schedule: z.nativeEnum(CronExpression) }) });
14
15  await event.step.email('digest-email', async (controls) => ({
16    subject: controls.subject,
17    body: render(<WeeklyDigestEmail {...controls} events={digest.events} />)
18  }), {
19    skip: () => !digest.events.length,
20    controlSchema: z.object({
21      subject: z.string().default('Hi {{subscriber.firstName}} - Acme Comments'),
22      openAiModel: z.enum(['gpt-3.5-turbo', 'gpt-4o']).default('gpt-4o'),
23      aiPrompt: z.string().default('Produce a concise comment digest'),
24    })
25  });
26}, { payloadSchema: z.object({ userName: z.string(), comment: z.string() }) });
27
28await weeklyComments.trigger({
29  payload: { userName: 'John Doe', comment: 'Are you free to give me a call?' },
30  to: 'jane@acme.com'
31});