upgrade packages

Author: fabrice404

.env.example

@@ -0,0 +1,6 @@
+TEST_HOST = 'your-neptune-host'
+TEST_PORT = '8182'
+TEST_ACCESS_KEY_ID = 'access-key-id'
+TEST_SECRET_ACCESS_KEY = 'secret-access-key'
+TEST_REGION = 'aws-region-1'
+TEST_SECURE = 'false'

jest.setup.js

@@ -0,0 +1 @@
+require('dotenv').config();

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

@@ -20,13 +20,14 @@ class AwsSigV4DriverRemoteConnection extends gremlin.driver.RemoteConnection {
     this.try = 0;
     this.maxRetry = this.options.maxRetry || 10;
 
-    this.clientOptions = Object.assign({
+    this.clientOptions = {
       connectOnStartup: true,
       mimeType: 'application/vnd.gremlin-v2.0+json',
       pingEnabled: true,
       pingInterval: 1000,
       pongTimeout: 2000,
-    }, this.options);
+      ...this.options,
+    };
 
     this._rejections = {};
     this._connect();
@@ -65,10 +66,10 @@ class AwsSigV4DriverRemoteConnection extends gremlin.driver.RemoteConnection {
   _connectSocket() {
     const { url, headers } = getUrlAndHeaders(this.host, this.port, this.options, '/gremlin', this.secure ? 'wss' : 'ws');
     debug(`connect: ${JSON.stringify(url, headers)} (try #${this.try})`);
-    this._client = new gremlin.driver.Client(url, Object.assign({ headers }, this.clientOptions));
-    this._client._connection.on('log', log => this._logHandler(log));
+    this._client = new gremlin.driver.Client(url, ({ headers, ...this.clientOptions }));
+    this._client._connection.on('log', (log) => this._logHandler(log));
     this._client._connection.on('close', (code, message) => this._closeHandler(code, message));
-    this._client._connection.on('error', error => this._errorHandler(error));
+    this._client._connection.on('error', (error) => this._errorHandler(error));
     this._client._connection._ws.on('open', () => this._connectHandler());
   }
 
@@ -111,7 +112,7 @@ class AwsSigV4DriverRemoteConnection extends gremlin.driver.RemoteConnection {
   }
 
   _cancelPendingQueries(error) {
-    Object.values(this._rejections).forEach(reject => reject(error));
+    Object.values(this._rejections).forEach((reject) => reject(error));
     this._rejections = {};
   }
 
@@ -134,7 +135,7 @@ class AwsSigV4DriverRemoteConnection extends gremlin.driver.RemoteConnection {
         })
         .catch(reject);
     })
-      .then(result => result);
+      .then((result) => result);
   }
 
   /** @override */

lib/utils.js

@@ -35,17 +35,14 @@ const getUrlAndHeaders = (host, port, credentials, canonicalUri, protocol) => {
     || process.env.AWS_ACCESS_KEY_ID;
   const secretAccessKey = credentials.secretKey || credentials.secretAccessKey
     || process.env.AWS_SECRET_ACCESS_KEY;
-  const sessionToken = credentials.sessionToken || credentials.sessionToken
-    || process.env.AWS_SESSION_TOKEN;
+  const sessionToken = credentials.sessionToken || process.env.AWS_SESSION_TOKEN;
   const region = credentials.region || process.env.AWS_DEFAULT_REGION;
 
   if (!accessKeyId || !secretAccessKey) {
     throw new Error('Access key and secret key are required');
   }
 
-  const awsCreds = {
-    accessKeyId, secretAccessKey, sessionToken,
-  };
+  const awsCreds = { accessKeyId, secretAccessKey, sessionToken };
   const sigOptions = {
     host: `${host}:${port}`,
     region,