fix: get role by role name

Author: hentrymartin

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/routes/copilotRequest/approveRequest.service.js

@@ -1,8 +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) {
@@ -54,11 +56,31 @@ module.exports = (req, data, existingTransaction) => {
                   .create(data, { transaction });
               }))
               .then(async (opportunity) => {
-                console.log(opportunity);
                 const roles = await util.getRolesByRoleName('copilot', req.log, req.id);
-                const roleInfo = await util.getRoleInfo(roles[0], req.log, req.id);
-                console.log(roles, roleInfo, 'roles by copilot');
+                const { subjects = [] } = await util.getRoleInfo(roles[0], req.log, req.id);
+                req.log.info("getting subjects for roles", roles[0]);
+                const emailEventType = CONNECT_NOTIFICATION_EVENT.COPILOT_OPPORTUNITY_CREATED;
+                const copilotPortalUrl = config.get('copilotPortalUrl');
+                req.log.info("Sending emails to all copilots about new opportunity");
+                subjects.forEach(subject => {
+                  req.log.info("Each copilot members", subject);
+                  createEvent(emailEventType, {
+                    data: {
+                      handle: subject.handle,
+                      opportunityDetailsUrl: `${copilotPortalUrl}/opportunity/${opportunity.id}`,
+                    },
+                    recipients: [subject.email],
+                    version: 'v3',
+                    from: {
+                      name: config.get('EMAIL_INVITE_FROM_NAME'),
+                      email: config.get('EMAIL_INVITE_FROM_EMAIL'),
+                    },
+                    categories: [`${process.env.NODE_ENV}:${emailEventType}`.toLowerCase()],
+                  }, req.log);
+                });
 
+                req.log.info("Finished sending emails to copilots");
+                
                 return opportunity;
               })
               .catch((err) => {

src/util.js

@@ -850,7 +850,9 @@ const projectServiceUtils = {
         },
       }).then((res) => {
         logger.debug(`Roles by ${roleName}: ${JSON.stringify(res.data.result.content)}`);
-        return _.get(res, 'data.result.content', []).map(r => r.id);
+        return _.get(res, 'data.result.content', [])
+          .filter(item => item.roleName === roleName)
+          .map(r => r.id);
       });
     } catch (err) {
       return Promise.reject(err);