Merge pull request #106 from topcoder-platform/feature/shapeup4-cqrs-update

sachin-maheshwari · web-flow · commit a0b1bbe6b5f3 · 2021-08-03T20:47:06.000+05:30
Shapeup4 : CQRS standards update
diff --git a/src/common/service-helper.js b/src/common/service-helper.js
@@ -50,12 +50,11 @@ async function createRecordInEs (resource, entity, toEs) {
     throw err
   }
 
-  if (!toEs) {
-    try {
-      await publishMessage("create", resource, entity);
-    } catch (err) {
-      logger.logFullError(err);
-    }
+  // publish create event.
+  try {
+    await publishMessage("create", resource, entity);
+  } catch (err) {
+    logger.logFullError(err);
   }
 
 }
@@ -75,12 +74,12 @@ async function patchRecordInEs (resource, entity, toEs) {
     logger.logFullError(err)
     throw err
   }
-  if (!toEs) {
-    try {
-      await publishMessage("patch", resource, entity);
-    } catch (err) {
-      logger.logFullError(err);
-    }
+
+  // publish patch event.
+  try {
+    await publishMessage("patch", resource, entity);
+  } catch (err) {
+    logger.logFullError(err);
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -50,12 +50,11 @@ async function createRecordInEs (resource, entity, toEs) {`
`50`	`50`	`throw err`
`51`	`51`	`}`
`52`	`52`
`53`		`- if (!toEs) {`
`54`		`- try {`
`55`		`- await publishMessage("create", resource, entity);`
`56`		`- } catch (err) {`
`57`		`- logger.logFullError(err);`
`58`		`- }`
	`53`	`+ // publish create event.`
	`54`	`+ try {`
	`55`	`+ await publishMessage("create", resource, entity);`
	`56`	`+ } catch (err) {`
	`57`	`+ logger.logFullError(err);`
`59`	`58`	`}`
`60`	`59`
`61`	`60`	`}`
`@@ -75,12 +74,12 @@ async function patchRecordInEs (resource, entity, toEs) {`
`75`	`74`	`logger.logFullError(err)`
`76`	`75`	`throw err`
`77`	`76`	`}`
`78`		`- if (!toEs) {`
`79`		`- try {`
`80`		`- await publishMessage("patch", resource, entity);`
`81`		`- } catch (err) {`
`82`		`- logger.logFullError(err);`
`83`		`- }`
	`77`	`+`
	`78`	`+ // publish patch event.`
	`79`	`+ try {`
	`80`	`+ await publishMessage("patch", resource, entity);`
	`81`	`+ } catch (err) {`
	`82`	`+ logger.logFullError(err);`
`84`	`83`	`}`
`85`	`84`	`}`
`86`	`85`