fix(PM-1168): invite user when assigning as copilot

.circleci/config.yml

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

src/routes/copilotOpportunity/assign.js

@@ -1,11 +1,13 @@
 import _ from 'lodash';
 import validate from 'express-validation';
 import Joi from 'joi';
+import config from 'config';
 
 import models from '../../models';
 import util from '../../util';
 import { PERMISSION } from '../../permissions/constants';
-import { COPILOT_APPLICATION_STATUS, COPILOT_OPPORTUNITY_STATUS, COPILOT_REQUEST_STATUS } from '../../constants';
+import { createEvent } from '../../services/busApi';
+import { CONNECT_NOTIFICATION_EVENT, COPILOT_APPLICATION_STATUS, COPILOT_OPPORTUNITY_STATUS, COPILOT_REQUEST_STATUS, EVENT, INVITE_STATUS, PROJECT_MEMBER_ROLE, RESOURCES } from '../../constants';
 
 const assignCopilotOpportunityValidations = {
   body: Joi.object().keys({
@@ -73,6 +75,63 @@ module.exports = [
         throw err;
       }
 
+      const project = await models.Project.findOne({
+        where: {
+          id: projectId,
+        },
+      });
+
+      const applicationUser = await util.getMemberDetailsByUserIds([userId], req.log, req.id)[0];
+
+      req.log.info("before create", applicationUser)
+
+      const invite = await models.ProjectMemberInvite.create({
+        status: INVITE_STATUS.PENDING,
+        role: PROJECT_MEMBER_ROLE.COPILOT,
+        userId,
+        email: applicationUser.email,
+      })
+
+      req.log.info("aftr create", invite)
+
+      util.sendResourceToKafkaBus(
+        req,
+        EVENT.ROUTING_KEY.PROJECT_MEMBER_INVITE_CREATED,
+        RESOURCES.PROJECT_MEMBER_INVITE,
+        invite.toJSON());
+
+      const initiator = await util.getMemberDetailsByUserIds([req.authUser.userId], req.log, req.id);
+
+      const emailEventType = CONNECT_NOTIFICATION_EVENT.PROJECT_MEMBER_EMAIL_INVITE_CREATED;
+      await createEvent(emailEventType, {
+        data: {
+          workManagerUrl: config.get('workManagerUrl'),
+          accountsAppURL: config.get('accountsAppUrl'),
+          subject: config.get('inviteEmailSubject'),
+          projects: [{
+            name: project.name,
+            projectId,
+            sections: [
+              {
+                EMAIL_INVITES: true,
+                title: config.get('inviteEmailSectionTitle'),
+                projectName: project.name,
+                projectId,
+                initiator,
+                isSSO: util.isSSO(project),
+              },
+            ],
+          }],
+        },
+        recipients: [applicationUser.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);
+
       await models.CopilotRequest.update(
         { status: COPILOT_REQUEST_STATUS.FULFILLED },
         { where: { id: opportunity.copilotRequestId }, transaction: t },