SES first iteration (no templates yet)

package.json

@@ -43,6 +43,7 @@
     },
     "dependencies": {
         "@aws-sdk/client-s3": "^3.496.0",
+        "@aws-sdk/client-ses": "^3.609.0",
         "@aws-sdk/s3-presigned-post": "^3.499.0",
         "@aws-sdk/s3-request-presigner": "^3.496.0",
         "@paralleldrive/cuid2": "^2.2.2",

src/app.ts

@@ -3,6 +3,7 @@ import { StatusCodes } from "http-status-codes";
 import { Config } from "./config";
 import { rateLimiter } from "./middleware/rateLimiter";
 import { isTest } from "./utilities";
+import AWS from "aws-sdk";
 
 import databaseMiddleware from "./middleware/database-middleware";
 import customCors from "./middleware/cors-middleware";
@@ -16,10 +17,17 @@ import eventsRouter from "./services/events/events-router";
 import notificationsRouter from "./services/notifications/notifications-router";
 import registrationRouter from "./services/registration/registration-router";
 import s3Router from "./services/s3/s3-router";
+import sesRouter from "./services/ses/ses-router";
 import statsRouter from "./services/stats/stats-router";
 import sponsorRouter from "./services/sponsor/sponsor-router";
 import subscriptionRouter from "./services/subscription/subscription-router";
 
+AWS.config.update({
+    region: Config.S3_REGION,
+    accessKeyId: Config.S3_ACCESS_KEY,
+    secretAccessKey: Config.S3_SECRET_KEY,
+});
+
 const app = express();
 
 // to prevent server-side caching/returning status code 200
@@ -42,6 +50,7 @@ app.use("/events", databaseMiddleware, eventsRouter);
 app.use("/notifications", databaseMiddleware, notificationsRouter);
 app.use("/registration", databaseMiddleware, registrationRouter);
 app.use("/s3", databaseMiddleware, s3Router);
+app.use("/ses", sesRouter);
 app.use("/stats", databaseMiddleware, statsRouter);
 app.use("/sponsor", databaseMiddleware, sponsorRouter);
 app.use("/subscription", databaseMiddleware, subscriptionRouter);

src/config.ts

@@ -3,6 +3,8 @@ import dotenv from "dotenv";
 import { z } from "zod";
 import { getEnv } from "./utilities";
 
+import AWS from "aws-sdk";
+
 dotenv.config();
 
 export const Environment = z.enum(["PRODUCTION", "DEVELOPMENT", "TESTING"]);
@@ -79,6 +81,8 @@ export const Config = {
     // QR Scanning
     QR_HASH_ITERATIONS: 10000,
     QR_HASH_SECRET: getEnv("QR_HASH_SECRET"),
+
+    OUTGOING_EMAIL_ADDRESSES: "[email protected]",
 };
 
 export const DeviceRedirects: Record<string, string> = {
@@ -87,4 +91,8 @@ export const DeviceRedirects: Record<string, string> = {
     mobile: "exp://192.168.86.24:8081/--/Main",
 };
 
+export const ses = new AWS.SES({
+    region: Config.S3_REGION,
+});
+
 export default Config;

src/services/ses/ses-formats.ts

@@ -0,0 +1,16 @@
+export interface sendEmailParams {
+    Destination: {
+        ToAddresses: string[];
+    };
+    Message: {
+        Body: {
+            Text: {
+                Data: string;
+            };
+        };
+        Subject: {
+            Data: string;
+        };
+    };
+    Source: string;
+}

src/services/ses/ses-router.ts

@@ -0,0 +1,52 @@
+import { Request, Response, Router } from "express";
+import RoleChecker from "../../middleware/role-checker";
+import { StatusCodes } from "http-status-codes";
+import { Role } from "../auth/auth-models";
+import { sendEmail } from "./ses-utils";
+
+const sesRouter: Router = Router();
+
+//Takes in a list of emails and sends a test email to each of them
+//Will change this to take in a template_id later
+//The template_id and substitutions will all be done locally
+sesRouter.post(
+    "/email",
+    RoleChecker([Role.enum.STAFF], true),
+    async (req: Request, res: Response) => {
+        if (!req.body.emailList) {
+            return res
+                .status(StatusCodes.BAD_REQUEST)
+                .json({ error: "Invalid Params" });
+        }
+
+        const emailList: string[] = req.body.emailList;
+        const emailPromises: Promise<void>[] = [];
+        for (let i = 0; i < emailList.length; i++) {
+            emailPromises.push(
+                sendEmail(emailList[i], "Hello from SES!", `Test Email ${i}`)
+                    .then(() => {})
+                    .catch((err) => {
+                        console.error(
+                            `Error sending email ${i + 1}:`,
+                            err.message
+                        );
+                    })
+            );
+        }
+
+        Promise.all(emailPromises)
+            .then(() => {
+                return res
+                    .status(StatusCodes.OK)
+                    .send("All emails sent successfully");
+            })
+            .catch((err) => {
+                console.error("Error sending emails:", err.message);
+                return res
+                    .status(StatusCodes.INTERNAL_SERVER_ERROR)
+                    .send("Internal Server Error");
+            });
+    }
+);
+
+export default sesRouter;

src/services/ses/ses-schema.ts

@@ -0,0 +1,10 @@
+import { z } from "zod";
+
+// Zod schema for email requests
+const NotificationsValidator = z.object({
+    recipients: z.string(),
+    template: z.string(),
+    //should be able to work out subs from template
+});
+
+export { NotificationsValidator };

src/services/ses/ses-utils.ts

@@ -0,0 +1,26 @@
+import { ses, Config } from "../../config";
+
+export function sendEmail(
+    emailId: string,
+    subject: string,
+    emailBody: string
+): Promise<AWS.SES.SendEmailResponse> {
+    return ses
+        .sendEmail({
+            Destination: {
+                ToAddresses: [emailId],
+            },
+            Message: {
+                Body: {
+                    Text: {
+                        Data: emailBody,
+                    },
+                },
+                Subject: {
+                    Data: subject,
+                },
+            },
+            Source: Config.OUTGOING_EMAIL_ADDRESSES,
+        })
+        .promise();
+}