feature/DEVSU-834-add-email-when-user-assigned

app/config.js

@@ -20,6 +20,7 @@ if (ENV === 'production') {
 }
 
 const DEFAULT_TEST_USER = 'ipr-bamboo-admin';
+const DEFAULT_EMAIL_ADDRESS = 'rpletz';
 
 const DEFAULTS = {
   env: ENV,
@@ -46,6 +47,9 @@ const DEFAULTS = {
   testing: {
     username: DEFAULT_TEST_USER,
   },
+  email: {
+    email: DEFAULT_EMAIL_ADDRESS,
+  },
   log: {
     level: DEFAULT_LOG_LEVEL,
   },
@@ -129,6 +133,12 @@ const CONFIG = nconf
     'testing.username': {
       alias: 'testing:username',
     },
+    'email.email': {
+      alias: 'email.email',
+    },
+    'email.password': {
+      alias: 'email.password',
+    },
     'log.level': {
       alias: 'log:level',
     },

app/constants.js

@@ -9,6 +9,9 @@ module.exports = {
     msi: 'msi',
     tmb: 'tmburMutationBurden',
   },
+  NOTIFICATION_EVENT: {
+    USER_BOUND: 'userBound',
+  },
   KB_PIVOT_COLUMN: 'variantType',
   GENE_LINKED_VARIANT_MODELS: [
     'expressionVariants',

app/libs/email.js

@@ -0,0 +1,90 @@
+const nodemailer = require('nodemailer');
+const CONFIG = require('../config');
+const db = require('../models');
+
+const {email, password} = CONFIG.get('email');
+
+const sendEmail = (subject, text, toEmail) => {
+  const transporter = nodemailer.createTransport({
+    host: 'webmail.bcgsc.ca',
+    auth: {
+      user: email,
+      pass: password,
+    },
+    tls: {
+      rejectUnauthorized: false,
+    },
+  });
+
+  const mailOptions = {
+    from: `${email}@bcgsc.ca`,
+    to: toEmail,
+    subject,
+    text,
+  };
+
+  transporter.sendMail(mailOptions, (error, info) => {
+    if (error) {
+      console.log(error);
+    } else {
+      console.log(`Email sent: ${info.response}`);
+    }
+  });
+};
+
+const getEmailList = async (triggers) => {
+  const notifs = await db.models.notification.scope('extended').findAll({
+    where: triggers,
+  });
+
+  const emailList = [];
+  for (const notif of notifs) {
+    if (notif.user) {
+      if (!emailList.includes(notif.user.email)) {
+        emailList.push(notif.user.email);
+      }
+    } else if (notif.userGroup) {
+      for (const groupUser of notif.userGroup.users) {
+        if (!emailList.includes(groupUser.email)) {
+          emailList.push(groupUser.email);
+        }
+      }
+    }
+  }
+
+  return emailList;
+};
+
+const notifyUsers = async (subject, text, triggers) => {
+  const emailList = await getEmailList(triggers);
+
+  const transporter = nodemailer.createTransport({
+    host: 'webmail.bcgsc.ca',
+    auth: {
+      user: email,
+      pass: password,
+    },
+    tls: {
+      rejectUnauthorized: false,
+    },
+  });
+
+  emailList.forEach((toEmail) => {
+    const mailOptions = {
+      from: `${email}@bcgsc.ca`,
+      to: toEmail,
+      subject,
+      text,
+    };
+
+    transporter.sendMail(mailOptions, (error, info) => {
+      if (error) {
+        console.log(error);
+      } else {
+        console.log(`Email sent: ${info.response}`);
+      }
+    });
+  });
+};
+
+module.exports = {sendEmail, getEmailList, notifyUsers};

app/models/notification/notification.js

@@ -71,6 +71,14 @@ module.exports = (sequelize, Sq) => {
             {model: sequelize.models.project.scope('minimal'), as: 'project'},
           ],
         },
+        extended: {
+          include: [
+            {model: sequelize.models.user, as: 'user'},
+            {model: sequelize.models.userGroup, as: 'userGroup', include: {model: sequelize.models.user, as: 'users', through: {attributes: []}}},
+            {model: sequelize.models.template, as: 'template'},
+            {model: sequelize.models.project, as: 'project'},
+          ],
+        },
       },
     },
   );

