fix: translate TCP errors

fixes #129

Author: rahulreddy

lib/IAMClient.js

@@ -7,6 +7,7 @@ const http = require('http');
 const https = require('https');
 const parseString = require('xml2js').parseString;
 const queryString = require('querystring');
+const Logger = require('werelogs').Logger;
 
 class IAMClient {
     /**
@@ -52,6 +53,7 @@ class IAMClient {
         }
         this.accessKey = accessKey;
         this.secretKeyValue = secretKeyValue;
+        this.logger = new Logger('vaultclient');
     }
 
     getServerHost() {
@@ -361,6 +363,7 @@ class IAMClient {
      * @returns {undefined}
      */
     request(method, path, callback, data, reqUid, logger) {
+        const log = logger || this.logger;
         const options = {
             method,
             path,
@@ -417,15 +420,12 @@ class IAMClient {
             });
         });
         req.on('error', err => {
-            if (logger) {
-                logger.debug('error during request', {
-                    component: 'vaultclient',
-                    method: 'IAMClient:request()',
-                    error: err.stack || err,
-                });
-                return callback(errors.InternalError);
-            }
-            return callback(err);
+            log.error('error during request', {
+                component: 'vaultclient',
+                method: 'IAMClient:request()',
+                error: err.stack || err,
+            });
+            return callback(errors.InternalError);
         });
         req.end();
     }
@@ -481,10 +481,11 @@ class IAMClient {
      * @returns {undefined}
      */
     handleResponse(res, ret, log, callback) {
+        const logger = log || this.logger;
         this.getObj(ret, (err, obj) => {
             if (err) {
-                if (log) {
-                    log.error('error from vault',
+                if (logger) {
+                    logger.error('error from vault',
                         { error: err, method: 'IAMClient.handleResponse' });
                 }
                 return callback(err, null, res.statusCode);
@@ -496,15 +497,15 @@ class IAMClient {
 
             // Load the error from errors(arsenal)
             if (obj && obj.ErrorResponse && obj.ErrorResponse.Error) {
-                if (log) {
-                    log.debug('error from vault',
+                if (logger) {
+                    logger.debug('error from vault',
                         { error: obj, method: 'IAMClient.handleResponse' });
                 }
                 return callback(
                     errors[obj.ErrorResponse.Error.Code], null, res.statusCode);
             }
-            if (log) {
-                log.error('unable to translate error from vault', {
+            if (logger) {
+                logger.error('unable to translate error from vault', {
                     error: obj,
                     method: 'IAMClient.handleResponse',
                 });

package.json

@@ -13,7 +13,8 @@
   "dependencies": {
     "arsenal": "scality/Arsenal#rel/6.2.5",
     "commander": "^2.9.0",
-    "xml2js": "^0.4.16"
+    "xml2js": "^0.4.16",
+    "werelogs": "scality/werelogs#rel/6.2.5"
   },
   "devDependencies": {
     "babel-eslint": "^4.1.3",