Add microsoftl365 email sender

* Add microsoftl365 email sender

* Test and lint mail365

Co-authored-by: Carlo Minotti <[email protected]>

Author: minottic

server/boot/graph-mail.js

@@ -0,0 +1,117 @@
+"use strict";
+const config = require("../../server/config.local");
+const superagent = require("superagent");
+  
+class M365Authenticate {
+  constructor(config){
+    this.tenantId = config.auth.tenantId || "";
+    this.clientId = config.auth.clientId || "";
+    this.clientSecret = config.auth.clientSecret || "";
+    this.aadEndpoint = config.aadEndpoint || "";
+    this.graphEndpoint = config.graphEndpoint || "";
+  }
+
+  async getAuthToken() {
+    const formData = {
+      "grant_type": "client_credentials",
+      scope: `${this.graphEndpoint}/.default`,
+      "client_id": this.clientId,
+      "client_secret": this.clientSecret,
+    };
+ 
+    const tokenObject = await superagent.post(
+      `${this.aadEndpoint}/${this.tenantId}/oauth2/v2.0/token`)
+      .set({ "Content-Type": "application/x-www-form-urlencoded" })
+      .send(formData);
+    return tokenObject.body.access_token;
+  }
+
+}
+
+class M365Email {
+  constructor(authClass) {
+    this.authClass = authClass;
+    this.graphEndpoint = authClass.graphEndpoint;
+  }
+
+  createRecipients(rcpts) {
+    return rcpts.filter(r => r).map((rcpt) => {
+      return {
+        emailAddress: {
+          address: rcpt,
+        },
+      };
+    });
+  }
+   
+  createEmailAsJson(rcpts, body, from, replyTo, subject) {
+    let messageAsJson = {
+      message: {
+        subject: subject,
+        from: {
+          emailAddress: { address: from }
+        },
+        replyTo: [{
+          emailAddress: { address: replyTo }
+        }],
+        body: {
+          contentType: "HTML",
+          content: body,
+        },
+      },
+    };
+   
+    messageAsJson = this.addRecipients(messageAsJson, rcpts);
+    return messageAsJson;
+  }
+  
+  async sendNotification(from, message){
+    const accessToken = await this.authClass.getAuthToken();
+    try {
+      const response = await superagent.post(
+        `${this.graphEndpoint}/v1.0/users/${from}/sendMail`)
+        .set({ Authorization: `Bearer ${accessToken}` })
+        .set({ "Content-Type": "application/json" })
+        .send(message);
+   
+      console.log("sendNotification status", response.statusText);
+    } catch (error) {
+      console.log(error);
+    }
+  }
+
+  addRecipients(messageBody, rcpts = {}) {
+    const cloned = Object.assign({}, messageBody);
+   
+    Object.keys(rcpts).forEach((element) => {
+      const recipients = this.createRecipients(rcpts[element]);
+      if (recipients.length > 0) {
+        cloned.message[element + "Recipients"] = recipients;
+      }
+    });
+   
+    return cloned;
+  }
+
+}
+
+exports.M365Email = M365Email;
+
+exports.sendEmailM365 = async(to, cc, subjectText, mailText, e, next, html = null) => {
+  try {
+    const client = new M365Authenticate(config.smtpSettings);
+    const emailSender = new M365Email(client);
+    const messageCofig = config.smtpMessage;
+    const message = emailSender.createEmailAsJson(
+      { to: to.split(","), cc: cc ?cc.split(","): [] }, 
+      html, 
+      messageCofig.from, 
+      messageCofig.replyTo, 
+      messageCofig.subject
+    );
+    emailSender.sendNotification(messageCofig.from, message);
+  } catch (err) {
+    console.log(err);
+  }
+  return next && next(e);
+};

server/boot/handleJobSideEffects.js

@@ -3,8 +3,10 @@ const fs = require("fs");
 const config = require("../config.local");
 const utils = require("../../common/models/utils");
 const Handlerbars = require("handlebars");
+const graphMail = require("./graph-mail");
 module.exports = (app) => {
 
+  const sendMail = config.smtpSettings && config.smtpSettings.graphEndpoint ? graphMail.sendEmailM365: utils.sendMail;
   const Job = app.models.Job;
   const jobTypes = Job.types;
   const Dataset = app.models.Dataset;
@@ -72,7 +74,7 @@ module.exports = (app) => {
     const emailTemplate = Handlerbars.compile(htmlTemplate);
     const email = emailTemplate(emailContext);
     const subject = emailContext.subject;
-    utils.sendMail(to, cc, subject, null, null, null, email);
+    sendMail(to, cc, subject, null, null, null, email);
   };
 
   // Check policy settings if mail should be sent

test/graph-mail.js

@@ -0,0 +1,57 @@
+"use strict";
+
+const { sendEmailM365, M365Email } = require("../server/boot/graph-mail.js");
+const sandbox = require("sinon").createSandbox();
+const { expect } = require("chai");
+const config = require("../server/config.local");
+
+afterEach((done) => {
+  sandbox.restore();
+  done();
+});      
+
+describe("server.boot.graph-mail", () => {
+
+  it("should sendEmailM365", () => {
+    const sendNotificationStub = sandbox.stub(M365Email.prototype, "sendNotification");
+    if (!config.smtpSettings) config.smtpSettings = {};
+    sandbox.stub(config, "smtpSettings").value({
+      auth: {
+        tenantId: "someTenant", 
+        clientId: "someClientId", 
+        clientSecret: "someClientSecret"
+      }
+    });
+    const from = "[email protected]";
+    if (!config.smtpMessage) config.smtpMessage = {};
+    sandbox.stub(config, "smtpMessage").value({
+      from: "[email protected]",
+      replyTo: "[email protected]",
+      subject: "this is a subject",
+    });
+    const body = "<h1>Test from James A</h1><p>HTML message sent via MS Graph</p>";
+    sendEmailM365("[email protected],[email protected]", "", null, null, null, null, body);
+    const expectedMessage = { 
+      message:{ 
+        subject:"this is a subject",
+        from:{ 
+          emailAddress:{ 
+            address:"[email protected]" 
+          } 
+        },
+        replyTo:[
+          { emailAddress:{ address:"[email protected]" } }
+        ],
+        body:{ 
+          contentType:"HTML",
+          content:"<h1>Test from James A</h1><p>HTML message sent via MS Graph</p>" },
+        toRecipients:[
+          { emailAddress:{ address:"[email protected]" } },
+          { emailAddress:{ address:"[email protected]" } }
+        ] 
+      } 
+    };
+    expect(sendNotificationStub.calledWith(from, expectedMessage)).to.be.true;
+  });
+
+});