Fixing ES access to AWS ES Search

config/default.js

@@ -24,6 +24,7 @@ module.exports = {
   ES: {
     HOST: process.env.ES_HOST || 'http://localhost:9200',
     ES_REFRESH: process.env.ES_REFRESH || 'true',
+    ES_API_VERSION: process.env.ES_API_VERSION || "7.4",
 
     ELASTICCLOUD: {
       id: process.env.ELASTICCLOUD_ID,

src/common/es-client.js

@@ -26,9 +26,17 @@ function getESClient () {
       }
     })
   } else {
-    esClient = new elasticsearch.Client({
-      node: host
-    })
+    if (/.*amazonaws.*/.test(host)) {
+      esClient = elasticsearch.Client({
+        apiVersion: config.get('ES.ES_API_VERSION'),
+        hosts: host,
+        connectionClass: require('http-aws-es'), // eslint-disable-line global-require
+      });
+    } else {
+      esClient = new elasticsearch.Client({
+        node: host
+      })
+    }
   }
   return esClient
 }