Merge pull request #78 from topcoder-platform/feature/topic-bus-key

Feature/topic bus key

Author: maxceem

config/test.js

@@ -8,5 +8,5 @@ module.exports = {
     ZAPIER_JOB_CANDIDATE_SWITCH: process.env.ZAPIER_JOB_CANDIDATE_SWITCH || 'ON'
   },
   // don't retry actions during tests because tests for now don't expect it and should be updated first
-  MAX_RETRY: 0,
+  MAX_RETRY: 0
 }

src/bootstrap.js

@@ -9,7 +9,7 @@ const allowedInterviewStatuses = _.values(Interview.Status)
 
 global.Promise = require('bluebird')
 
-Joi.rateType = () => Joi.string().valid('hourly', 'daily', 'weekly', 'monthly','annual')
+Joi.rateType = () => Joi.string().valid('hourly', 'daily', 'weekly', 'monthly', 'annual')
 Joi.jobStatus = () => Joi.string().valid('sourcing', 'in-review', 'assigned', 'closed', 'cancelled')
 Joi.resourceBookingStatus = () => Joi.string().valid('placed', 'closed', 'cancelled')
 Joi.jobCandidateStatus = () => Joi.string().valid('open', 'placed', 'selected', 'client rejected - screening', 'client rejected - interview', 'rejected - other', 'cancelled', 'interview', 'topcoder-rejected', 'applied', 'rejected-pre-screen', 'skills-test', 'skills-test', 'phone-screen', 'job-closed', 'offered')

src/services/InterviewProcessorService.js

@@ -56,6 +56,7 @@ processRequestInterview.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required(),
       xaiId: Joi.string().allow(null),
@@ -176,6 +177,7 @@ processBulkUpdateInterviews.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().pattern(
       Joi.string().uuid(), // key - jobCandidateId
       Joi.object().pattern(

src/services/JobCandidateProcessorService.js

@@ -91,7 +91,8 @@ processCreate.schema = {
       topic: Joi.string().required(),
       originator: Joi.string().required(),
       timestamp: Joi.date().required(),
-      "mime-type": Joi.string().required(),
+      'mime-type': Joi.string().required(),
+      key: Joi.string().allow(null),
       payload: Joi.object()
         .keys({
           id: Joi.string().uuid().required(),
@@ -106,11 +107,11 @@ processCreate.schema = {
           resume: Joi.string().uri().allow(null).allow(''),
           remark: Joi.string().allow(null).allow('')
         })
-        .required(),
+        .required()
     })
     .required(),
-  transactionId: Joi.string().required(),
-};
+  transactionId: Joi.string().required()
+}
 
 /**
  * Process update entity message
@@ -164,6 +165,7 @@ processDelete.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required()
     }).required()

src/services/JobProcessorService.js

@@ -65,6 +65,7 @@ processCreate.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required(),
       projectId: Joi.number().integer().required(),
@@ -142,6 +143,7 @@ processDelete.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required()
     }).required()

src/services/ResourceBookingProcessorService.js

@@ -32,6 +32,7 @@ processCreate.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required(),
       projectId: Joi.number().integer().required(),
@@ -94,6 +95,7 @@ processDelete.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required()
     }).required()

src/services/RoleProcessorService.js

@@ -32,6 +32,7 @@ processCreate.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required(),
       name: Joi.string().max(50).required(),
@@ -103,6 +104,7 @@ processDelete.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required()
     }).required()

src/services/WorkPeriodPaymentProcessorService.js

@@ -62,6 +62,7 @@ processCreate.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required(),
       workPeriodId: Joi.string().uuid().required(),

src/services/WorkPeriodProcessorService.js

@@ -228,6 +228,7 @@ processDelete.schema = {
     originator: Joi.string().required(),
     timestamp: Joi.date().required(),
     'mime-type': Joi.string().required(),
+    key: Joi.string().allow(null),
     payload: Joi.object().keys({
       id: Joi.string().uuid().required()
     }).required()