feat(PM-1611): send email when opportunity is completed or canceled

.circleci/config.yml

@@ -149,7 +149,7 @@ workflows:
           context : org-global
           filters:
             branches:
-              only: ['develop', 'migration-setup', 'pm-1613']
+              only: ['develop', 'migration-setup', 'pm-1611']
       - deployProd:
           context : org-global
           filters:

src/constants.js

@@ -314,6 +314,8 @@ export const TEMPLATE_IDS = {
   INFORM_PM_COPILOT_APPLICATION_ACCEPTED: 'd-b35d073e302b4279a1bd208fcfe96f58',
   COPILOT_ALREADY_PART_OF_PROJECT: 'd-003d41cdc9de4bbc9e14538e8f2e0585',
   COPILOT_APPLICATION_ACCEPTED: 'd-eef5e7568c644940b250e76d026ced5b',
+  COPILOT_OPPORTUNITY_COMPLETED: 'd-dc448919d11b4e7d8b4ba351c4b67b8b',
+  COPILOT_OPPORTUNITY_CANCELED: 'd-2a67ba71e82f4d70891fe6989c3522a3'
 }
 export const REGEX = {
   URL: /^(http(s?):\/\/)?(www\.)?[a-zA-Z0-9\.\-\_]+(\.[a-zA-Z]{2,15})+(\:[0-9]{2,5})?(\/[a-zA-Z0-9\_\-\s\.\/\?\%\#\&\=;]*)?$/, // eslint-disable-line

src/routes/copilotOpportunity/assign.js

@@ -18,6 +18,41 @@ const assignCopilotOpportunityValidations = {
   }),
 };
 
+const sendEmailToAllApplicants = async (req, opportunity, copilotRequest, applicationId) => {
+  const allApplications = await models.Sequelize.CopilotApplication.findAll({
+    where: {
+      opportunityId: opportunity.id,
+      id: {
+        [Op.notIn]: [applicationId],
+      }
+    }
+  });
+
+  const userIds = allApplications.map(item => item.userId);
+
+  const users = await util.getMemberDetailsByUserIds(userIds, req.log, req.id);
+
+  users.forEach(async (user) => {
+    req.log.debug(`Sending email notification to copilots who are not accepted`);
+    const emailEventType = CONNECT_NOTIFICATION_EVENT.EXTERNAL_ACTION_EMAIL;
+    const copilotPortalUrl = config.get('copilotPortalUrl');
+    const requestData = copilotRequest.data;
+    createEvent(emailEventType, {
+      data: {
+        opportunity_details_url: `${copilotPortalUrl}/opportunity`,
+        opportunity_title: requestData.opportunityTitle,
+        user_name: user ? user.handle : "",
+      },
+      sendgrid_template_id: TEMPLATE_IDS.COPILOT_OPPORTUNITY_COMPLETED,
+      recipients: [user.email],
+      version: 'v3',
+    }, req.log);
+
+    req.log.debug(`Email sent to copilots who are not accepted`);
+  });
+
+};
+
 module.exports = [
   validate(assignCopilotOpportunityValidations),
   async (req, res, next) => {
@@ -134,6 +169,9 @@ module.exports = [
         }, req.log);
 
         req.log.debug(`Email sent`);
+
+        // Send email to all applicants about opportunity completion
+        await sendEmailToAllApplicants(req, opportunity, copilotRequest, application.id);
       };
 
       const existingMember = activeMembers.find(item => item.userId === userId);

src/routes/copilotOpportunity/delete.js

@@ -1,12 +1,39 @@
 import _ from 'lodash';
 import { Op } from 'sequelize';
+import config from 'config';
 
 import models from '../../models';
 import util from '../../util';
-import { COPILOT_APPLICATION_STATUS, COPILOT_OPPORTUNITY_STATUS, COPILOT_REQUEST_STATUS, EVENT, INVITE_STATUS, RESOURCES } from '../../constants';
+import { CONNECT_NOTIFICATION_EVENT, COPILOT_APPLICATION_STATUS, COPILOT_OPPORTUNITY_STATUS, COPILOT_REQUEST_STATUS, EVENT, INVITE_STATUS, RESOURCES, TEMPLATE_IDS } from '../../constants';
+import { createEvent } from '../../services/busApi';
 import { PERMISSION } from '../../permissions/constants';
 
 
+const sendEmailToAllApplicants = async (req, copilotRequest, applications) => {
+  const userIds = applications.map(item => item.userId);
+  const users = await util.getMemberDetailsByUserIds(userIds, req.log, req.id);
+
+  users.forEach(async (user) => {
+    req.log.debug(`Sending email notification to copilots who applied`);
+    const emailEventType = CONNECT_NOTIFICATION_EVENT.EXTERNAL_ACTION_EMAIL;
+    const copilotPortalUrl = config.get('copilotPortalUrl');
+    const requestData = copilotRequest.data;
+    createEvent(emailEventType, {
+      data: {
+        opportunity_details_url: `${copilotPortalUrl}/opportunity`,
+        opportunity_title: requestData.opportunityTitle,
+        user_name: user ? user.handle : "",
+      },
+      sendgrid_template_id: TEMPLATE_IDS.COPILOT_OPPORTUNITY_CANCELED,
+      recipients: [user.email],
+      version: 'v3',
+    }, req.log);
+
+    req.log.debug(`Email sent to copilots who applied`);
+  });
+
+};
+
 module.exports = [
   (req, res, next) => {
     if (!util.hasPermissionByReq(PERMISSION.CANCEL_COPILOT_OPPORTUNITY, req)) {
@@ -93,6 +120,8 @@ module.exports = [
           invite.toJSON());
       }
 
+      await sendEmailToAllApplicants(req, copilotRequest, applications)
+
       res.status(200).send({ id: opportunity.id });
     })