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:

src/constants.js

@@ -301,6 +301,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',
+
+  // Copilot events
+  COPILOT_OPPORTUNITY_CREATED: 'connect.notification.project.copilot.opportunity.created',
 };
 
 export const REGEX = {

src/routes/copilotRequest/approveRequest.service.js

@@ -2,6 +2,7 @@ import _ from 'lodash';
 
 import models from '../../models';
 import { COPILOT_REQUEST_STATUS } from '../../constants';
+import util from '../../util';
 
 const resolveTransaction = (transaction, callback) => {
   if (transaction) {
@@ -52,6 +53,14 @@ module.exports = (data, existingTransaction) => {
                 return models.CopilotOpportunity
                   .create(data, { transaction });
               }))
+              .then(async (opportunity) => {
+                console.log(opportunity);
+                const roles = await util.getRolesByRoleName('copilot');
+                const roleInfo = await util.getRoleInfo(roles[0]);
+                console.log(roles, roleInfo, 'roles by copilot');
+
+                return opportunity;
+              })
               .catch((err) => {
                 transaction.rollback();
                 return Promise.reject(err);

src/util.js

@@ -815,6 +815,48 @@ 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 });
+      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) {
+      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 });
+      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', []).map(r => r.id);
+      });
+    } catch (err) {
+      return Promise.reject(err);
+    }
+  }),
+
   /**
    * Retrieve member details from userIds
    */