cluster-service - npm Package Compare versions

Comparing version 0.5.7 to 0.5.8

lib/http-client.js

 var
 	util = require("util"),
-	request = require("request"),
+	http = require("http"),
 	querystring = require("querystring"),
@@ -42,8 +42,25 @@ locals = null,
 	cservice.log("Running remote command: ".warn + url.replace(/accessKey=.*/i, "accessKey={ACCESS_KEY}").data);
-	request.post(url, function (err, res, body) {
-		if (res.statusCode !== 200 && !err && body) {
-		    err = body;
-		}
-		onCallback(err, body, res, cb);
-	});
+    var body = "", err;
+    http.request(
+        {
+            host: options.host || "localhost",
+            port: options.port || 11987,
+            path: "/cli?" + qs,
+            method: "POST"
+        }, function(res) {
+            res.setEncoding('utf8');
+            res.on("data", function(chunk) {
+                body += chunk;
+            });
+            res.on("end", function() {
+        	    if (res.statusCode !== 200 && body) {
+                    err = body;
+                }
+                onCallback(err, body, res, cb);
+            });
+        }
+    ).on("error", function(err) {
+        body = err;
+        onCallback(err, body, res, cb);
+    }).end();
 }
@@ -54,3 +71,3 @@
 	    cservice.error("Error: ", err);
-	    result = { statusCode: res.statusCode, error: err };
+	    result = { statusCode: res ? res.statusCode : "unknown", error: err };
     } else if (result) {
@@ -57,0 +74,0 @@ if (typeof result === "string" && (result.indexOf("{") === 0 || result.indexOf("[") === 0)) {

lib/run.js

 var
 	util = require("util"),
-	request = require("request"),
+	http = require("http"),
 	querystring = require("querystring"),
@@ -28,22 +28,37 @@ options = null,
 	cservice.log("Running remote command: ".warn + url.replace(/accessKey=.*/i, "accessKey={ACCESS_KEY}").data);
-	request.post(url, function (err, res, body) {
-	    if (res && res.statusCode !== 200 && !err && body) {
-	        err = body;
-	    }
-	    if (err) {
-			cservice.error("Error: ", err);
-			body = { statusCode: res ? res.statusCode : "no response", error: err };
-		} else if (body) {
-			if (typeof body === "string" && (body.indexOf("{") === 0 || body.indexOf("[") === 0)) {
-				body = JSON.parse(body); // deserialize
-			}
-		}
-		if (options.json === true) {
-			cservice.results(JSON.stringify(body));
-		} else {
-			cservice.results(util.inspect(body, { depth: null, colors: true }));
-		}
+    var body = "", err;
+    http.request(
+        {
+            host: options.host || "localhost",
+            port: options.port || 11987,
+            path: "/cli?" + qs,
+            method: "POST"
+        }, function(res) {
+            res.setEncoding('utf8');
+            res.on("data", function(chunk) {
+                body += chunk;
+            });
+            res.on("end", function() {
+        	    if (res.statusCode !== 200 && body) {
+                    err = body;
+                }
+	            if (err) {
+			        cservice.error("Error: ", err);
+			        body = { statusCode: res ? res.statusCode : "no response", error: err };
+		        } else if (typeof body === "string" && (body.indexOf("{") === 0 || body.indexOf("[") === 0)) {
+				    body = JSON.parse(body); // deserialize
+		        }
+		        if (options.json === true) {
+			        cservice.results(JSON.stringify(body));
+		        } else {
+			        cservice.results(util.inspect(body, { depth: null, colors: true }));
+		        }
 		
-		cb && cb(err, body);
-	});
+		        cb && cb(err, body);
+            });
+        }
+    ).on("error", function(err) {
+        body = err;
+        cb && cb(err, body);
+    }).end();
 }

package.json

 {
   "name": "cluster-service",
-  "version": "0.5.7",
+  "version": "0.5.8",
   "author": {
@@ -15,3 +15,2 @@ "name": "Aaron Silvas",
     "async": ">=0.2.x",
-    "request": ">=2.21.0",
 	"optimist": ">=0.6.0",
@@ -23,2 +22,3 @@ "colors": ">=0.6.2",
     "mocha": "~1.12.0",
+    "request": ">=2.21.0",
     "istanbul": "~0.1.43"
@@ -25,0 +25,0 @@ },

No alert changes

Improved metrics

Total package byte prevSize

88234

increased by1.28%

Dependency count

4

decreased by-20%

Lines of code

1964

increased by1.66%

Worsened metrics

Dev dependency count

3

increased by50%

Number of medium supply chain risk alerts

4

increased by100%

Dependency changes

• - Removedrequest@>=2.21.0

• - Removedajv@6.12.6(transitive)

• - Removedasn1@0.2.6(transitive)

• - Removedassert-plus@1.0.0(transitive)

• - Removedasynckit@0.4.0(transitive)

• - Removedaws-sign2@0.7.0(transitive)

• - Removedaws4@1.13.0(transitive)

• - Removedbcrypt-pbkdf@1.0.2(transitive)

• - Removedcaseless@0.12.0(transitive)

• - Removedcombined-stream@1.0.8(transitive)

• - Removedcore-util-is@1.0.2(transitive)

• - Removeddashdash@1.14.1(transitive)

• - Removeddelayed-stream@1.0.0(transitive)

• - Removedecc-jsbn@0.1.2(transitive)

• - Removedextsprintf@1.3.0(transitive)

• - Removedfast-deep-equal@3.1.3(transitive)

• - Removedfast-json-stable-stringify@2.1.0(transitive)

• - Removedforever-agent@0.6.1(transitive)

• - Removedform-data@2.3.3(transitive)

• - Removedgetpass@0.1.7(transitive)

• - Removedhar-schema@2.0.0(transitive)

• - Removedhar-validator@5.1.5(transitive)

• - Removedhttp-signature@1.2.0(transitive)

• - Removedis-typedarray@1.0.0(transitive)

• - Removedisstream@0.1.2(transitive)

• - Removedjsbn@0.1.1(transitive)

• - Removedjson-schema@0.4.0(transitive)

• - Removedjson-schema-traverse@0.4.1(transitive)

• - Removedjson-stringify-safe@5.0.1(transitive)

• - Removedjsprim@1.4.2(transitive)

• - Removedmime-db@1.52.0(transitive)

• - Removedmime-types@2.1.35(transitive)

• - Removedoauth-sign@0.9.0(transitive)

• - Removedperformance-now@2.1.0(transitive)

• - Removedpsl@1.9.0(transitive)

• - Removedpunycode@2.3.1(transitive)

• - Removedqs@6.5.3(transitive)

• - Removedrequest@2.88.2(transitive)

• - Removedsafe-buffer@5.2.1(transitive)

• - Removedsafer-buffer@2.1.2(transitive)

• - Removedsshpk@1.18.0(transitive)

• - Removedtough-cookie@2.5.0(transitive)

• - Removedtunnel-agent@0.6.0(transitive)

• - Removedtweetnacl@0.14.5(transitive)

• - Removeduri-js@4.4.1(transitive)

• - Removeduuid@3.4.0(transitive)

• - Removedverror@1.10.0(transitive)