feat: disable es update topic

Author: 朱龚

src/app.js

@@ -13,9 +13,9 @@ const JobProcessorService = require('./services/JobProcessorService')
 const JobCandidateProcessorService = require('./services/JobCandidateProcessorService')
 // const ResourceBookingProcessorService = require('./services/ResourceBookingProcessorService')
 // const WorkPeriodProcessorService = require('./services/WorkPeriodProcessorService')
-const InterviewProcessorService = require('./services/InterviewProcessorService')
+// const InterviewProcessorService = require('./services/InterviewProcessorService')
 // const WorkPeriodPaymentProcessorService = require('./services/WorkPeriodPaymentProcessorService')
-const RoleProcessorService = require('./services/RoleProcessorService')
+// const RoleProcessorService = require('./services/RoleProcessorService')
 const ActionProcessorService = require('./services/ActionProcessorService')
 const Mutex = require('async-mutex').Mutex
 const events = require('events')
@@ -34,11 +34,11 @@ const topicServiceMapping = {
   // job
   [config.topics.TAAS_JOB_CREATE_TOPIC]: JobProcessorService.processCreate,
   [config.topics.TAAS_JOB_UPDATE_TOPIC]: JobProcessorService.processUpdate,
-  [config.topics.TAAS_JOB_DELETE_TOPIC]: JobProcessorService.processDelete,
+  // [config.topics.TAAS_JOB_DELETE_TOPIC]: JobProcessorService.processDelete,
   // job candidate
-  [config.topics.TAAS_JOB_CANDIDATE_CREATE_TOPIC]: JobCandidateProcessorService.processCreate,
+  // [config.topics.TAAS_JOB_CANDIDATE_CREATE_TOPIC]: JobCandidateProcessorService.processCreate,
   [config.topics.TAAS_JOB_CANDIDATE_UPDATE_TOPIC]: JobCandidateProcessorService.processUpdate,
-  [config.topics.TAAS_JOB_CANDIDATE_DELETE_TOPIC]: JobCandidateProcessorService.processDelete,
+  // [config.topics.TAAS_JOB_CANDIDATE_DELETE_TOPIC]: JobCandidateProcessorService.processDelete,
   // resource booking
   // [config.topics.TAAS_RESOURCE_BOOKING_CREATE_TOPIC]: ResourceBookingProcessorService.processCreate,
   // [config.topics.TAAS_RESOURCE_BOOKING_UPDATE_TOPIC]: ResourceBookingProcessorService.processUpdate,
@@ -51,13 +51,13 @@ const topicServiceMapping = {
   // [config.topics.TAAS_WORK_PERIOD_PAYMENT_CREATE_TOPIC]: WorkPeriodPaymentProcessorService.processCreate,
   // [config.topics.TAAS_WORK_PERIOD_PAYMENT_UPDATE_TOPIC]: WorkPeriodPaymentProcessorService.processUpdate,
   // interview
-  [config.topics.TAAS_INTERVIEW_REQUEST_TOPIC]: InterviewProcessorService.processRequestInterview,
-  [config.topics.TAAS_INTERVIEW_UPDATE_TOPIC]: InterviewProcessorService.processUpdateInterview,
-  [config.topics.TAAS_INTERVIEW_BULK_UPDATE_TOPIC]: InterviewProcessorService.processBulkUpdateInterviews,
+  // [config.topics.TAAS_INTERVIEW_REQUEST_TOPIC]: InterviewProcessorService.processRequestInterview,
+  // [config.topics.TAAS_INTERVIEW_UPDATE_TOPIC]: InterviewProcessorService.processUpdateInterview,
+  // [config.topics.TAAS_INTERVIEW_BULK_UPDATE_TOPIC]: InterviewProcessorService.processBulkUpdateInterviews,
   // role
-  [config.topics.TAAS_ROLE_CREATE_TOPIC]: RoleProcessorService.processCreate,
-  [config.topics.TAAS_ROLE_UPDATE_TOPIC]: RoleProcessorService.processUpdate,
-  [config.topics.TAAS_ROLE_DELETE_TOPIC]: RoleProcessorService.processDelete,
+  // [config.topics.TAAS_ROLE_CREATE_TOPIC]: RoleProcessorService.processCreate,
+  // [config.topics.TAAS_ROLE_UPDATE_TOPIC]: RoleProcessorService.processUpdate,
+  // [config.topics.TAAS_ROLE_DELETE_TOPIC]: RoleProcessorService.processDelete,
   // action
   [config.topics.TAAS_ACTION_RETRY_TOPIC]: ActionProcessorService.processRetry
 }

src/services/JobCandidateProcessorService.js

@@ -126,15 +126,15 @@ async function processUpdate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
     id: data.id
   })
-  await esClient.updateExtra({
-    index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
-    id: data.id,
-    transactionId,
-    body: {
-      doc: data
-    },
-    refresh: constants.esRefreshOption
-  })
+  // await esClient.updateExtra({
+  //   index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
+  //   id: data.id,
+  //   transactionId,
+  //   body: {
+  //     doc: data
+  //   },
+  //   refresh: constants.esRefreshOption
+  // })
   await postMessageToZapier({
     type: constants.Zapier.MessageType.JobCandidateUpdate,
     payload: data,
@@ -174,9 +174,9 @@ processDelete.schema = {
 }
 
 module.exports = {
-  processCreate,
-  processUpdate,
-  processDelete
+  // processCreate,
+  processUpdate
+  // processDelete
 }
 
 logger.buildService(module.exports, 'JobCandidateProcessorService')

src/services/JobProcessorService.js

@@ -46,13 +46,13 @@ async function postMessageToZapier ({ type, payload }) {
  */
 async function processCreate (message, transactionId) {
   const job = message.payload
-  await esClient.createExtra({
-    index: config.get('esConfig.ES_INDEX_JOB'),
-    id: job.id,
-    transactionId,
-    body: job,
-    refresh: constants.esRefreshOption
-  })
+  // await esClient.createExtra({
+  //   index: config.get('esConfig.ES_INDEX_JOB'),
+  //   id: job.id,
+  //   transactionId,
+  //   body: job,
+  //   refresh: constants.esRefreshOption
+  // })
   await postMessageToZapier({
     type: constants.Zapier.MessageType.JobCreate,
     payload: job
@@ -110,15 +110,15 @@ processCreate.schema = {
  */
 async function processUpdate (message, transactionId) {
   const data = message.payload
-  await esClient.updateExtra({
-    index: config.get('esConfig.ES_INDEX_JOB'),
-    id: data.id,
-    transactionId,
-    body: {
-      doc: data
-    },
-    refresh: constants.esRefreshOption
-  })
+  // await esClient.updateExtra({
+  //   index: config.get('esConfig.ES_INDEX_JOB'),
+  //   id: data.id,
+  //   transactionId,
+  //   body: {
+  //     doc: data
+  //   },
+  //   refresh: constants.esRefreshOption
+  // })
   await postMessageToZapier({
     type: constants.Zapier.MessageType.JobUpdate,
     payload: data