Merge pull request #95 from ReflectionsProjections/dev/alex/ses

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";
@@ -21,6 +22,12 @@ import statsRouter from "./services/stats/stats-router";
 import subscriptionRouter from "./services/subscription/subscription-router";
 import speakersRouter from "./services/speakers/speakers-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

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: z.enum(["[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-utils.ts

@@ -0,0 +1,40 @@
+import { ses, Config } from "../../config";
+
+export function sendManyEmails(
+    emailIds: string[],
+    subject: string,
+    emailBody: string
+): Promise<AWS.SES.SendEmailResponse>[] {
+    const emailPromises: Promise<AWS.SES.SendEmailResponse>[] = [];
+    for (let i = 0; i < emailIds.length; i++) {
+        emailPromises.push(sendEmail(emailIds[i], subject, emailBody));
+    }
+    return emailPromises;
+}
+
+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.Enum[
+                "[email protected]"
+            ],
+        })
+        .promise();
+}