Send internal emails to ACM email

If that email doesn't exist, then it will be forwarded to the Illinois email.

Author: devksingh4

src/api/routes/apiKey.ts

@@ -24,6 +24,7 @@ import {
 import * as z from "zod/v4";
 import { AvailableSQSFunctions, SQSPayload } from "common/types/sqsMessage.js";
 import { SendMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
+import { getAllUserEmails } from "common/utils.js";
 
 const apiKeyRoute: FastifyPluginAsync = async (fastify, _options) => {
   await fastify.register(rateLimiter, {
@@ -96,7 +97,7 @@ const apiKeyRoute: FastifyPluginAsync = async (fastify, _options) => {
           reqId: request.id,
         },
         payload: {
-          to: [request.username!],
+          to: getAllUserEmails(request.username),
           subject: "Important: API Key Created",
           content: `
 This email confirms that an API key for the Core API has been generated from your account.
@@ -203,7 +204,7 @@ If you did not create this API key, please secure your account and notify the AC
           reqId: request.id,
         },
         payload: {
-          to: [request.username!],
+          to: getAllUserEmails(request.username),
           subject: "Important: API Key Deleted",
           content: `
 This email confirms that an API key for the Core API has been deleted from your account.

src/api/routes/iam.ts

@@ -44,6 +44,7 @@ import { AvailableSQSFunctions } from "common/types/sqsMessage.js";
 import { SendMessageBatchCommand, SQSClient } from "@aws-sdk/client-sqs";
 import { randomUUID } from "crypto";
 import { getKey, setKey } from "api/functions/redisCache.js";
+import { getAllUserEmails } from "common/utils.js";
 
 const iamRoutes: FastifyPluginAsync = async (fastify, _options) => {
   const getAuthorizedClients = async () => {
@@ -456,7 +457,7 @@ const iamRoutes: FastifyPluginAsync = async (fastify, _options) => {
               reqId: request.id,
             },
             payload: {
-              to: [x],
+              to: getAllUserEmails(x),
               subject: "You have been added to an access group",
               content: `
 Hello,
@@ -478,7 +479,7 @@ No action is required from you at this time.
               reqId: request.id,
             },
             payload: {
-              to: [x],
+              to: getAllUserEmails(x),
               subject: "You have been removed from an access group",
               content: `
 Hello,

src/api/routes/roomRequests.ts

@@ -32,6 +32,7 @@ import { buildAuditLogTransactPut } from "api/functions/auditLog.js";
 import { Modules } from "common/modules.js";
 import {
   generateProjectionParams,
+  getAllUserEmails,
   getDefaultFilteringQuerystring,
   nonEmptyCommaSeparatedStringSchema,
 } from "common/utils.js";
@@ -142,7 +143,7 @@ const roomRequestRoutes: FastifyPluginAsync = async (fastify, _options) => {
           reqId: request.id,
         },
         payload: {
-          to: [originalRequestor],
+          to: getAllUserEmails(originalRequestor),
           subject: "Room Reservation Request Status Change",
           content: `Your Room Reservation Request has been been moved to status "${formatStatus(request.body.status)}". Please visit the management portal for more details.`,
           callToActionButton: {

src/api/routes/stripe.ts

@@ -44,6 +44,7 @@ import rawbody from "fastify-raw-body";
 import { AvailableSQSFunctions, SQSPayload } from "common/types/sqsMessage.js";
 import { SendMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
 import * as z from "zod/v4";
+import { getAllUserEmails } from "common/utils.js";
 
 const stripeRoutes: FastifyPluginAsync = async (fastify, _options) => {
   await fastify.register(rawbody, {
@@ -412,7 +413,7 @@ const stripeRoutes: FastifyPluginAsync = async (fastify, _options) => {
                       reqId: request.id,
                     },
                     payload: {
-                      to: [unmarshalledEntry.userId],
+                      to: getAllUserEmails(unmarshalledEntry.userId),
                       subject: `Payment Failed for Invoice ${unmarshalledEntry.invoiceId}`,
                       content: `
 A ${paidInFull ? "full" : "partial"} payment for Invoice ${unmarshalledEntry.invoiceId} (${withCurrency} paid by ${name}, ${email}) <b>has failed.</b>
@@ -565,7 +566,7 @@ Please ask the payee to try again, perhaps with a different payment method, or c
                       reqId: request.id,
                     },
                     payload: {
-                      to: [unmarshalledEntry.userId],
+                      to: getAllUserEmails(unmarshalledEntry.userId),
                       subject: `Payment Pending for Invoice ${unmarshalledEntry.invoiceId}`,
                       content: `
 ACM @ UIUC has received intent of ${paidInFull ? "full" : "partial"} payment for Invoice ${unmarshalledEntry.invoiceId} (${withCurrency} paid by ${name}, ${email}).
@@ -610,7 +611,7 @@ Please contact Officer Board with any questions.
                       reqId: request.id,
                     },
                     payload: {
-                      to: [unmarshalledEntry.userId],
+                      to: getAllUserEmails(unmarshalledEntry.userId),
                       cc: [
                         notificationRecipients[fastify.runEnvironment]
                           .Treasurer,

src/common/utils.ts

@@ -53,3 +53,10 @@ export const getDefaultFilteringQuerystring = ({ defaultSelect }: GetDefaultFilt
     })
   };
 };
+
+export const getAllUserEmails = (username?: string) => {
+  if (!username) {
+    return [];
+  }
+  return [username.replace("@illinois.edu", "@acm.illinois.edu")]
+}