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']
       - deployProd:
           context : org-global
           filters:

migrations/umzug/migrations/20250521211708-copilot_invite_from_application.js

@@ -0,0 +1,18 @@
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    await queryInterface.addColumn('project_member_invites', 'applicationId', {
+      type: Sequelize.BIGINT,
+      allowNull: true,
+      references: {
+        model: 'copilot_applications',
+        key: 'id',
+      },
+      onUpdate: 'CASCADE',
+      onDelete: 'SET NULL',
+    });
+  },
+
+  down: async (queryInterface) => {
+    await queryInterface.removeColumn('project_member_invites', 'applicationId');
+  },
+};

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,20 +75,80 @@ module.exports = [
         throw err;
       }
 
-      await models.CopilotRequest.update(
-        { status: COPILOT_REQUEST_STATUS.FULFILLED },
-        { where: { id: opportunity.copilotRequestId }, transaction: t },
-      );
+      const project = await models.Project.findOne({
+        where: {
+          id: projectId,
+        },
+      });
+
+      const existingInvite = await models.ProjectMemberInvite.findAll({
+        where: {
+          userId,
+          projectId,
+          role: PROJECT_MEMBER_ROLE.COPILOT,
+          status: INVITE_STATUS.PENDING,
+        },
+      });
+
+      if (existingInvite) {
+        const err = new Error(`User already has an pending invite to the project`);
+        err.status = 400;
+        throw err;
+      }
+
+      const applicationUser = await util.getMemberDetailsByUserIds([userId], req.log, req.id);
+
+      const invite = await models.ProjectMemberInvite.create({
+        status: INVITE_STATUS.PENDING,
+        role: PROJECT_MEMBER_ROLE.COPILOT,
+        userId,
+        projectId,
+        email: applicationUser[0].email,
+        createdBy: req.authUser.userId,
+        createdAt: new Date(),
+        updatedBy: req.authUser.userId,
+        updatedAt: new Date(),
+      }, {
+        transaction: t,
+      })
+
+      util.sendResourceToKafkaBus(
+        req,
+        EVENT.ROUTING_KEY.PROJECT_MEMBER_INVITE_CREATED,
+        RESOURCES.PROJECT_MEMBER_INVITE,
+        invite.toJSON());
 
-      await opportunity.update(
-        { status: COPILOT_OPPORTUNITY_STATUS.COMPLETED },
-        { transaction: t },
-      );
+      const authUserDetails = await util.getMemberDetailsByUserIds([req.authUser.userId], req.log, req.id);
 
-      await models.CopilotApplication.update(
-        { status: COPILOT_APPLICATION_STATUS.ACCEPTED },
-        { where: { id: applicationId }, transaction: t },
-      );
+      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: authUserDetails[0],
+                isSSO: util.isSSO(project),
+              },
+            ],
+          }],
+        },
+        recipients: [applicationUser[0].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);
 
       res.status(200).send({ id: applicationId });
     }).catch(err => next(err));

src/routes/projectMemberInvites/update.js

@@ -119,7 +119,9 @@ module.exports = [
                   };
                   return util
                     .addUserToProject(req, member)
-                    .then(() => res.json(util.postProcessInvites('$.email', updatedInvite, req)))
+                    .then(async () => {
+                      return res.json(util.postProcessInvites('$.email', updatedInvite, req))
+                    })
                     .catch(err => next(err));
                 });
             }