part2

Author: xxcxy

README.md

@@ -34,6 +34,7 @@ The following parameters can be set in config files or in env variables:
 - `topics.TAAS_WORK_PERIOD_UPDATE_TOPIC`: the update work period entity Kafka message topic
 - `topics.TAAS_WORK_PERIOD_DELETE_TOPIC`: the delete work period entity Kafka message topic
 - `topics.TAAS_INTERVIEW_REQUEST_TOPIC`: the request interview entity Kafka message topic
+- `topics.TAAS_INTERVIEW_UPDATE_TOPIC`: the update interview entity Kafka message topic
 - `esConfig.HOST`: Elasticsearch host
 - `esConfig.AWS_REGION`: The Amazon region to use when using AWS Elasticsearch service
 - `esConfig.ELASTICCLOUD.id`: The elastic cloud id, if your elasticsearch instance is hosted on elastic cloud. DO NOT provide a value for ES_HOST if you are using this

config/default.js

@@ -33,7 +33,8 @@ module.exports = {
     TAAS_WORK_PERIOD_UPDATE_TOPIC: process.env.TAAS_WORK_PERIOD_UPDATE_TOPIC || 'taas.workperiod.update',
     TAAS_WORK_PERIOD_DELETE_TOPIC: process.env.TAAS_WORK_PERIOD_DELETE_TOPIC || 'taas.workperiod.delete',
     // topics for interview service
-    TAAS_INTERVIEW_REQUEST_TOPIC: process.env.TAAS_INTERVIEW_REQUEST_TOPIC || 'taas.interview.request'
+    TAAS_INTERVIEW_REQUEST_TOPIC: process.env.TAAS_INTERVIEW_REQUEST_TOPIC || 'taas.interview.requested',
+    TAAS_INTERVIEW_UPDATE_TOPIC: process.env.TAAS_INTERVIEW_UPDATE_TOPIC || 'taas.interview.update'
   },
 
   esConfig: {

local/docker-compose.yml

@@ -12,7 +12,7 @@ services:
       - "9092:9092"
     environment:
       KAFKA_ADVERTISED_HOST_NAME: localhost
-      KAFKA_CREATE_TOPICS: "taas.job.create:1:1,taas.jobcandidate.create:1:1,taas.resourcebooking.create:1:1,taas.interview.request:1:1,taas.job.update:1:1,taas.jobcandidate.update:1:1,taas.resourcebooking.update:1:1,taas.job.delete:1:1,taas.jobcandidate.delete:1:1,taas.resourcebooking.delete:1:1"
+      KAFKA_CREATE_TOPICS: "taas.job.create:1:1,taas.jobcandidate.create:1:1,taas.resourcebooking.create:1:1,taas.interview.requested:1:1,taas.interview.update:1:1,taas.job.update:1:1,taas.jobcandidate.update:1:1,taas.resourcebooking.update:1:1,taas.job.delete:1:1,taas.jobcandidate.delete:1:1,taas.resourcebooking.delete:1:1"
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
   esearch:
     image: elasticsearch:7.7.1

src/app.js

@@ -46,7 +46,8 @@ const topicServiceMapping = {
   [config.topics.TAAS_WORK_PERIOD_UPDATE_TOPIC]: WorkPeriodProcessorService.processUpdate,
   [config.topics.TAAS_WORK_PERIOD_DELETE_TOPIC]: WorkPeriodProcessorService.processDelete,
   // interview
-  [config.topics.TAAS_INTERVIEW_REQUEST_TOPIC]: InterviewProcessorService.processRequestInterview
+  [config.topics.TAAS_INTERVIEW_REQUEST_TOPIC]: InterviewProcessorService.processRequestInterview,
+  [config.topics.TAAS_INTERVIEW_UPDATE_TOPIC]: InterviewProcessorService.processUpdateInterview
 }
 
 // Start kafka consumer

src/common/constants.js

@@ -19,7 +19,12 @@ module.exports = {
   },
   Interview: {
     Status: {
-      Requested: 'Requested'
+      Scheduling: 'Scheduling',
+      Scheduled: 'Scheduled',
+      RequestedForReschedule: 'Requested for reschedule',
+      Rescheduled: 'Rescheduled',
+      Completed: 'Completed',
+      Cancelled: 'Cancelled'
     }
   }
 }

src/scripts/createIndex.js

@@ -52,6 +52,8 @@ async function createIndex () {
                 id: { type: 'keyword' },
                 jobCandidateId: { type: 'keyword' },
                 googleCalendarId: { type: 'keyword' },
+                startTimestamp: { type: 'date' },
+                attendeesList: { type: 'keyword' },
                 customMessage: { type: 'text' },
                 xaiTemplate: { type: 'keyword' },
                 round: { type: 'integer' },

src/services/InterviewProcessorService.js

@@ -2,6 +2,7 @@
  * Interview Processor Service
  */
 
+const _ = require('lodash')
 const Joi = require('@hapi/joi')
 const logger = require('../common/logger')
 const helper = require('../common/helper')
@@ -66,14 +67,74 @@ processRequestInterview.schema = {
       createdAt: Joi.date().required(),
       createdBy: Joi.string().uuid().required(),
       updatedAt: Joi.date().allow(null),
-      updatedBy: Joi.string().uuid().allow(null)
+      updatedBy: Joi.string().uuid().allow(null),
+      attendeesList: Joi.array().items(Joi.string().email()).allow(null),
+      startTimestamp: Joi.date().allow(null)
+    }).required()
+  }).required(),
+  transactionId: Joi.string().required()
+}
+
+/**
+ * Process update interview entity message.
+ * Update an interview record under jobCandidate.
+ *
+ * @param {Object} message the kafka message
+ * @param {String} transactionId
+ */
+async function processUpdateInterview (message, transactionId) {
+  const data = message.payload
+  const { body: jobCandidate } = await esClient.getExtra({
+    index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
+    id: data.jobCandidateId
+  })
+  const interviews = jobCandidate.interviews || []
+  const index = _.findIndex(interviews, ['id', data.id])
+  if (index === -1) {
+    interviews.push(data)
+  } else {
+    interviews.splice(index, 1, data)
+  }
+  jobCandidate.interviews = interviews
+  await esClient.updateExtra({
+    index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
+    id: data.jobCandidateId,
+    transactionId,
+    body: {
+      doc: jobCandidate
+    },
+    refresh: constants.esRefreshOption
+  })
+}
+
+processUpdateInterview.schema = {
+  message: Joi.object().keys({
+    topic: Joi.string().required(),
+    originator: Joi.string().required(),
+    timestamp: Joi.date().required(),
+    'mime-type': Joi.string().required(),
+    payload: Joi.object().keys({
+      id: Joi.string().uuid().required(),
+      jobCandidateId: Joi.string().uuid().required(),
+      googleCalendarId: Joi.string().allow(null),
+      customMessage: Joi.string().allow(null),
+      xaiTemplate: Joi.string().required(),
+      round: Joi.number().integer().positive().required(),
+      status: Joi.interviewStatus().required(),
+      createdAt: Joi.date().required(),
+      createdBy: Joi.string().uuid().required(),
+      updatedAt: Joi.date().required(),
+      updatedBy: Joi.string().uuid().required(),
+      attendeesList: Joi.array().items(Joi.string().email()).allow(null),
+      startTimestamp: Joi.date().allow(null)
     }).required()
   }).required(),
   transactionId: Joi.string().required()
 }
 
 module.exports = {
-  processRequestInterview
+  processRequestInterview,
+  processUpdateInterview
 }
 
 logger.buildService(module.exports, 'InterviewProcessorService')