implement email service with zod and nodemailer

package.json

@@ -21,6 +21,7 @@
     "@eslint/js": "^10.0.1",
     "@types/express": "^5.0.6",
     "@types/node": "^25.5.0",
+    "@types/nodemailer": "^8.0.0",
     "@types/swagger-jsdoc": "^6.0.4",
     "@types/swagger-ui-express": "^4.1.8",
     "eslint": "^10.0.3",
@@ -40,7 +41,9 @@
     "express": "^5.2.1",
     "http-status-codes": "^2.3.0",
     "mongoose": "^9.4.1",
+    "nodemailer": "^8.0.10",
     "swagger-jsdoc": "^6.2.8",
-    "swagger-ui-express": "^5.0.1"
+    "swagger-ui-express": "^5.0.1",
+    "zod": "^4.4.3"
   }
 }

src/app.ts

@@ -9,6 +9,7 @@ import { errorHandler } from './middleware/error.middleware';
 import swaggerUi from 'swagger-ui-express';
 import { swaggerSpec } from './utils/swagger';
 import metricsRoutes from './routes/metrics.routes';
+import emailRoutes from './routes/email.routes';
 
 const app: Application = express();
 
@@ -24,6 +25,7 @@ app.use('/api/login', loginRoutes);
 app.use('/api/appointment', appointmentRoutes);
 app.use('/api/tips', tipsRoutes);
 app.use('/api/metrics/', metricsRoutes);
+app.use('/api/email', emailRoutes);
 
 app.use(errorHandler);
 

src/constants/email/email.constants.ts

@@ -0,0 +1,56 @@
+export const EMAIL_TYPE = {
+  ATTENDANCE_UPDATE: 'ATTENDANCE_UPDATE',
+} as const;
+
+export const ATTENDANCE_STATUS = {
+  COMING: 'COMING',
+  NOT_COMING: 'NOT_COMING',
+} as const;
+
+export const EMAIL_SUBJECTS = {
+  ATTENDANCE_COMING: 'אישור הגעה לטיפול',
+  ATTENDANCE_NOT_COMING: 'ביטול הגעה לטיפול',
+} as const;
+
+export const EMAIL_TEXT = {
+  dearCaregiver: 'מטפל יקר',
+  patientNumber: 'מספר מטופל',
+  willCome: 'יגיע לטיפול',
+  willNotCome: 'לא יוכל להגיע לטיפול',
+  treatmentTime: 'בשעה',
+  cell: 'תא',
+  building: 'בניין',
+  rescheduleMessage:
+    'אנא פנה למטופל לקביעת מועד חדש ועדכן במערכת כי התפנה כיסא.',
+  automaticMessage: 'הודעה זו נשלחה אוטומטית ממערכת Sagol360.',
+  patientNameLabel: 'שם מטופל',
+  patientNumberLabel: 'מספר מטופל',
+  attendanceStatusLabel: 'סטטוס הגעה',
+  timeLabel: 'שעה',
+  cellLabel: 'תא',
+  buildingLabel: 'בניין',
+  comingStatusLabel: 'מגיע לטיפול',
+  notComingStatusLabel: 'לא מגיע לטיפול',
+} as const;
+
+export const EMAIL_ERRORS = {
+  invalidEmailData: 'Invalid email data',
+  unsupportedEmailType: 'Unsupported email type',
+  missingEmailEnvironmentVariables: 'Missing email environment variables',
+  emailWasNotSent: 'Email was not sent',
+} as const;
+
+export const EMAIL_SUCCESS_MESSAGES = {
+  emailSentSuccessfully: 'Email sent successfully',
+} as const;
+
+export const EMAIL_COLORS = {
+  comingHeader: '#1f7a4d',
+  notComingHeader: '#9f2f2f',
+  background: '#f4f6f8',
+  cardBackground: '#ffffff',
+  border: '#e0e0e0',
+  text: '#222222',
+  mutedText: '#777777',
+  tableLabelBackground: '#f8f9fa',
+} as const;

src/controllers/email/email.controller.ts

@@ -0,0 +1,26 @@
+import { Request, Response } from 'express';
+import { StatusCodes } from 'http-status-codes';
+import { sendEmail as serviceSendEmail } from '@/services/email/email.service';
+import { EMAIL_ERRORS, EMAIL_SUCCESS_MESSAGES } from '@/constants/email/email.constants';
+
+export const sendEmail = async (req: Request, res: Response) => {
+  try {
+    await serviceSendEmail(req.body);
+
+    res.status(StatusCodes.OK).json({
+      message: EMAIL_SUCCESS_MESSAGES.emailSentSuccessfully,
+    });
+  } catch (error) {
+    const errorMessage = error instanceof Error ? error.message : EMAIL_ERRORS.emailWasNotSent;
+
+    const statusCode =
+      errorMessage === EMAIL_ERRORS.invalidEmailData ||
+      errorMessage === EMAIL_ERRORS.unsupportedEmailType
+        ? StatusCodes.BAD_REQUEST
+        : StatusCodes.INTERNAL_SERVER_ERROR;
+
+    res.status(statusCode).json({
+      message: errorMessage,
+    });
+  }
+};

