From 67b98f148fe737afa664b70732c304034da8b062 Mon Sep 17 00:00:00 2001
From: phead198708 <85940583+phead198708@users.noreply.github.com>
Date: Tue, 3 Aug 2021 13:27:05 +0800
Subject: [PATCH] Update service-helper.js

---
 src/common/service-helper.js | 23 +++++++++++------------
 1 file changed, 11 insertions(+), 12 deletions(-)

diff --git a/src/common/service-helper.js b/src/common/service-helper.js
index 7eb518b..b47ae48 100644
--- 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);
   }
 }