fix(PM-1510): added existing membership to the copilot application

src/routes/copilotOpportunity/assign.js

@@ -45,11 +45,17 @@ module.exports = [
         throw err;
       }
 
+      const copilotRequest = await models.CopilotRequest.findOne({
+        where: { id: opportunity.copilotRequestId },
+        transaction: t,
+      });
+
       const application = await models.CopilotApplication.findOne({
         where: { id: applicationId, opportunityId: copilotOpportunityId },
         transaction: t,
       });
 
+
       if (!application) {
         const err = new Error('No such application available');
         err.status = 400;
@@ -65,12 +71,72 @@ module.exports = [
       const projectId = opportunity.projectId;
       const userId = application.userId;
       const activeMembers = await models.ProjectMember.getActiveProjectMembers(projectId, t);
-
-      const existingUser = activeMembers.find(item => item.userId === userId);
-      if (existingUser && existingUser.role === 'copilot') {
-        const err = new Error(`User is already a copilot of this project`);
-        err.status = 400;
-        throw err;
+      const updateCopilotOpportunity = async () => {
+        await opportunity.update({
+          status: COPILOT_OPPORTUNITY_STATUS.COMPLETED,
+        }, {
+          transaction: t,
+        });
+        await application.update({
+          status: COPILOT_APPLICATION_STATUS.ACCEPTED,
+        }, {
+          transaction: t,
+        });
+
+        await copilotRequest.update({
+          status: COPILOT_REQUEST_STATUS.FULFILLED,
+        }, {
+          transaction: t,
+        });
+
+        await models.CopilotApplication.update({
+          status: COPILOT_APPLICATION_STATUS.CANCELED,
+        }, {
+          where: {
+            projectId,
+            opportunityId: opportunity.id,
+            id: {
+              $ne: application.id,
+            },
+          }
+        });
+      };
+
+      const existingMember = activeMembers.find(item => item.userId === userId);
+      if (existingMember) {
+        req.log.debug(`User already part of project: ${JSON.stringify(existingMember)}`);
+        if (['copilot', 'manager'].includes(existingMember.role)) {
+          req.log.debug(`User is a copilot or manager`);
+          updateCopilotOpportunity();
+        } else {
+          req.log.debug(`User has read/write role`);
+          await models.ProjectMember.update({
+            role: 'copilot',
+          }, {
+            where: {
+              id: existingMember.id,
+            },
+          });
+
+          const projectMember = await models.ProjectMember.findOne({
+            where: {
+              id: existingMember.id,
+            },
+          });
+
+          req.log.debug(`Updated project member: ${JSON.stringify(projectMember.get({plain: true}))}`);
+
+          util.sendResourceToKafkaBus(
+            req,
+            EVENT.ROUTING_KEY.PROJECT_MEMBER_UPDATED,
+            RESOURCES.PROJECT_MEMBER,
+            projectMember.get({ plain: true }),
+            existingMember);
+          req.log.debug(`Member updated in kafka`);
+          updateCopilotOpportunity();
+        }
+        res.status(200).send({ id: applicationId });
+        return;
       }
 
       const existingInvite = await models.ProjectMemberInvite.findAll({

src/routes/copilotOpportunityApply/list.js

@@ -31,19 +31,48 @@ module.exports = [
     canAccessAllApplications ? {} : { createdBy: userId },
     );
 
-    return models.CopilotApplication.findAll({
-      where: whereCondition,
-      include: [
-        {
-          model: models.CopilotOpportunity,
-          as: 'copilotOpportunity',
-        },
-      ],
-      order: [[sortParams[0], sortParams[1]]],
+    return models.CopilotOpportunity.findOne({
+      where: {
+        id: opportunityId,
+      }
+    }).then((opportunity) => {
+      if (!opportunity) {
+        const err = new Error('No opportunity found');
+        err.status = 404;
+        throw err;
+      }
+      return models.CopilotApplication.findAll({
+        where: whereCondition,
+        include: [
+          {
+            model: models.CopilotOpportunity,
+            as: 'copilotOpportunity',
+          },
+        ],
+        order: [[sortParams[0], sortParams[1]]],
+      })
+        .then(copilotApplications => {
+          req.log.debug(`CopilotApplications ${JSON.stringify(copilotApplications)}`);
+          return models.ProjectMember.getActiveProjectMembers(opportunity.projectId).then((members) => {
+            req.log.debug(`Fetched existing active members ${JSON.stringify(members)}`);
+            req.log.debug(`Applications ${JSON.stringify(copilotApplications)}`);
+            const enrichedApplications = copilotApplications.map(application => {
+              const m = members.find(m => m.userId === application.userId);
+              req.log.debug(`Existing member to application ${JSON.stringify(Object.assign({}, application, {
+                existingMembership: m,
+              }))}`);
+              return Object.assign({}, application, {
+                existingMembership: m,
+              });
+            });
+
+            req.log.debug(`Enriched Applications ${JSON.stringify(enrichedApplications)}`);
+            res.status(200).send(enrichedApplications);
+          });
+        })
     })
-      .then(copilotApplications => res.json(copilotApplications))
-      .catch((err) => {
-        util.handleError('Error fetching copilot applications', err, req, next);
-      });
+    .catch((err) => {
+      util.handleError('Error fetching copilot applications', err, req, next);
+    });
   },
 ];