Create trigger.dev task to send policy email due to resend rate limit issue (#1633)

* fix(app): trigger 2 new-policy-email events per second at most due to resend rate limit

* fix(app): create trigger.dev task to send policy email due to resend rate limit issue

* fix(app): remove unused send-policy-email API

---------

Co-authored-by: chasprowebdev <[email protected]>
Co-authored-by: Mariano Fuentes <[email protected]>

Author: 3 people

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

@@ -1,6 +1,8 @@
 'use server';
 
+import { sendNewPolicyEmail } from '@/jobs/tasks/email/new-policy-email';
 import { db, PolicyStatus } from '@db';
+import { tasks } from '@trigger.dev/sdk';
 import { revalidatePath, revalidateTag } from 'next/cache';
 import { z } from 'zod';
 import { authActionClient } from '../safe-action';
@@ -92,34 +94,36 @@ export const acceptRequestedPolicyChangesAction = authActionClient
         return roles.includes('employee');
       });
 
-      // 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_PORTAL_URL ?? 'https://portal.trycomp.ai'}/${session.activeOrganizationId}`,
-          description: `The "${policy.name}" policy has been ${isNewPolicy ? 'created' : 'updated'}.`,
-        }));
+        .map((employee) => {
+          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';
+          }
+
+          return {
+            email: employee.user.email,
+            userName: employee.user.name || employee.user.email || 'Employee',
+            policyName: policy.name,
+            organizationId: session.activeOrganizationId || '',
+            organizationName: policy.organization.name,
+            notificationType,
+          };
+        });
 
       // 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
-      }
+      await Promise.all(
+        events.map((event) =>
+          tasks.trigger<typeof sendNewPolicyEmail>('send-new-policy-email', event),
+        ),
+      );
 
       // 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,49 @@
+import { sendPolicyNotificationEmail } from '@comp/email';
+import { logger, queue, task } from '@trigger.dev/sdk';
+
+// Queue with concurrency limit of 1 to ensure rate limiting (1 email per second max)
+const policyEmailQueue = queue({
+  name: 'policy-email-queue',
+  concurrencyLimit: 2,
+});
+
+interface PolicyEmailPayload {
+  email: string;
+  userName: string;
+  policyName: string;
+  organizationId: string;
+  organizationName: string;
+  notificationType: 'new' | 'updated' | 're-acceptance';
+}
+
+export const sendNewPolicyEmail = task({
+  id: 'send-new-policy-email',
+  queue: policyEmailQueue,
+  run: async (payload: PolicyEmailPayload) => {
+    logger.info('Sending new policy email', {
+      email: payload.email,
+      policyName: payload.policyName,
+    });
+
+    try {
+      await sendPolicyNotificationEmail(payload);
+
+      logger.info('Successfully sent policy email', {
+        email: payload.email,
+        policyName: payload.policyName,
+      });
+
+      return {
+        success: true,
+        email: payload.email,
+      };
+    } catch (error) {
+      logger.error('Failed to send policy email', {
+        email: payload.email,
+        error: error instanceof Error ? error.message : String(error),
+      });
+
+      throw error;
+    }
+  },
+});