src/routes/email.routes.ts

@@ -0,0 +1,99 @@
+import { sendEmail } from '@/controllers/email/email.controller';
+import { Router } from 'express';
+
+const router = Router();
+
+/**
+ * @swagger
+ * /api/email:
+ *   post:
+ *     summary: Send an email
+ *     description: Sends an attendance update email according to the provided email type and payload.
+ *     tags:
+ *       - Email
+ *     requestBody:
+ *       required: true
+ *       content:
+ *         application/json:
+ *           schema:
+ *             type: object
+ *             required:
+ *               - emailType
+ *               - email
+ *               - payload
+ *             properties:
+ *               emailType:
+ *                 type: string
+ *                 enum:
+ *                   - ATTENDANCE_UPDATE
+ *                 example: ATTENDANCE_UPDATE
+ *               email:
+ *                 type: string
+ *                 format: email
+ *                 example: secretary@example.com
+ *               payload:
+ *                 type: object
+ *                 required:
+ *                   - patientName
+ *                   - patientNumber
+ *                   - attendanceStatus
+ *                   - time
+ *                   - cell
+ *                   - building
+ *                 properties:
+ *                   patientName:
+ *                     type: string
+ *                     example: ישראל ישראלי
+ *                   patientNumber:
+ *                     type: string
+ *                     example: "123456"
+ *                   attendanceStatus:
+ *                     type: string
+ *                     enum:
+ *                       - COMING
+ *                       - NOT_COMING
+ *                     example: NOT_COMING
+ *                   time:
+ *                     type: string
+ *                     example: "18:00"
+ *                   cell:
+ *                     type: string
+ *                     example: כתום
+ *                   building:
+ *                     type: string
+ *                     example: אריסון
+ *     responses:
+ *       200:
+ *         description: Email sent successfully
+ *         content:
+ *           application/json:
+ *             schema:
+ *               type: object
+ *               properties:
+ *                 message:
+ *                   type: string
+ *                   example: Email sent successfully
+ *       400:
+ *         description: Invalid email data or unsupported email type
+ *         content:
+ *           application/json:
+ *             schema:
+ *               type: object
+ *               properties:
+ *                 message:
+ *                   type: string
+ *                   example: Invalid email data
+ *       500:
+ *         description: Email was not sent or server email configuration is missing
+ *         content:
+ *           application/json:
+ *             schema:
+ *               type: object
+ *               properties:
+ *                 message:
+ *                   type: string
+ *                   example: Email was not sent
+ */
+router.post('/', sendEmail);
+
+export default router;

src/schemas/email/attendance-email.schema.ts

@@ -0,0 +1,18 @@
+import { ATTENDANCE_STATUS, EMAIL_TYPE } from '@/constants/email/email.constants';
+import { sendEmailSchema } from '@/services/email/email.service';
+import { z } from 'zod';
+
+export const attendanceEmailSchema = z.object({
+  emailType: z.literal(EMAIL_TYPE.ATTENDANCE_UPDATE),
+  email: z.string().trim().pipe(z.email()),
+  payload: z.object({
+    patientName: z.string().trim().min(1),
+    patientNumber: z.string().trim().min(1),
+    attendanceStatus: z.enum([ATTENDANCE_STATUS.COMING, ATTENDANCE_STATUS.NOT_COMING]),
+    time: z.string().trim().min(1),
+    cell: z.string().trim().min(1),
+    building: z.string().trim().min(1),
+  }),
+});
+
+export type SendEmailData = z.infer<typeof sendEmailSchema>;

src/schemas/email/email.service.helpers.ts

@@ -0,0 +1,13 @@
+import { buildAttendanceEmailContent, EmailContent } from '@/services/email/email.service.helpers';
+import { SendEmailData } from './attendance-email.schema';
+import { EMAIL_ERRORS, EMAIL_TYPE } from '@/constants/email/email.constants';
+
+export const buildEmailContent = (data: SendEmailData): EmailContent => {
+  switch (data.emailType) {
+    case EMAIL_TYPE.ATTENDANCE_UPDATE:
+      return buildAttendanceEmailContent(data.payload);
+
+    default:
+      throw new Error(EMAIL_ERRORS.unsupportedEmailType);
+  }
+};