refactor(api): streamline API routes and workflows

app/api/messages/route.ts

@@ -1,15 +1,11 @@
 import { SUBSCRIBER_ID } from '@/constants/subscriber';
-import { Novu } from '@novu/node';
-
-const novu = new Novu(process.env.NOVU_API_KEY as string);
+import { aiDigest } from '@/lib/novu/workflows';
 
 export async function POST(request: Request) {
   const res = await request.json();
 
-  await novu.trigger('ai-digest', {
-    to: {
-      subscriberId: SUBSCRIBER_ID,
-    },
+  await aiDigest.trigger({
+    to: [SUBSCRIBER_ID],
     payload: {
       message: res.message,
       digestDuration: res.digestDuration,

app/api/notifications/route.ts

@@ -1,3 +1,4 @@
+import { notificationSchemaJson } from '@/lib/novu/workflows';
 import { OpenAI } from 'openai';
 
 const openai = new OpenAI({
@@ -22,22 +23,7 @@ export async function GET(request: Request) {
       {
         name: "create_sample_notification",
         description: "A sample notification for a user.",
-        parameters: {
-          type: "object",
-          properties: {
-            message: {
-              type: "string",
-              description: "The message to be sent."
-            },
-            category: {
-              type: "string",
-              enum: ["Urgent", "Important", "Normal", "Low"],
-              description: "The priority of the message."
-            }
-          },
-          required: ["message", "category"],
-          additionalProperties: false,
-        }
+        parameters: notificationSchemaJson
       }
     ],
   });

app/api/novu/route.ts

@@ -0,0 +1,4 @@
+import { serve } from "@novu/framework/next";
+import { aiDigest } from "@/lib/novu/workflows";
+
+export const { GET, POST, OPTIONS } = serve({ workflows: [aiDigest] });