app/routes/notification/notification.js

@@ -164,13 +164,19 @@ router.route('/')
     }
 
     try {
-      const newnotif = await db.models.notification.create({
-        projectId: req.body.project_id, userId: req.body.user_id ? req.body.user_id : null, userGroupId: req.body.user_group_id ? req.body.user_group_id : null, eventType: req.body.event_type, templateId: req.body.template_id,
+      const newnotif = await db.models.notification.findOrCreate({
+        where: {
+          projectId: req.body.project_id,
+          userId: req.body.user_id ? req.body.user_id : null,
+          userGroupId: req.body.user_group_id ? req.body.user_group_id : null,
+          eventType: req.body.event_type,
+          templateId: req.body.template_id,
+        },
       });
 
       // Load new notif with associations
       const result = await db.models.notification.scope('public').findOne({
-        where: {id: newnotif.id},
+        where: {id: newnotif[0].id},
       });
 
       return res.status(HTTP_STATUS.CREATED).json(result);

app/routes/report/reportUser.js

@@ -8,7 +8,8 @@ const router = express.Router({mergeParams: true});
 
 const schemaGenerator = require('../../schemas/schemaGenerator');
 const validateAgainstSchema = require('../../libs/validateAgainstSchema');
-const {REPORT_CREATE_BASE_URI} = require('../../constants');
+const email = require('../../libs/email');
+const {REPORT_CREATE_BASE_URI, NOTIFICATION_EVENT} = require('../../constants');
 const {REPORT_EXCLUDE} = require('../../schemas/exclude');
 
 // Generate create schema
@@ -129,6 +130,21 @@ router.route('/')
         addedBy_id: req.user.id,
       });
 
+      // Try sending email
+      try {
+        await email.notifyUsers(
+          `${bindUser.firstName} ${bindUser.lastName} has been bound to a report`,
+          `User ${bindUser.firstName} ${bindUser.lastName} has been bound to report ${req.report.ident}`,
+          {
+            eventType: NOTIFICATION_EVENT.USER_BOUND,
+            templateId: req.report.templateId,
+          },
+        );
+        logger.info('Email sent successfully');
+      } catch (error) {
+        logger.error(`Email not sent successfully: ${error}`);
+      }
+
       await req.report.reload();
       return res.status(HTTP_STATUS.CREATED).json(req.report.view('public'));
     } catch (error) {

emaildebug/emailtest.js

@@ -0,0 +1,53 @@
+const nodemailer = require('nodemailer');
+const Queue = require('bull');
+
+const emailQueue = new Queue('emails');
+
+const email = 'rpletz';
+const password = 'password';
+
+const transporter = nodemailer.createTransport({
+  host: 'webmail.bcgsc.ca',
+  auth: {
+    user: email,
+    pass: password,
+  },
+  tls: {
+    rejectUnauthorized: false,
+  },
+  pool: true,
+});
+
+const mail = {
+  to: `${email}@bcgsc.ca`,
+  subject: 'subject',
+  body: 'body',
+};
+
+emailQueue.process(async (job) => {
+  const {to, subject, body} = job.data;
+  const mailOptions = {
+    from: `${email}@bcgsc.ca`,
+    to,
+    subject,
+    text: body,
+  };
+  await transporter.sendMail(mailOptions, (error, info) => {
+    if (error) {
+      console.log(error);
+    } else {
+      console.log(`Email sent: ${info.response}`);
+    }
+  });
+});
+
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);
+emailQueue.add(mail);