Create powerful notification workflows using code

• JavaScript

1const commentWorkflow = client.workflow('comment-on-post', async function({ step, subscriber }) => {
2	const inAppResponse = await step.inApp('in-app-step', async (inputs) => {
3		return {
4			body: renderReactComponent(inputs)
5		}
6	}, {
7		inputs: {
8				// ...JSON Schema or ZOD/Ajv/Class Validators definition
9		}
10	});
11
12	// Novu Worker Engine will manage the state and durability of each step in isolation
13	const { digestedEvents } = await step.digest('1 day');
14
15	await step.email('email-step', async () => {
16		return {
17			subject: 'E-mail Subject',
18			body: renderReactEmail(<ReactEmailComponet events={digestedEvents} />)
19		}
20  }, {
21		// Step-level inputs defined in code and controlled in the novu Cloud UI by a Non Technical Team member
22		inputs: {...JSON Schema},
23		providers: {
24			sendgrid: async (inputs) => {
25				// Echo runs as part of your application, so you have access to your database or resources
26				const email = await db.findUserEmail(subscriber.subscriberId);
27				
28				return {
29					to: email,
30					ipPoolName: 'custom-pool'
31				}
32			}
33		},
34		skip: () => {
35			// Write custom skip logic
36			return inAppResponse.seen;
37		}
38	});
39// Define your workflow trigger payload using json schema and custom validation;
40}, { 
41	dataSchema: {
42	// ...JSON Schema
43	}
44});
45
46
47// Trigger workflows like you usually do
48commentWorkflow.trigger({
49	to: { subscriberId: '12345' },
50	payload: { ...Custom Trigger Data }
51});