Restore changes carried out in 830712e - refresh on update

Author: callmekatootie

src/common/helper.js

@@ -145,7 +145,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: 'true'
   })
 }
 
@@ -170,7 +171,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: 'true'
   })
 }
 

src/services/ProcessorService.js

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