feat: use "project.action." prefix for Kafka events

maxceem · maxceem · commit b6505bfb7c82 · 2019-12-18T17:49:16.000+08:00
diff --git a/ReadMe.md b/ReadMe.md
@@ -3,7 +3,7 @@
 ## Dependencies
 
 - nodejs https://nodejs.org/en/ (v8)
-- Kafka 
+- Kafka
 - Informix
 - Postgres
 - Docker, Docker Compose
@@ -21,9 +21,9 @@ The following parameters can be set in config files or in env variables:
     if not provided, then SSL connection is not used, direct insecure connection is used;
     if provided, it can be either path to private key file or private key content
 - KAFKA_GROUP_ID: the Kafka group id, default value is 'legacy-project-processor'
-- CREATE_PROJECT_TOPIC: create project Kafka topic, default value is 'project.notification.create'
-- UPDATE_PROJECT_TOPIC: update project Kafka topic, default value is 'project.notification.update'
-- DELETE_PROJECT_TOPIC: delete project member Kafka topic, default value is 'project.notification.delete'
+- CREATE_PROJECT_TOPIC: create project Kafka topic, default value is 'project.action.create'
+- UPDATE_PROJECT_TOPIC: update project Kafka topic, default value is 'project.action.update'
+- DELETE_PROJECT_TOPIC: delete project member Kafka topic, default value is 'project.action.delete'
 - INFORMIX: Informix database configuration parameters, refer `config/default.js` for more information
 - POSTGRES: Postgres database configuration parameters, refer `config/default.js` for more information
 
@@ -47,20 +47,20 @@ Configuration for the tests is at `config/test.js`, only add such new configurat
   `bin/kafka-server-start.sh config/server.properties`
 - note that the zookeeper server is at localhost:2181, and Kafka server is at localhost:9092
 - use another terminal, go to same directory, create the needed topics:
-  `bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project.notification.create`
+  `bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project.action.create`
 
-  `bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project.notification.update`
+  `bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project.action.update`
 
-  `bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project.notification.delete`
+  `bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project.action.delete`
 
 - verify that the topics are created:
   `bin/kafka-topics.sh --list --zookeeper localhost:2181`,
   it should list out the created topics
-- run the producer and then write some message into the console to send to the `project.notification.create` topic:
+- run the producer and then write some message into the console to send to the `project.action.create` topic:
   in the console, write message, one message per line:
-  `{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1000, "name": "Develop website", "description": "<h>Test</h><p>This is description</p>", "type": "Develop website", "directProjectId": null, "billingAccountId": 70015983,  "type": "Web Application", "createdBy": 8547899 } }`
+  `{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1000, "name": "Develop website", "description": "<h>Test</h><p>This is description</p>", "type": "Develop website", "directProjectId": null, "billingAccountId": 70015983,  "type": "Web Application", "createdBy": 8547899 } }`
 - optionally, use another terminal, go to same directory, start a consumer to view the messages:
-  `bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic project.notification.create --from-beginning`
+  `bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic project.action.create --from-beginning`
 - writing/reading messages to/from other topics are similar
 
 ## Topcoder Informix Database Setup
