sendEmailService added

Author: anijitsao

.env.development

@@ -4,6 +4,8 @@ REGION="ap-south-1"
 # Message queue related
 QUEUE_NAME="simple-fifo-queue.fifo"
 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"
 
 
 # HTTP status codes

package-lock.json

@@ -11,6 +11,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
+    "@aws-sdk/client-ses": "^3.131.0",
     "@aws-sdk/client-sqs": "^3.130.0",
     "uuid": "^8.3.2"
   },

package.json

@@ -0,0 +1,19 @@
+// Node js dependencies
+import fs from "fs";
+import { dirname } from "path";
+import { fileURLToPath } from "url";
+
+const __dirname = dirname(fileURLToPath(import.meta.url));
+
+const template = fs.readFileSync(
+  `${__dirname}/template.html`,
+  "utf-8",
+  (err, data) => {
+    if (err) throw err;
+  }
+);
+
+const sampleEmailTemplate = {
+  emailContent: template,
+};
+export { sampleEmailTemplate };

src/helpers/generateTemplates.js

@@ -0,0 +1,22 @@
+// AWS SDK dependencies
+import { ListIdentitiesCommand } from "@aws-sdk/client-ses";
+
+// local dependencies
+import { emailClient } from "../libs/emailClient.js";
+
+export async function listGenericIdentities() {
+  try {
+    // list upto 10 Generic Email Accounts
+    const params = {
+      IdentityType: "EmailAddress",
+      MaxRecords: 10,
+    };
+
+    const { Identities } = await emailClient.send(
+      new ListIdentitiesCommand(params)
+    );
+    return Identities;
+  } catch (error) {
+    return error;
+  }
+}

src/helpers/listGenericEmailIdentities.js

@@ -0,0 +1,51 @@
+<div
+  style="
+    margin: 0 auto;
+    width: 70vw;
+    font-family: 'Consolas', Arial, Helvetica, sans-serif;
+  "
+>
+  <div
+    style="
+      height: 2rem;
+      background-color: #ff8c00;
+      color: #fff;
+      padding: 6px 3px;
+      font-size: 1.1rem;
+      text-align: center;
+      border-radius: 5px 5px 0 0;
+    "
+  >
+    Sample Email Content
+  </div>
+  <div style="padding: 16px">
+    <p>
+      Dear Sir/Madam, <br />
+      <br />
+
+      This is a Simple Email sent from Amazon Simple Email Service (SES). This
+      is just a test email. It has no other purposes. <br />
+      <br />
+
+      Thanks and Regards, <br />
+      Anijit
+    </p>
+  </div>
+  <div
+    style="
+      height: 1rem;
+      background-color: #ff8c00;
+      color: #fff;
+      padding: 6px 3px;
+      text-align: center;
+      border-radius: 0 0 5px 5px;
+    "
+  >
+    send via
+    <a
+      style="text-decoration: none; color: #fff"
+      href="https://aws.amazon.com/ses/"
+      >amazonses.com</a
+    >
+  </div>
+</div>

src/helpers/template.html

@@ -0,0 +1,6 @@
+// import the SES client
+import { SESClient } from "@aws-sdk/client-ses";
+
+// initialize the client and export
+const emailClient = new SESClient({ region: process.env.REGION });
+export { emailClient };

src/lib/emailClient.js

@@ -1,3 +1,14 @@
 export async function receiveMessageQueueHandler(event) {
-  console.log("SQS Event received", 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);
+    }
+  });
+}
+
+function processEvent(eventData) {
+  console.log(JSON.parse(ele.body));
+  console.log("Message attributes are\n", ele.messageAttributes);
 }

src/services/receiveMessageQueueService.js

@@ -0,0 +1,47 @@
+// AWS SDK dependencies
+import { SendEmailCommand } from "@aws-sdk/client-ses";
+
+// local dependencies
+import { emailClient } from "../lib/emailClient.js";
+import { listGenericIdentities } from "../helpers/listGenericEmailIdentities.js";
+import { sampleEmailTemplate } from "../helpers/generateTemplates.js";
+
+export async function sendEmailHandler(event) {
+  try {
+    // list set of Generic Email Accounts which will send the emails
+    const genericAccounts = await listGenericIdentities();
+
+    if (Array.isArray(genericAccounts)) {
+      const emailParams = {
+        Destination: {
+          CcAddresses: [],
+          // list of receiver accounts
+          ToAddresses: ["anijitsau@gmail.com"],
+        },
+        Message: {
+          Body: {
+            Html: {
+              Charset: "UTF-8",
+              Data: sampleEmailTemplate.emailContent,
+            },
+          },
+          Subject: {
+            Charset: "UTF-8",
+            Data: process.env.SAMPLE_EMAIL_SUBJECT,
+          },
+        },
+        Source: genericAccounts[0],
+        ReplyToAddresses: [],
+      };
+
+      // sending the Email
+      const emailData = await emailClient.send(
+        new SendEmailCommand(emailParams)
+      );
+
+      return;
+    }
+  } catch (error) {
+    return error.toString();
+  }
+}