move functionality to service

Author: jolinhuang224

src/app/api/assessments/send-invitation/route.ts

@@ -3,9 +3,7 @@ import { z } from 'zod';
 import { handleError } from '@/lib/utils/errors.utils';
 import { getSession } from '@/lib/utils/auth.utils';
 import { assertRecruiterOrAbove } from '@/lib/utils/permissions.utils';
-import { prisma } from '@/lib/prisma';
-import sesConnector from '@/lib/connectors/ses.connector';
-import { generateAssessmentInvitationHTML } from '@/lib/templates/assessment-invitation-email';
+import { sendAssessmentInvitationEmail } from '@/lib/services/assessment-invitation-email.service';
 
 const sendAssessmentInvitationSchema = z.object({
     candidateId: z.string().cuid(),
@@ -19,82 +17,14 @@ export async function POST(request: NextRequest) {
         const body = await request.json();
         const { candidateId } = sendAssessmentInvitationSchema.parse(body);
 
-        const candidate = await prisma.candidate.findUnique({
-            where: { id: candidateId },
-            include: {
-                applications: {
-                    include: {
-                        assessment: true,
-                        position: true,
-                    },
-                },
-                organization: true,
-            },
-        });
-
-        //validation
-        if (!candidate) {
-            return Response.json({ error: 'Candidate not found' }, { status: 404 });
-        }
-
-        if (candidate.orgId !== session.activeOrganizationId) {
-            return Response.json({ error: 'Unauthorized' }, { status: 403 });
-        }
-
-        const applicationWithAssessment = candidate.applications.find(
-            (app) => app.assessment !== null
+        const result = await sendAssessmentInvitationEmail(
+            candidateId,
+            session.activeOrganizationId
         );
 
-        if (!applicationWithAssessment?.assessment) {
-            return Response.json(
-                { error: 'Candidate does not have an assigned assessment' },
-                { status: 400 }
-            );
-        }
-
-        const assessment = applicationWithAssessment.assessment;
-        const position = applicationWithAssessment.position;
-        const organization = candidate.organization;
-
-        //create url
-        const baseUrl =
-            process.env.BETTER_AUTH_URL ??
-            process.env.NEXT_PUBLIC_APP_URL ??
-            'http://localhost:3000';
-        const assessmentUrl = `${baseUrl}/assessment/${assessment.uniqueLink}`;
-        const logoUrl = `${baseUrl}/Sarge_logo.svg`;
-
-        //email html
-        const htmlContent = generateAssessmentInvitationHTML({
-            candidateName: candidate.name,
-            positionTitle: position.title,
-            organizationName: organization.name,
-            assessmentId: assessment.id,
-            assessmentUrl,
-            logoUrl,
-        });
-
-        //send email
-        const emailSent = await sesConnector.sendEmail(
-            candidate.email,
-            `${organization.name} Software Engineering Role: Online Assessment Invitation`,
-            `Hello ${candidate.name}, you have been invited to complete an online assessment for the ${position.title} position at ${organization.name}. Visit ${assessmentUrl} to begin.`,
-            { html: htmlContent }
-        );
-
-        if (!emailSent) {
-            return Response.json({ error: 'Failed to send invitation email' }, { status: 500 });
-        }
-
         return Response.json(
             {
-                data: {
-                    success: true,
-                    message: `Assessment invitation sent to ${candidate.email}`,
-                    candidateName: candidate.name,
-                    positionTitle: position.title,
-                    assessmentId: assessment.id,
-                },
+                data: result,
             },
             { status: 200 }
         );

src/lib/services/assessment-invitation-email.service.ts

@@ -0,0 +1,86 @@
+import { prisma } from '@/lib/prisma';
+import sesConnector from '@/lib/connectors/ses.connector';
+import { generateAssessmentInvitationHTML } from '@/lib/templates/assessment-invitation-email';
+
+interface SendAssessmentInvitationResult {
+    success: boolean;
+    message: string;
+    candidateName: string;
+    positionTitle: string;
+    assessmentId: string;
+}
+
+export async function sendAssessmentInvitationEmail(
+    candidateId: string,
+    activeOrganizationId: string
+): Promise<SendAssessmentInvitationResult> {
+    const candidate = await prisma.candidate.findUnique({
+        where: { id: candidateId },
+        include: {
+            applications: {
+                include: {
+                    assessment: true,
+                    position: true,
+                },
+            },
+            organization: true,
+        },
+    });
+
+    if (!candidate) {
+        throw new Error('Candidate not found');
+    }
+
+    if (candidate.orgId !== activeOrganizationId) {
+        throw new Error('Unauthorized');
+    }
+
+    const applicationWithAssessment = candidate.applications.find((app) => app.assessment !== null);
+
+    if (!applicationWithAssessment?.assessment) {
+        throw new Error('Candidate does not have an assigned assessment');
+    }
+
+    const assessment = applicationWithAssessment.assessment;
+    const position = applicationWithAssessment.position;
+    const organization = candidate.organization;
+
+    const baseUrl =
+        process.env.BETTER_AUTH_URL ?? process.env.NEXT_PUBLIC_APP_URL ?? 'http://localhost:3000';
+    const assessmentUrl = `${baseUrl}/assessment/${assessment.uniqueLink}`;
+    const logoUrl = `${baseUrl}/Sarge_logo.svg`;
+
+    //placeholder duration and expiration
+    const durationMinutes = 120;
+    const expirationDate = 'March 16, 2026 11:59PM EST';
+    const htmlContent = generateAssessmentInvitationHTML({
+        candidateName: candidate.name,
+        positionTitle: position.title,
+        organizationName: organization.name,
+        assessmentId: assessment.id,
+        assessmentUrl,
+        logoUrl,
+        durationMinutes,
+        expirationDate,
+    });
+
+    // Send email
+    const emailSent = await sesConnector.sendEmail(
+        candidate.email,
+        `${organization.name} Software Engineering Role: Online Assessment Invitation`,
+        `Hello ${candidate.name}, you have been invited to complete an online assessment for the ${position.title} position at ${organization.name}. Visit ${assessmentUrl} to begin.`,
+        { html: htmlContent }
+    );
+
+    if (!emailSent) {
+        throw new Error('Failed to send invitation email');
+    }
+
+    return {
+        success: true,
+        message: `Assessment invitation sent to ${candidate.email}`,
+        candidateName: candidate.name,
+        positionTitle: position.title,
+        assessmentId: assessment.id,
+    };
+}

src/lib/templates/assessment-invitation-email.ts

@@ -5,6 +5,8 @@ export interface AssessmentInvitationEmailData {
     assessmentId: string;
     assessmentUrl: string;
     logoUrl: string;
+    durationMinutes: number;
+    expirationDate: string;
 }
 
 export function generateAssessmentInvitationHTML(data: AssessmentInvitationEmailData): string {
@@ -49,10 +51,10 @@ export function generateAssessmentInvitationHTML(data: AssessmentInvitationEmail
 
                 <div style="text-align: center; margin: 0 0 32px 0; padding: 24px 0;">
                     <div style="margin-bottom: 16px; font-size: 14px; color: #333333;">
-                        <strong>Duration:</strong> 120 minutes
+                        <strong>Duration:</strong> ${data.durationMinutes} minutes
                     </div>
                     <div style="font-size: 14px; color: #333333;">
-                        <strong>Test Expiration Date:</strong> March 16, 2026 11:59PM EST
+                        <strong>Test Expiration Date:</strong> ${data.expirationDate}
                     </div>
                 </div>