diff --git a/Verification.md b/Verification.md
@@ -15,45 +15,45 @@ npm run test-data
 ```
 
 ## Verification
-1. start kafka-console-producer to write messages to `project.notification.create` topic:
-  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.create`
+1. start kafka-console-producer to write messages to `project.action.create` topic:
+  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.action.create`
 2. write message:
-  `{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1000, "name": "Develop website", "description": "<h>Test</h><p>This is description</p>", "directProjectId": null, "billingAccountId": 70015983,  "type": "Web Application", "createdBy": 132458 } }`
+  `{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1000, "name": "Develop website", "description": "<h>Test</h><p>This is description</p>", "directProjectId": null, "billingAccountId": 70015983,  "type": "Web Application", "createdBy": 132458 } }`
 3. check the app console to verify message has been properly handled.
 4. Again, write another message(directProjectId is provided at this time):
-  `{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "name": "<h1>Test Project</h1>", "description": "<h>Test</h><p>This is description</p>", "directProjectId": 500, "billingAccountId": null, "type": "Web", "createdBy": 132458 } }`
+  `{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "name": "<h1>Test Project</h1>", "description": "<h>Test</h><p>This is description</p>", "directProjectId": 500, "billingAccountId": null, "type": "Web", "createdBy": 132458 } }`
 5. check the app console to verify message has been properly handled.
 6. Try to write an invalid message:
-  `{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "name": "<h1>Test Project</h1>", "description": "<h>Test</h><p>This is description</p>", "directProjectId": 500, "billingAccountId": 100, "type": "Web", "createdBy": 132458 } }`
+  `{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "name": "<h1>Test Project</h1>", "description": "<h>Test</h><p>This is description</p>", "directProjectId": 500, "billingAccountId": 100, "type": "Web", "createdBy": 132458 } }`
 7. You will see error message in the app console.
-8. start kafka-console-producer to write messages to `project.notification.update` topic:
-  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.update`
+8. start kafka-console-producer to write messages to `project.action.update` topic:
+  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.action.update`
 9. write message:
-  `{ "topic": "project.notification.update", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "directProjectId": 500, "billingAccountId": 70015984, "updatedBy": 132458 } }`
+  `{ "topic": "project.action.update", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "directProjectId": 500, "billingAccountId": 70015984, "updatedBy": 132458 } }`
 10. check the app console to verify message has been properly handled.
 11. Try to write an invalid message:
-  `{ "topic": "project.notification.update", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "directProjectId": 500, "billingAccountId": 1, "updatedBy": 132458 } }`
+  `{ "topic": "project.action.update", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project", "id": 1001, "directProjectId": 500, "billingAccountId": 1, "updatedBy": 132458 } }`
 12. You will see error message in the app console.
-13. start kafka-console-producer to write messages to `project.notification.update` topic:
-  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.create`
+13. start kafka-console-producer to write messages to `project.action.update` topic:
+  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.action.create`
 14. write messages:
-`{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 132457, "role": "copilot", "createdBy": 132458 } }`
+`{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 132457, "role": "copilot", "createdBy": 132458 } }`
 
-`{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124835, "role": "manager", "createdBy": 132458 } }`
+`{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124835, "role": "manager", "createdBy": 132458 } }`
 
-`{ "topic": "project.notification.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124836, "role": "account_manager", "createdBy": 132458 } }`
+`{ "topic": "project.action.create", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124836, "role": "account_manager", "createdBy": 132458 } }`
 
 15. check the app console to verify messages has been properly handled.
 16. Repeat step 14 again.
 17. You will see error messages in the app console.
-18. start kafka-console-producer to write messages to `project.notification.update` topic:
-  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.delete`
+18. start kafka-console-producer to write messages to `project.action.update` topic:
+  `bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.action.delete`
 19. write messages:
-`{ "topic": "project.notification.delete", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 132457, "role": "copilot", "deletedBy": 132458 } }`
+`{ "topic": "project.action.delete", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 132457, "role": "copilot", "deletedBy": 132458 } }`
 
-`{ "topic": "project.notification.delete", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124835, "role": "manager", "deletedBy": 132458 } }`
+`{ "topic": "project.action.delete", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124835, "role": "manager", "deletedBy": 132458 } }`
 
-`{ "topic": "project.notification.delete", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124836, "role": "account_manager", "deletedBy": 132458 } }`
+`{ "topic": "project.action.delete", "originator": "project-api", "timestamp": "2018-07-02T00:00:00", "mime-type": "application/json", "payload": { "resource": "project.member", "projectId": 1001, "userId": 124836, "role": "account_manager", "deletedBy": 132458 } }`
 
 20. check the app console to verify messages has been properly handled.
 21. Repeat step 14 again.
diff --git a/config/default.js b/config/default.js
@@ -14,9 +14,9 @@ module.exports = {
   // Kafka group id
   KAFKA_GROUP_ID: process.env.KAFKA_GROUP_ID || 'legacy-project-processor',
 
-  CREATE_PROJECT_TOPIC: process.env.CREATE_PROJECT_TOPIC || 'project.notification.create',
-  UPDATE_PROJECT_TOPIC: process.env.UPDATE_PROJECT_TOPIC || 'project.notification.update',
-  DELETE_PROJECT_TOPIC: process.env.DELETE_PROJECT_TOPIC || 'project.notification.delete',
+  CREATE_PROJECT_TOPIC: process.env.CREATE_PROJECT_TOPIC || 'project.action.create',
+  UPDATE_PROJECT_TOPIC: process.env.UPDATE_PROJECT_TOPIC || 'project.action.update',
+  DELETE_PROJECT_TOPIC: process.env.DELETE_PROJECT_TOPIC || 'project.action.delete',
 
   // informix database configuration
   INFORMIX: {
diff --git a/test/processor.test.js b/test/processor.test.js
@@ -190,7 +190,7 @@ describe('Topcoder - Legacy Project Processor E2E Test', () => {
       }
     })
     await waitJob()
-    should.equal(errorLogs[0], 'The message topic invalid doesn\'t match the Kafka topic project.notification.create.')
+    should.equal(errorLogs[0], 'The message topic invalid doesn\'t match the Kafka topic project.action.create.')
   })
 
   it('failure - processor create project with nonexistent billing account ', async () => {
diff --git a/test/testData.js b/test/testData.js
@@ -10,7 +10,7 @@ const testTopics = {
     integerFields: ['payload.id', 'payload.directProjectId', 'payload.billingAccountId', 'payload.createdBy'],
     testMessages: [
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -26,7 +26,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -42,7 +42,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -66,7 +66,7 @@ const testTopics = {
     integerFields: ['payload.id', 'payload.directProjectId', 'payload.billingAccountId'],
     testMessages: [
       {
-        topic: 'project.notification.update',
+        topic: 'project.action.update',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -79,7 +79,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.update',
+        topic: 'project.action.update',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -92,7 +92,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.update',
+        topic: 'project.action.update',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -105,7 +105,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.update',
+        topic: 'project.action.update',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -125,7 +125,7 @@ const testTopics = {
     integerFields: ['payload.projectId', 'payload.userId', 'payload.createdBy'],
     testMessages: [
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -138,7 +138,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -151,7 +151,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -164,7 +164,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -177,7 +177,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.create',
+        topic: 'project.action.create',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -198,7 +198,7 @@ const testTopics = {
     integerFields: ['payload.projectId', 'payload.userId', 'payload.deletedBy'],
     testMessages: [
       {
-        topic: 'project.notification.delete',
+        topic: 'project.action.delete',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -211,7 +211,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.delete',
+        topic: 'project.action.delete',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',
@@ -224,7 +224,7 @@ const testTopics = {
         }
       },
       {
-        topic: 'project.notification.delete',
+        topic: 'project.action.delete',
         originator: 'project-api',
         timestamp: '2018-07-02T00:00:00',
         'mime-type': 'application/json',

Original file line number	Diff line number	Diff line change
`@@ -190,7 +190,7 @@ describe('Topcoder - Legacy Project Processor E2E Test', () => {`
`190`	`190`	`}`
`191`	`191`	`})`
`192`	`192`	`await waitJob()`
`193`		`- should.equal(errorLogs[0], 'The message topic invalid doesn\'t match the Kafka topic project.notification.create.')`
	`193`	`+ should.equal(errorLogs[0], 'The message topic invalid doesn\'t match the Kafka topic project.action.create.')`
`194`	`194`	`})`
`195`	`195`
`196`	`196`	`it('failure - processor create project with nonexistent billing account ', async () => {`
Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,7 @@ const testTopics = {`
`10`	`10`	`integerFields: ['payload.id', 'payload.directProjectId', 'payload.billingAccountId', 'payload.createdBy'],`
`11`	`11`	`testMessages: [`
`12`	`12`	`{`
`13`		`- topic: 'project.notification.create',`
	`13`	`+ topic: 'project.action.create',`
`14`	`14`	`originator: 'project-api',`
`15`	`15`	`timestamp: '2018-07-02T00:00:00',`
`16`	`16`	`'mime-type': 'application/json',`
`@@ -26,7 +26,7 @@ const testTopics = {`
`26`	`26`	`}`
`27`	`27`	`},`
`28`	`28`	`{`
`29`		`- topic: 'project.notification.create',`
	`29`	`+ topic: 'project.action.create',`
`30`	`30`	`originator: 'project-api',`
`31`	`31`	`timestamp: '2018-07-02T00:00:00',`
`32`	`32`	`'mime-type': 'application/json',`
`@@ -42,7 +42,7 @@ const testTopics = {`
`42`	`42`	`}`
`43`	`43`	`},`
`44`	`44`	`{`
`45`		`- topic: 'project.notification.create',`
	`45`	`+ topic: 'project.action.create',`
`46`	`46`	`originator: 'project-api',`
`47`	`47`	`timestamp: '2018-07-02T00:00:00',`
`48`	`48`	`'mime-type': 'application/json',`
`@@ -66,7 +66,7 @@ const testTopics = {`
`66`	`66`	`integerFields: ['payload.id', 'payload.directProjectId', 'payload.billingAccountId'],`
`67`	`67`	`testMessages: [`
`68`	`68`	`{`
`69`		`- topic: 'project.notification.update',`
	`69`	`+ topic: 'project.action.update',`
`70`	`70`	`originator: 'project-api',`
`71`	`71`	`timestamp: '2018-07-02T00:00:00',`
`72`	`72`	`'mime-type': 'application/json',`
`@@ -79,7 +79,7 @@ const testTopics = {`
`79`	`79`	`}`
`80`	`80`	`},`
`81`	`81`	`{`
`82`		`- topic: 'project.notification.update',`
	`82`	`+ topic: 'project.action.update',`
`83`	`83`	`originator: 'project-api',`
`84`	`84`	`timestamp: '2018-07-02T00:00:00',`
`85`	`85`	`'mime-type': 'application/json',`
`@@ -92,7 +92,7 @@ const testTopics = {`
`92`	`92`	`}`
`93`	`93`	`},`
`94`	`94`	`{`
`95`		`- topic: 'project.notification.update',`
	`95`	`+ topic: 'project.action.update',`
`96`	`96`	`originator: 'project-api',`
`97`	`97`	`timestamp: '2018-07-02T00:00:00',`
`98`	`98`	`'mime-type': 'application/json',`
`@@ -105,7 +105,7 @@ const testTopics = {`
`105`	`105`	`}`
`106`	`106`	`},`
`107`	`107`	`{`
`108`		`- topic: 'project.notification.update',`
	`108`	`+ topic: 'project.action.update',`
`109`	`109`	`originator: 'project-api',`
`110`	`110`	`timestamp: '2018-07-02T00:00:00',`
`111`	`111`	`'mime-type': 'application/json',`
`@@ -125,7 +125,7 @@ const testTopics = {`
`125`	`125`	`integerFields: ['payload.projectId', 'payload.userId', 'payload.createdBy'],`
`126`	`126`	`testMessages: [`
`127`	`127`	`{`
`128`		`- topic: 'project.notification.create',`
	`128`	`+ topic: 'project.action.create',`
`129`	`129`	`originator: 'project-api',`
`130`	`130`	`timestamp: '2018-07-02T00:00:00',`
`131`	`131`	`'mime-type': 'application/json',`
`@@ -138,7 +138,7 @@ const testTopics = {`
`138`	`138`	`}`
`139`	`139`	`},`
`140`	`140`	`{`
`141`		`- topic: 'project.notification.create',`
	`141`	`+ topic: 'project.action.create',`
`142`	`142`	`originator: 'project-api',`
`143`	`143`	`timestamp: '2018-07-02T00:00:00',`
`144`	`144`	`'mime-type': 'application/json',`
`@@ -151,7 +151,7 @@ const testTopics = {`
`151`	`151`	`}`
`152`	`152`	`},`
`153`	`153`	`{`
`154`		`- topic: 'project.notification.create',`
	`154`	`+ topic: 'project.action.create',`
`155`	`155`	`originator: 'project-api',`
`156`	`156`	`timestamp: '2018-07-02T00:00:00',`
`157`	`157`	`'mime-type': 'application/json',`
`@@ -164,7 +164,7 @@ const testTopics = {`
`164`	`164`	`}`
`165`	`165`	`},`
`166`	`166`	`{`
`167`		`- topic: 'project.notification.create',`
	`167`	`+ topic: 'project.action.create',`
`168`	`168`	`originator: 'project-api',`
`169`	`169`	`timestamp: '2018-07-02T00:00:00',`
`170`	`170`	`'mime-type': 'application/json',`
`@@ -177,7 +177,7 @@ const testTopics = {`
`177`	`177`	`}`
`178`	`178`	`},`
`179`	`179`	`{`
`180`		`- topic: 'project.notification.create',`
	`180`	`+ topic: 'project.action.create',`
`181`	`181`	`originator: 'project-api',`
`182`	`182`	`timestamp: '2018-07-02T00:00:00',`
`183`	`183`	`'mime-type': 'application/json',`
`@@ -198,7 +198,7 @@ const testTopics = {`
`198`	`198`	`integerFields: ['payload.projectId', 'payload.userId', 'payload.deletedBy'],`
`199`	`199`	`testMessages: [`
`200`	`200`	`{`
`201`		`- topic: 'project.notification.delete',`
	`201`	`+ topic: 'project.action.delete',`
`202`	`202`	`originator: 'project-api',`
`203`	`203`	`timestamp: '2018-07-02T00:00:00',`
`204`	`204`	`'mime-type': 'application/json',`
`@@ -211,7 +211,7 @@ const testTopics = {`
`211`	`211`	`}`
`212`	`212`	`},`
`213`	`213`	`{`
`214`		`- topic: 'project.notification.delete',`
	`214`	`+ topic: 'project.action.delete',`
`215`	`215`	`originator: 'project-api',`
`216`	`216`	`timestamp: '2018-07-02T00:00:00',`
`217`	`217`	`'mime-type': 'application/json',`
`@@ -224,7 +224,7 @@ const testTopics = {`
`224`	`224`	`}`
`225`	`225`	`},`
`226`	`226`	`{`
`227`		`- topic: 'project.notification.delete',`
	`227`	`+ topic: 'project.action.delete',`
`228`	`228`	`originator: 'project-api',`
`229`	`229`	`timestamp: '2018-07-02T00:00:00',`
`230`	`230`	`'mime-type': 'application/json',`