Update ES updates to wait for index to refresh before returning with response

Author: callmekatootie

src/common/helper.js

@@ -89,7 +89,8 @@ async function updateUser (userId, body) {
     index: config.get('ES.USER_INDEX'),
     type: config.get('ES.USER_TYPE'),
     id: userId,
-    body: { doc: body }
+    body: { doc: body },
+    refresh: 'wait_for'
   })
 }
 
@@ -114,7 +115,8 @@ async function updateOrg (organizationId, body) {
     index: config.get('ES.ORGANIZATION_INDEX'),
     type: config.get('ES.ORGANIZATION_TYPE'),
     id: organizationId,
-    body: { doc: body }
+    body: { doc: body },
+    refresh: 'wait_for'
   })
 }
 

src/services/ProcessorService.js

@@ -27,7 +27,7 @@ async function processCreate (message) {
       type: topResources[resource].type,
       id: message.payload.id,
       body: _.omit(message.payload, 'resource'),
-      refresh: 'true'
+      refresh: 'wait_for'
     })
   } else if (_.includes(_.keys(userResources), resource)) {
     // process user resources such as userSkill, userAttribute...
@@ -102,7 +102,8 @@ async function processUpdate (message) {
       id,
       body: {
         doc: _.assign(source, _.omit(message.payload, 'resource'))
-      }
+      },
+      refresh: 'wait_for'
     })
   } else if (_.includes(_.keys(userResources), resource)) {
     // process user resources such as userSkill, userAttribute...
@@ -174,7 +175,7 @@ async function processDelete (message) {
       index: topResources[resource].index,
       type: topResources[resource].type,
       id: message.payload.id,
-      refresh: 'true'
+      refresh: 'wait_for'
     })
   } else if (_.includes(_.keys(userResources), resource)) {
     // process user resources such as userSkill, userAttribute...