Code-First Notifications Workflow SDK

Novu Framework allows you to write notification workflows in your codebase. Workflows are functions that execute business logic and use your preferred libraries for email, SMS, and chat generation. You can use Novu Framework with React.Email, MJML, or any other template generator.

Learn more about the Code-First Notifications Workflow SDK in our docs.

Installation

npm install @novu/framework

Quickstart

import { workflow, CronExpression, } from "@novu/framework";
import { serve } from "@novu/framework/next";
import { z } from 'zod';

// Define your notification workflow
const weeklyComments = workflow(
  'comment-on-post',
  async ({ payload, step }) => {
    const inAppResponse = await step.inApp('new-comment', async () => ({
      body: `You have a new comment on your post ${payload.comment}`,
    }));

    const weeklyDigest = await step.digest('weekly-digest', () => ({
      cron: CronExpression.EVERY_WEEK,
    }));

    await step.email('weekly-comments', async (controls) => ({
      subject: `${controls.prefix} - Weekly post comments (${weeklyDigest.events.length})`,
      body: `Weekly digest: ${weeklyDigest.events.map(({ payload }) => payload.comment).join(', ')}`,
    }), {
      // Skip the notification if the user has already seen it
      skip: () => inAppResponse.seen,
      // Non-technical stakeholders can modify strongly-validated copy in Novu Cloud
      inputSchema: z.object({ prefix: z.string().describe('The prefix of the subject.').default('Hi!') }),
    });
  },
  { payloadSchema: z.object({ comment: z.string().describe('The comment on the post.') }) }
);

// Use your favorite framework to serve your workflows
const { GET, POST, OPTIONS } = serve({ workflows: [weeklyComments] });

// Trigger your notification workflow
weeklyComments.trigger({ postId: '123', to: 'user:123' });