@dekproject/elasticsearch - npm Package Compare versions

Comparing version 1.0.1 to 1.1.1

build/index.js

@@ -29,11 +29,13 @@ 'use strict';
         var hosts = env.ELASTICSEARCH_HOST.indexOf(",") > -1 ? env.ELASTICSEARCH_HOST.split(",") : env.ELASTICSEARCH_HOST;
-        var elasticsearch = null;
+        var client = null;
 
         switch (env.ELASTICSEARCH_VERSION) {
             case "6":
-                elasticsearch = new Client6.Client({ node: hosts });break;
+                if (Array.isArray(hosts)) client = new Client6.Client({ nodes: hosts });else client = new Client6.Client({ node: hosts });
+                break;
             case "7":
-                elasticsearch = new Client7.Client({ node: hosts });break;
+                if (Array.isArray(hosts)) client = new Client7.Client({ nodes: hosts });else client = new Client7.Client({ node: hosts });
+                break;
             default:
-                elasticsearch = new _elasticsearch2.default.Client({ hosts: hosts });break;
+                client = new _elasticsearch2.default.Client({ hosts: hosts });break;
         }
@@ -43,3 +45,3 @@
 
-        _scope.$.set("elasticsearch", elasticsearch);
+        _scope.$.set("elasticsearch", client);
     } catch (e) {
@@ -46,0 +48,0 @@ console.log('[ Elasticsearch ] - ' + e.message);

package.json

 {
     "name": "@dekproject/elasticsearch",
-    "version": "1.0.1",
+    "version": "1.1.1",
     "description": "Elasticsearch interface plugin for DEK",
@@ -5,0 +5,0 @@ "main": "./build/index.js",

src/index.js

@@ -9,9 +9,19 @@ import { $ } from "@dekproject/scope";
         let env = process.env;
-        let hosts = (env.ELASTICSEARCH_HOST.indexOf(",") > -1) ? env.ELASTICSEARCH_HOST.split(",") : env.ELASTICSEARCH_HOST
-        let elasticsearch = null;
+        let hosts = (env.ELASTICSEARCH_HOST.indexOf(",") > -1) ? env.ELASTICSEARCH_HOST.split(",") : env.ELASTICSEARCH_HOST;
+        let client = null;
 
         switch(env.ELASTICSEARCH_VERSION){
-            case "6": elasticsearch = new Client6.Client( { node: hosts }); break;
-            case "7": elasticsearch = new Client7.Client( { node: hosts }); break;
-            default: elasticsearch = new Elasticsearch.Client( { hosts: hosts }); break;
+            case "6": 
+                if(Array.isArray(hosts))
+                    client = new Client6.Client( { nodes: hosts }); 
+                else
+                    client = new Client6.Client( { node: hosts });
+            break;
+            case "7": 
+                if(Array.isArray(hosts))
+                    client = new Client7.Client( { nodes: hosts });
+                else
+                    client = new Client7.Client( { node: hosts }); 
+            break;
+            default: client = new Elasticsearch.Client( { hosts: hosts }); break;
         }
@@ -22,3 +32,3 @@
 
-        $.set("elasticsearch", elasticsearch);
+        $.set("elasticsearch", client);
     }
@@ -25,0 +35,0 @@ catch (e) {

No alert changes

Improved metrics

Total package byte prevSize

9355

increased by11.55%

Lines of code

79

increased by17.91%

No dependency changes