feat(app): send email via Novu when the policy has been published

Author: chasprowebdev

apps/app/src/actions/policies/accept-requested-policy-changes.ts

@@ -1,7 +1,6 @@
 'use server';
 
 import { db, PolicyStatus } from '@db';
-import { sendPolicyNotificationEmail } from '@trycompai/email';
 import { revalidatePath, revalidateTag } from 'next/cache';
 import { z } from 'zod';
 import { authActionClient } from '../safe-action';
@@ -92,56 +91,34 @@ export const acceptRequestedPolicyChangesAction = authActionClient
         return roles.includes('employee');
       });
 
-      // Send notification emails to all employees
-      // Send emails in batches of 2 per second to respect rate limit
-      const BATCH_SIZE = 2;
-      const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));
-
-      const sendEmailsInBatches = async () => {
-        for (let i = 0; i < employeeMembers.length; i += BATCH_SIZE) {
-          const batch = employeeMembers.slice(i, i + BATCH_SIZE);
-
-          await Promise.all(
-            batch.map(async (employee) => {
-              if (!employee.user.email) return;
-
-              let notificationType: 'new' | 're-acceptance' | 'updated';
-              const wasAlreadySigned = policy.signedBy.includes(employee.id);
-              if (isNewPolicy) {
-                notificationType = 'new';
-              } else if (wasAlreadySigned) {
-                notificationType = 're-acceptance';
-              } else {
-                notificationType = 'updated';
-              }
-
-              try {
-                await sendPolicyNotificationEmail({
-                  email: employee.user.email,
-                  userName: employee.user.name || employee.user.email || 'Employee',
-                  policyName: policy.name,
-                  organizationName: policy.organization.name,
-                  organizationId: session.activeOrganizationId,
-                  notificationType,
-                });
-              } catch (emailError) {
-                console.error(`Failed to send email to ${employee.user.email}:`, emailError);
-                // Don't fail the whole operation if email fails
-              }
-            }),
-          );
-
-          // Only delay if there are more emails to send
-          if (i + BATCH_SIZE < employeeMembers.length) {
-            await delay(1000); // wait 1 second between batches
-          }
-        }
-      };
-
-      // Fire and forget, but log errors if any
-      sendEmailsInBatches().catch((error) => {
-        console.error('Some emails failed to send:', error);
-      });
+      // Call /api/send-policy-email to send emails to employees
+
+      // Prepare the events array for the API
+      const events = employeeMembers
+        .filter((employee) => employee.user.email)
+        .map((employee) => ({
+          subscriberId: `${employee.user.id}-${session.activeOrganizationId}`,
+          email: employee.user.email,
+          userName: employee.user.name || employee.user.email || 'Employee',
+          policyName: policy.name,
+          organizationName: policy.organization.name,
+          url: `${process.env.NEXT_PUBLIC_APP_URL ?? 'https://app.trycomp.ai'}/${session.activeOrganizationId}/policies/${policy.id}`,
+          description: `The "${policy.name}" policy has been ${isNewPolicy ? 'created' : 'updated'}.`,
+        }));
+
+      // Call the API route to send the emails
+      try {
+        await fetch(`${process.env.BETTER_AUTH_URL ?? ''}/api/send-policy-email`, {
+          method: 'POST',
+          headers: {
+            'Content-Type': 'application/json',
+          },
+          body: JSON.stringify(events),
+        });
+      } catch (error) {
+        console.error('Failed to call /api/send-policy-email:', error);
+        // Don't throw, just log
+      }
 
       // If a comment was provided, create a comment
       if (comment && comment.trim() !== '') {

apps/app/src/app/api/send-policy-email/route.ts

@@ -0,0 +1,50 @@
+import { NextResponse, type NextRequest } from 'next/server';
+import { Novu } from '@novu/api';
+
+export async function POST(request: NextRequest) {
+  let events;
+  try {
+    events = await request.json();
+  } catch (error) {
+    return NextResponse.json(
+      { success: false, error: 'Invalid JSON in request body' },
+      { status: 400 }
+    );
+  }
+
+  // You may want to validate required fields in the body here
+  // For now, we just pass the whole body to Novu
+
+  const novuApiKey = process.env.NOVU_API_KEY;
+  if (!novuApiKey) {
+    return NextResponse.json(
+      { success: false, error: 'Novu API key not configured' },
+      { status: 500 }
+    );
+  }
+
+  const novu = new Novu({ secretKey: novuApiKey });
+
+  try {
+    const result = await novu.triggerBulk({
+      events: events.map((event: any) => ({
+        workflowId: "new-policy-email",
+        to: {
+          subscriberId: event.subscriberId,
+          email: event.email,
+        },
+        payload: event,
+      })),
+    });
+
+    return NextResponse.json({ success: true, result });
+  } catch (error) {
+    return NextResponse.json(
+      {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to trigger notification',
+      },
+      { status: 500 }
+    );
+  }
+}