Merge pull request #25 from shutterstock/dependencies-upgrade

Update dependencies

Author: fabrice404

lib/driver/aws-sigv4-driver-remote-connection.js

@@ -1,7 +1,6 @@
 const debug = require('debug')('gremlin-aws-sigv4:driver');
 const gremlin = require('gremlin');
-const request = require('request');
-const { getUrlAndHeaders, uuid } = require('../utils');
+const { getUrlAndHeaders, uuid, request } = require('../utils');
 
 class AwsSigV4DriverRemoteConnection extends gremlin.driver.RemoteConnection {
   constructor(host, port, options = {}, cbConnected = null, cbDisconnected = null, cbError = null) {
@@ -37,9 +36,11 @@ class AwsSigV4DriverRemoteConnection extends gremlin.driver.RemoteConnection {
     this.try += 1;
     const { url, headers } = getUrlAndHeaders(this.host, this.port, this.options, '/status', this.secure ? 'https' : 'http');
     debug(`get Neptune status: ${JSON.stringify(url, headers)} (try #${this.try})`);
-    request.get({ url, headers, timeout: 3000 }, (error, response, body) => {
-      this._statusCallback(error, response, body);
-    });
+    request(
+      url,
+      { headers, timeout: 3000 },
+      (err, response, body) => { this._statusCallback(err, response, body); },
+    );
   }
 
   _statusCallback(error, response, body) {

lib/utils.js

@@ -1,8 +1,10 @@
 /* eslint-disable no-bitwise */
 
+const aws4 = require('aws4');
 const crypto = require('crypto');
 const debug = require('debug')('gremlin-aws-sigv4:utils');
-const aws4 = require('aws4');
+const http = require('http');
+const https = require('https');
 
 /**
  * Generates a random uuid
@@ -56,6 +58,25 @@ const getUrlAndHeaders = (host, port, credentials, canonicalUri, protocol) => {
   };
 };
 
+/**
+ * Callbackify native http(s) get
+ */
+const request = (url, options, cb) => {
+  debug(`Requesting: ${url}`);
+  (url.match('https://') ? https.get : http.get)(url, options, (response) => {
+    let body = '';
+    response.on('data', (d) => {
+      body += d;
+    });
+    response.on('end', () => {
+      cb(null, response, body);
+    });
+  })
+    .on('error', (err) => {
+      cb(err, null, null);
+    });
+};
+
 module.exports = {
-  uuid, getUrlAndHeaders,
+  uuid, getUrlAndHeaders, request,
 };