feat(PM-1173): Notify all copilots on copilot opportunity

.circleci/config.yml

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

config/default.json

@@ -54,6 +54,7 @@
   "inviteEmailSubject": "You are invited to Topcoder",
   "inviteEmailSectionTitle": "Project Invitation",
   "workManagerUrl": "https://challenges.topcoder-dev.com",
+  "copilotPortalUrl": "https://copilots.topcoder-dev.com",
   "accountsAppUrl": "https://accounts.topcoder-dev.com",
   "MAX_REVISION_NUMBER": 100,
   "UNIQUE_GMAIL_VALIDATION": false,

config/development.json

@@ -3,6 +3,7 @@
   "pubsubExchangeName": "dev.projects",
   "attachmentsS3Bucket": "topcoder-dev-media",
   "workManagerUrl": "https://challenges.topcoder-dev.com",
+  "copilotPortalUrl": "https://copilots.topcoder-dev.com",
   "fileServiceEndpoint": "https://api.topcoder-dev.com/v5/files",
   "memberServiceEndpoint": "https://api.topcoder-dev.com/v5/members",
   "identityServiceEndpoint": "https://api.topcoder-dev.com/v3/",

config/production.json

@@ -1,6 +1,7 @@
 {
   "authDomain": "topcoder.com",
   "workManagerUrl": "https://challenges.topcoder.com",
+  "copilotPortalUrl": "https://copilots.topcoder.com",
   "sfdcBillingAccountNameField": "Billing_Account_name__c",
   "sfdcBillingAccountMarkupField": "Mark_up__c",
   "sfdcBillingAccountActiveField": "Active__c"

src/constants.js

@@ -302,6 +302,9 @@ export const CONNECT_NOTIFICATION_EVENT = {
   TOPIC_UPDATED: 'connect.notification.project.topic.updated',
   POST_CREATED: 'connect.notification.project.post.created',
   POST_UPDATED: 'connect.notification.project.post.edited',
+
+  // External action email
+  EXTERNAL_ACTION_EMAIL: 'external.action.email',
 };
 
 export const REGEX = {

src/routes/copilotRequest/approveRequest.js

@@ -35,7 +35,7 @@ module.exports = [
       updatedBy: req.authUser.userId,
     });
 
-    return approveRequest(data)
+    return approveRequest(req, data)
       .then(_newCopilotOpportunity => res.status(201).json(_newCopilotOpportunity))
       .catch((err) => {
         if (err.message) {

src/routes/copilotRequest/approveRequest.service.js

@@ -1,7 +1,10 @@
 import _ from 'lodash';
+import config from 'config';
 
 import models from '../../models';
-import { COPILOT_REQUEST_STATUS } from '../../constants';
+import { CONNECT_NOTIFICATION_EVENT, COPILOT_REQUEST_STATUS } from '../../constants';
+import util from '../../util';
+import { createEvent } from '../../services/busApi';
 
 const resolveTransaction = (transaction, callback) => {
   if (transaction) {
@@ -11,7 +14,7 @@ const resolveTransaction = (transaction, callback) => {
   return models.sequelize.transaction(callback);
 };
 
-module.exports = (data, existingTransaction) => {
+module.exports = (req, data, existingTransaction) => {
   const { projectId, copilotRequestId } = data;
 
   return resolveTransaction(existingTransaction, transaction =>
@@ -52,6 +55,31 @@ module.exports = (data, existingTransaction) => {
                 return models.CopilotOpportunity
                   .create(data, { transaction });
               }))
+              .then(async (opportunity) => {
+                const roles = await util.getRolesByRoleName('copilot', req.log, req.id);
+                req.log.info("getting subjects for roles", roles[0]);
+                const { subjects = [] } = await util.getRoleInfo(roles[0], req.log, req.id);
+                const emailEventType = CONNECT_NOTIFICATION_EVENT.EXTERNAL_ACTION_EMAIL;
+                const copilotPortalUrl = config.get('copilotPortalUrl');
+                req.log.info("Sending emails to all copilots about new opportunity");
+                req.log.info(`${copilotPortalUrl}/opportunity/${opportunity.id}`, '`${copilotPortalUrl}/opportunity/${opportunity.id}`');
+                subjects.forEach(subject => {
+                  req.log.info("Each copilot members", subject);
+                  createEvent(emailEventType, {
+                    data: {
+                      user_name: subject.handle,
+                      opportunityDetailsUrl: `${copilotPortalUrl}/opportunity/${opportunity.id}`,
+                    },
+                    sendgrid_template_id: "d-3efdc91da580479d810c7acd50a4c17f",
+                    recipients: [subject.email],
+                    version: '433b1688-c543-4656-a295-efcbea57444d',
+                  }, req.log);
+                });
+
+                req.log.info("Finished sending emails to copilots");
+
+                return opportunity;
+              })
               .catch((err) => {
                 transaction.rollback();
                 return Promise.reject(err);

src/routes/copilotRequest/create.js

@@ -98,7 +98,7 @@ module.exports = [
               updatedBy: req.authUser.userId,
               type: copilotRequest.data.projectType,
             });
-            return approveRequest(approveData, transaction).then(() => copilotRequest);
+            return approveRequest(req, approveData, transaction).then(() => copilotRequest);
           }).then(copilotRequest => res.status(201).json(copilotRequest))
             .catch((err) => {
               try {

src/util.js

@@ -815,6 +815,54 @@ const projectServiceUtils = {
     }
   },
 
+  getRoleInfo: Promise.coroutine(function* (roleId, logger, requestId) { // eslint-disable-line func-names
+    try {
+      const token = yield this.getM2MToken();
+      const httpClient = this.getHttpClient({ id: requestId, log: logger });
+      httpClient.defaults.timeout = 6000;
+      logger.debug(`${config.identityServiceEndpoint}roles/${roleId}`, "fetching role info");
+      return httpClient.get(`${config.identityServiceEndpoint}roles/${roleId}`, {
+        params: {
+          fields: `subjects`,
+        },
+        headers: {
+          'Content-Type': 'application/json',
+          Authorization: `Bearer ${token}`,
+        },
+      }).then((res) => {
+        logger.debug(`Role info by ${roleId}: ${JSON.stringify(res.data.result.content)}`);
+        return _.get(res, 'data.result.content', []);
+      });
+    } catch (err) {
+      logger.debug(err, "error on getting role info");
+      return Promise.reject(err);
+    }
+  }),
+
+  getRolesByRoleName: Promise.coroutine(function* (roleName, logger, requestId) { // eslint-disable-line func-names
+    try {
+      const token = yield this.getM2MToken();
+      const httpClient = this.getHttpClient({ id: requestId, log: logger });
+      httpClient.defaults.timeout = 6000;
+      return httpClient.get(`${config.identityServiceEndpoint}roles`, {
+        params: {
+          filter: `roleName=${roleName}`,
+        },
+        headers: {
+          'Content-Type': 'application/json',
+          Authorization: `Bearer ${token}`,
+        },
+      }).then((res) => {
+        logger.debug(`Roles by ${roleName}: ${JSON.stringify(res.data.result.content)}`);
+        return _.get(res, 'data.result.content', [])
+          .filter(item => item.roleName === roleName)
+          .map(r => r.id);
+      });
+    } catch (err) {
+      return Promise.reject(err);
+    }
+  }),
+
   /**
    * Retrieve member details from userIds
    */