Send denied application email with SES

apps/backend/src/lambdas/applicationUpdate.ts

@@ -0,0 +1,43 @@
+import { SESClient, SendEmailCommand } from '@aws-sdk/client-ses';
+
+const sesClient = new SESClient({ region: process.env.AWS_REGION });
+
+exports.handler = async (event: any) => {
+  const { firstName, userEmail } = event;
+
+  try {
+    // Send email using SES
+    const emailParams = {
+      Destination: {
+        ToAddresses: [userEmail],
+      },
+      Message: {
+        Body: {
+          Text: {
+            Data: `Hi ${firstName},\n\nWe regret to inform you that your application has not been approved at this time. Please contact the Office of Green Infrastructure if you have any questions or concerns about your application.\n\nSincerely,\nOffice of Green Infrastructure`,
+          },
+        },
+        Subject: {
+          Data: 'Green Infrastructure Volunteer Application Update',
+        },
+      },
+      Source: process.env.SES_SOURCE_EMAIL,
+    };
+
+    const sendEmailCommand = new SendEmailCommand(emailParams);
+    await sesClient.send(sendEmailCommand);
+
+    return {
+      statusCode: 200,
+      body: JSON.stringify({ message: 'Email sent successfully' }),
+    };
+  } catch (error) {
+    console.error('Error sending email:', error);
+    return {
+      statusCode: 500,
+      body: JSON.stringify({
+        message: `Error sending email: ${error.message}`,
+      }),
+    };
+  }
+};

apps/backend/src/user/user.model.ts

@@ -25,7 +25,7 @@ export type UserInputModel = {
     zipCode: {S: string},
     birthDate: {S: string},
     role: {S: string},
-    siteIds: {S: string},
+    siteIds: {L: {N: string}[] },
     status: {S: string}
 };
 export class EditUserModel {

apps/backend/src/user/user.service.ts

@@ -3,14 +3,14 @@ import { UserModel, EditUserModel } from "./user.model";
 import { DynamoDbService } from "../dynamodb";
 import { UserInputModel, UserStatus, Role } from "./user.model";
 import { NewUserInput } from "../dtos/newUserDTO";
+import { LambdaClient, InvokeCommand } from '@aws-sdk/client-lambda';
 
 @Injectable()
 export class UserService {
 
     private readonly tableName = 'gibostonUsers';
-    constructor(private readonly dynamoDbService: DynamoDbService) {}
-
-
+    private readonly lambdaClient: LambdaClient = new LambdaClient({ region: process.env.AWS_REGION });
+    constructor(private readonly dynamoDbService: DynamoDbService) { }
 
     /**
      * Gets a user's information based on the user's id.
@@ -76,8 +76,6 @@ export class UserService {
 
             const originalUser = await this.getUser(userId);
 
-
-
             if (model.firstName) {
                 commands.push(`firstName = :firstName`);
                 expressionAttributeValues[":firstName"] = { S: model.firstName };
@@ -112,13 +110,25 @@ export class UserService {
                 if (!siteCheckResult) {
                     return {statusCode: 400, message: "Site does not exist"};
                 }
-              }
+            }
 
-              if (model.status) {
+            if (model.status) {
                 commands.push(`#s = :status`);
                 expressionAttributeValues[":status"] = { S: model.status };
-                expressionAttributeNames["#s"] = "status"; // Define the alias
-              }
+                expressionAttributeNames["#s"] = "status";
+                if (model.status === UserStatus.DENIED) {
+                    // Send email if status is denied
+                    const lamdaParams = {
+                        FunctionName: 'giSendEmail',
+                        Payload: JSON.stringify({
+                            firstName: model.firstName ? model.firstName : originalUser.firstName,
+                            userEmail: originalUser.email
+                        }),
+                    }
+                    const command = new InvokeCommand(lamdaParams);
+                    await this.lambdaClient.send(command);
+                }
+            }
 
 
             // Make sure commands aren't empty
@@ -177,8 +187,9 @@ export class UserService {
      * @returns the user's information as a UserModel object
      */
     private mapDynamoDBItemToUserModel(objectId: number, data?: {[key: string]: any}): UserModel {
-
-        const siteIds = data["siteIds"].L.map(item => Number(item.N)) ?? [];
+        const siteIds = Array.isArray(data["siteIds"]?.L) 
+        ? data["siteIds"].L.map(item => Number(item.N)) 
+        : [];
 
 
         return {
@@ -205,7 +216,7 @@ export class UserService {
             zipCode: {S: input.zipCode},
             birthDate: {S: input.birthDate},
             role: {S: role},
-            siteIds: {S: "null"},
+            siteIds: { L: [] },
             status: {S: UserStatus.PENDING}
         };
     }

package.json

@@ -13,6 +13,8 @@
   "private": true,
   "dependencies": {
     "@aws-sdk/client-dynamodb": "^3.319.0",
+    "@aws-sdk/client-lambda": "^3.738.0",
+    "@aws-sdk/client-ses": "^3.738.0",
     "@aws-sdk/util-dynamodb": "^3.319.0",
     "@blueprintjs/core": "^4.18.0",
     "@blueprintjs/table": "^4.10.1",