/libs/ naming fixed

Author: anijitsao

.env.development

@@ -7,6 +7,8 @@ MESSAGE_GROUP_ID="purchase-info"
 QUEUE_URL="https://sqs.ap-south-1.amazonaws.com/657149196530/simple-fifo-queue.fifo"
 QUEUE_ARN="arn:aws:sqs:ap-south-1:657149196530:simple-fifo-queue.fifo"
 
+# Email related
+SAMPLE_EMAIL_SUBJECT="Invoice"
 
 # HTTP status codes
 SUCCESS_CODE=200

serverless.json

@@ -11,7 +11,7 @@
         "statements": [
           {
             "Effect": "Allow",
-            "Action": ["sqs:*"],
+            "Action": ["sqs:*", "ses:*"],
             "Resource": "*"
           }
         ],

src/lib/emailClient.js src/libs/emailClient.jssrc/lib/emailClient.js renamed to src/libs/emailClient.js

@@ -1,6 +1,8 @@
+// local dependencies
+import { sendEmailHandler } from "./sendEmailService.js";
+
 export async function receiveMessageQueueHandler(event) {
   console.log("SQS Event received\n", event);
-  console.log("Printing event body");
   event.Records.forEach((ele) => {
     if (ele.eventSourceARN === process.env.QUEUE_ARN) {
       processEvent(ele);
@@ -9,6 +11,7 @@ export async function receiveMessageQueueHandler(event) {
 }
 
 function processEvent(eventData) {
-  console.log(JSON.parse(ele.body));
-  console.log("Message attributes are\n", ele.messageAttributes);
+  console.log(JSON.parse(eventData.body));
+  console.log("Message attributes are\n", eventData.messageAttributes);
+  return sendEmailHandler(eventData);
 }

src/lib/queueClient.js src/libs/queueClient.jssrc/lib/queueClient.js renamed to src/libs/queueClient.js

@@ -2,7 +2,7 @@
 import { SendEmailCommand } from "@aws-sdk/client-ses";
 
 // local dependencies
-import { emailClient } from "../lib/emailClient.js";
+import { emailClient } from "../libs/emailClient.js";
 import { listGenericIdentities } from "../helpers/listGenericEmailIdentities.js";
 import { sampleEmailTemplate } from "../helpers/generateTemplates.js";