fix(PM-1169) Cancel all copilot requests when copilot added via WM

.circleci/config.yml

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

src/routes/projectMemberInvites/update.js

@@ -1,12 +1,14 @@
 import validate from 'express-validation';
 import _ from 'lodash';
 import Joi from 'joi';
+import { Op } from 'sequelize';
 import { middleware as tcMiddleware } from 'tc-core-library-js';
 import models from '../../models';
 import util from '../../util';
 import { INVITE_STATUS, EVENT, RESOURCES, COPILOT_APPLICATION_STATUS, COPILOT_OPPORTUNITY_STATUS, COPILOT_REQUEST_STATUS, INVITE_SOURCE } from '../../constants';
 import { PERMISSION } from '../../permissions/constants';
 
+
 /**
  * API to update invite member to project.
  *
@@ -170,6 +172,67 @@ module.exports = [
                       }, {
                         transaction: t,
                       });
+                    } else if (source === INVITE_SOURCE.WORK_MANAGER) {
+                      req.log.info("cancelling all existing requests", source);
+                      const allCopilotRequestsByProjectId = await models.CopilotRequest.findAll({
+                        where: {
+                          projectId: invite.projectId,
+                        },
+                        transaction: t,
+                      });
+
+                      const requestIds = allCopilotRequestsByProjectId.map(item => item.id);
+                      req.log.info("requestIds", requestIds);
+
+                      await models.CopilotRequest.update({
+                        status: COPILOT_REQUEST_STATUS.CANCELED,
+                      }, {
+                        where: {
+                          id: {
+                            [Op.in]: requestIds,
+                          }
+                        },
+                        transaction: t,
+                      });
+
+                      req.log.info("updated copilot request");
+
+                      const allCopilotOpportunityByRequestIds = await models.CopilotOpportunity.findAll({
+                        where: {
+                          copilotRequestId: {
+                            [Op.in]: requestIds,
+                          },
+                        },
+                        transaction: t,
+                      });
+
+                      req.log.info("allCopilotOpportunityByRequestIds", allCopilotOpportunityByRequestIds.length);
+
+                      await models.CopilotOpportunity.update({
+                        status: COPILOT_OPPORTUNITY_STATUS.CANCELED,
+                      }, {
+                        where: {
+                          copilotRequestId: {
+                            [Op.in]: allCopilotOpportunityByRequestIds,
+                          },
+                        },
+                        transaction: t,
+                      });
+
+                      req.log.info("updated copilot opportunity");
+
+                      await models.CopilotApplication.update({
+                        status: COPILOT_APPLICATION_STATUS.CANCELED,
+                      }, {
+                        where: {
+                          opportunityId: {
+                            [Op.in]: allCopilotOpportunityByRequestIds.map(item => item.id),
+                          },
+                        },
+                        transaction: t,
+                      });
+
+                      req.log.info("updated CopilotApplication");
                     }
 
                     await t.commit();