Feature/opty lead status sync with project (#50)

vikasrohit · web-flow · commit fa8f466150ea · 2020-02-27T11:42:57.000+05:30
* Reading new SFDC events to act appropriately

* Fixed case sensitivity of connect project id field

* V5 request format for projects api call

* Handling cancel reason for the cases where we have to cancel the project

* Handled the lead.qualified logic similar to opty.create

* Fixed the field to pick the correct disqualify reason for the lead
diff --git a/consumer/src/salesforce-worker.js b/consumer/src/salesforce-worker.js
@@ -23,20 +23,42 @@ export function consumeMessage(message) {
   debug('Got Connect_SFDC__e', message);
   const payload = _.get(message, 'payload');
   const eventType = _.get(payload, 'Type__c');
+  const original = JSON.parse(_.get(payload, 'Original__c'));
+  const updated = JSON.parse(_.get(payload, 'Updated__c'));
+  let statusToBe = null;
+  let statusChangeReason = null;
   if (eventType === 'billingAccount.updated') {
-    const original = JSON.parse(_.get(payload, 'Original__c'));
-    const updated = JSON.parse(_.get(payload, 'Updated__c'));
     const oldStatus = _.get(original, 'Active__c');
     const updatedStatus = _.get(updated, 'Active__c');
     debug(`${oldStatus} === ${updatedStatus}`);
     if (oldStatus !== updatedStatus && updatedStatus === true) {
-      const projectId = _.get(updated, 'TC_Connect_Project_ID__c');
-      debug(`Activating project with id ${projectId}`);
-      // TODO retrieve project id from the payload
-      if (projectId) {
-        ProjectService.activateProject(projectId);
-      }
+      statusToBe = 'active'
     }
+  } else if (eventType === 'opportunity.won') {
+    // TODO
+  } else if (eventType === 'opportunity.lost') {
+    // Cancel connect project
+    statusToBe = 'cancelled'
+    statusChangeReason = _.get(updated, 'Loss_Description__c', 'Opportunity Lost');
+  } else if (eventType === 'lead.disqualified') {
+    // Cancel the project
+    statusToBe = 'cancelled'
+    statusChangeReason = _.get(updated, 'Disqualified_Reason__c', 'Lead Disqualified');
+  } else if (eventType === 'opportunity.create') {
+    // Move to reviewed status
+    statusToBe = 'reviewed'
+  } else if (eventType === 'lead.qualified') {
+    // Move to reviewed status
+    statusToBe = 'reviewed'
+  }
+  let projectId = _.get(updated, 'TC_Connect_Project_ID__c');
+  if (!projectId) {
+    projectId = _.get(updated, 'TC_Connect_Project_Id__c');
+  }
+  debug(`Status to be updated: ${statusToBe} for project with id ${projectId}`);
+  if (statusToBe && projectId) {
+    debug(`Updating status to ${statusToBe} project with id ${projectId}`);
+    ProjectService.updateProjectStatus(projectId, statusToBe, statusChangeReason);
   }
 }
 
diff --git a/consumer/src/services/ProjectService.js b/consumer/src/services/ProjectService.js
@@ -6,6 +6,8 @@ const request = require('superagent');
 const config = require('config');
 const _ = require('lodash');
 
+const debug = require('debug')('app:project-service');
+
 /**
  * Get project details
  *
@@ -14,25 +16,22 @@ const _ = require('lodash');
  * @return {Promise}          promise resolved to project details
  */
 const getProject = (projectId) => {
-  console.log(`AUTH0_CLIENT_ID: ${config.AUTH0_CLIENT_ID.substring(0, 5)}`);
-  console.log(`AUTH0_CLIENT_SECRET: ${config.AUTH0_CLIENT_SECRET.substring(0, 5)}`);
-  console.log(`AUTH0_URL: ${config.AUTH0_URL}`);
-  console.log(`AUTH0_AUDIENCE: ${config.AUTH0_AUDIENCE}`);
-  console.log(`AUTH0_PROXY_SERVER_URL: ${config.AUTH0_PROXY_SERVER_URL}`);
+  debug(`AUTH0_CLIENT_ID: ${config.AUTH0_CLIENT_ID.substring(0, 5)}`);
+  debug(`AUTH0_CLIENT_SECRET: ${config.AUTH0_CLIENT_SECRET.substring(0, 5)}`);
   return M2m.getMachineToken(config.AUTH0_CLIENT_ID, config.AUTH0_CLIENT_SECRET)
     .then((token) => (
       request
         .get(`${config.projectApi.url}/projects/${projectId}`)
         .set('accept', 'application/json')
         .set('authorization', `Bearer ${token}`)
         .then((res) => {
-          if (!_.get(res, 'body.result.success')) {
+          if (res.status !== 200) {
             throw new Error(`Failed to get project details of project id: ${projectId}`);
           }
-          const project = _.get(res, 'body.result.content');
+          const project = _.get(res, 'body');
           return project;
         }).catch((err) => {
-          const errorDetails = _.get(err, 'response.body.result.content.message');
+          const errorDetails = _.get(err, 'response.body');
           throw new Error(
             `Failed to get project details of project id: ${projectId}.` +
             (errorDetails ? ' Server response: ' + errorDetails : '')
@@ -52,31 +51,32 @@ const getProject = (projectId) => {
  *
  * @return {Promise}          promise resolved to the updated project
  */
-const activateProject = (projectId) => {
-  console.log(`AUTH0_CLIENT_ID: ${config.AUTH0_CLIENT_ID.substring(0, 5)}`);
-  console.log(`AUTH0_CLIENT_SECRET: ${config.AUTH0_CLIENT_SECRET.substring(0, 5)}`);
-  console.log(`AUTH0_URL: ${config.AUTH0_URL}`);
-  console.log(`AUTH0_AUDIENCE: ${config.AUTH0_AUDIENCE}`);
-  console.log(`AUTH0_PROXY_SERVER_URL: ${config.AUTH0_PROXY_SERVER_URL}`);
+const updateProjectStatus = (projectId, status='active', changeReason) => {
+  debug(`AUTH0_CLIENT_ID: ${config.AUTH0_CLIENT_ID.substring(0, 5)}`);
+  debug(`AUTH0_CLIENT_SECRET: ${config.AUTH0_CLIENT_SECRET.substring(0, 5)}`);
+  const updatedProject = { status };
+  if (changeReason) {
+    updatedProject.cancelReason = changeReason;
+  }
   return M2m.getMachineToken(config.AUTH0_CLIENT_ID, config.AUTH0_CLIENT_SECRET)
     .then((token) => (
       request
         .patch(`${config.projectApi.url}/projects/${projectId}`)
         .set('accept', 'application/json')
         .set('Authorization', `Bearer ${token}`)
-        .send({ param : { status : 'active' } })
+        .send(updatedProject)
         .then((res) => {
-          if (!_.get(res, 'body.result.success')) {
-            throw new Error(`Failed to activate project with id: ${projectId}`);
+          if (res.status !== 200) {
+            throw new Error(`Failed to update project with id: ${projectId}`);
           }
-          const project = _.get(res, 'body.result.content');
+          const project = _.get(res, 'body');
           if (project) {
-            console.log(`Successfully activated the project with id ${projectId}`);
+            debug(`Successfully updated the project ${projectId} with status ${status}`);
           }
           return project;
         }).catch((err) => {
-          console.log(err);
-          const errorDetails = _.get(err, 'response.body.result.content.message');
+          debug(err);
+          const errorDetails = _.get(err, 'response.body');
           throw new Error(
             `Failed to update project with id: ${projectId}.` +
             (errorDetails ? ' Server response: ' + errorDetails : '')
@@ -91,5 +91,5 @@ const activateProject = (projectId) => {
 
 module.exports = {
   getProject,
-  activateProject
+  updateProjectStatus
 };
diff --git a/consumer/test/ProjectService.spec.js b/consumer/test/ProjectService.spec.js
@@ -31,22 +31,13 @@ const authenticateResponse = {
 };
 
 const getProjectResponse = {
-  id: '-88f3803:1557f8485b0:-b0a',
-  result: {
-    success: true,
-    status: 200,
-    metadata: null,
-    content: {
-      id: '265522',
-      modifiedBy: null,
-      modifiedAt: '2016-06-01T16:57:47.000Z',
-      createdBy: null,
-      createdAt: '2002-02-06T18:06:40.000Z',
-      status: 'active',
-      name: 'Test Project',
-    },
-  },
-  version: 'v4',
+    id: '265522',
+    modifiedBy: null,
+    modifiedAt: '2016-06-01T16:57:47.000Z',
+    createdBy: null,
+    createdAt: '2002-02-06T18:06:40.000Z',
+    status: 'active',
+    name: 'Test Project',
 };
 
 
@@ -80,8 +71,8 @@ describe('ProjectService', () => {
         })
         .get('/projects/1234')
         .reply(200, getProjectResponse);
-      const user = await ProjectService.getProject(1234);
-      expect(user).to.deep.equal(getProjectResponse.result.content);
+      const project = await ProjectService.getProject(1234);
+      expect(project).to.deep.equal(getProjectResponse);
       fakeHttp.done();
     });
 
@@ -93,8 +84,9 @@ describe('ProjectService', () => {
         })
         .patch('/projects/1234')
         .reply(200, getProjectResponse);
-      const user = await ProjectService.activateProject(1234);
-      expect(user).to.deep.equal(getProjectResponse.result.content);
+      const project = await ProjectService.updateProjectStatus(1234);
+      console.log(project, 'project')
+      expect(project).to.deep.equal(getProjectResponse);
       fakeHttp.done();
     });
   });
diff --git a/consumer/test/salesforce-worker.spec.js b/consumer/test/salesforce-worker.spec.js
@@ -14,9 +14,9 @@ describe('salesforce-worker', () => {
     }
   }
   describe('consumeMessage', () => {
-    let activateProjectSpy;
+    let updateProjectStatusSpy;
     beforeEach(() => {
-        activateProjectSpy = ProjectService.activateProject = sinon.spy();
+        updateProjectStatusSpy = ProjectService.updateProjectStatus = sinon.spy();
     });
 
     /**
@@ -29,7 +29,7 @@ describe('salesforce-worker', () => {
 
     it('should consume and active project successfully', (done) => {
       invokeConsume(done);
-      activateProjectSpy.should.have.been.calledWith(1234);
+      updateProjectStatusSpy.should.have.been.calledWith(1234);
       done();
     });
   });
