.eslintrc

@@ -0,0 +1 @@
+{ "extends": "scality" }

.eslintrc.json

@@ -1,7 +0,0 @@
-{
-    "extends": ["scality"],
-    "plugins": ["jest"],
-    "env": {
-        "jest/globals": true
-    }
-}

babel.config.js

@@ -1,8 +0,0 @@
-module.exports = {
-    presets: [
-        ['@babel/preset-env', { targets: { node: 'current' } }],
-        '@babel/preset-typescript',
-    ],
-    plugins: ['add-module-exports'],
-};
-

lib/algos/set/SortedSet.js

@@ -1,6 +1,7 @@
 const ArrayUtils = require('./ArrayUtils');
 
 class SortedSet {
+
     constructor(obj) {
         if (obj) {
             this.keys = obj.keys;

lib/auth/Vault.js

@@ -91,7 +91,7 @@ class Vault {
                 requestContext: serializedRCsArr,
             },
             (err, userInfo) => vaultSignatureCb(err, userInfo,
-                params.log, callback),
+                                                params.log, callback)
         );
     }
 
@@ -146,7 +146,7 @@ class Vault {
                 requestContext: serializedRCs,
             },
             (err, userInfo) => vaultSignatureCb(err, userInfo,
-                params.log, callback, streamingV4Params),
+                params.log, callback, streamingV4Params)
         );
     }
 

lib/auth/auth.js

@@ -194,7 +194,7 @@ function generateV4Headers(request, data, accessKey, secretKeyValue,
         .filter(headerName =>
             headerName.startsWith('x-amz-')
             || headerName.startsWith('x-scal-')
-            || headerName === 'host',
+            || headerName === 'host'
         ).sort().join(';');
     const params = { request, signedHeaders, payloadChecksum,
         credentialScope, timestamp, query: data,

lib/auth/backends/ChainBackend.js

@@ -29,7 +29,7 @@ class ChainBackend extends BaseBackend {
             typeof client.getCanonicalIds === 'function' &&
             typeof client.getEmailAddresses === 'function' &&
             typeof client.checkPolicies === 'function' &&
-            typeof client.healthcheck === 'function',
+            typeof client.healthcheck === 'function'
         ), 'invalid client: missing required auth backend methods');
         this._clients = clients;
     }
@@ -55,7 +55,7 @@ class ChainBackend extends BaseBackend {
             signatureFromRequest,
             accessKey,
             options,
-            done,
+            done
         ), callback);
     }
 
@@ -67,7 +67,7 @@ class ChainBackend extends BaseBackend {
             region,
             scopeDate,
             options,
-            done,
+            done
         ), callback);
     }
 
@@ -153,7 +153,7 @@ class ChainBackend extends BaseBackend {
             requestContextParams,
             userArn,
             options,
-            done,
+            done
         ), (err, res) => {
             if (err) {
                 return callback(err);
@@ -171,7 +171,7 @@ class ChainBackend extends BaseBackend {
             client.healthcheck(reqUid, (err, res) => done(null, {
                 error: !!err ? err : null,
                 status: res,
-            }),
+            })
         ), (err, res) => {
             if (err) {
                 return callback(err);

lib/auth/v4/streamingV4/V4Transform.js

@@ -273,7 +273,7 @@ class V4Transform extends Transform {
                 }
                 // get next chunk
                 return callback();
-            },
+            }
         );
     }
 }

lib/metrics/RedisClient.js

@@ -17,7 +17,7 @@ class RedisClient {
                 method: 'RedisClient.constructor',
                 redisHost: config.host,
                 redisPort: config.port,
-            }),
+            })
         );
         return this;
     }

lib/metrics/StatsModel.js

@@ -9,6 +9,7 @@ const StatsClient = require('./StatsClient');
  * rather than by seconds
  */
 class StatsModel extends StatsClient {
+
     /**
     * Utility method to convert 2d array rows to columns, and vice versa
     * See also: https://docs.ruby-lang.org/en/2.0.0/Array.html#method-i-zip

lib/models/LifecycleConfiguration.js

@@ -1128,7 +1128,7 @@ class LifecycleConfiguration {
                                 `<NoncurrentDays>${noncurrentDays}` +
                                 '</NoncurrentDays>',
                                 `<StorageClass>${storageClass}</StorageClass>`,
-                            `</${actionName}>`,
+                            `</${actionName}>`
                         );
                     });
                     Action = xml.join('');
@@ -1148,7 +1148,7 @@ class LifecycleConfiguration {
                             `<${actionName}>`,
                                 element,
                                 `<StorageClass>${storageClass}</StorageClass>`,
-                            `</${actionName}>`,
+                            `</${actionName}>`
                         );
                     });
                     Action = xml.join('');

lib/models/ObjectMD.js

@@ -10,6 +10,7 @@ const ObjectMDLocation = require('./ObjectMDLocation');
  * mpuPart metadata for example)
  */
 class ObjectMD {
+
     /**
      * Create a new instance of ObjectMD. Parameter <tt>objMd</tt> is
      * reserved for internal use, users should call

lib/models/ObjectMDLocation.js

@@ -3,6 +3,7 @@
  * 'location' array
  */
 class ObjectMDLocation {
+
     /**
      * @constructor
      * @param {object} locationObj - single data location info

lib/network/http/server.js

@@ -10,6 +10,7 @@ const { checkSupportIPv6 } = require('./utils');
 
 
 class Server {
+
     /**
      * @constructor
      *

lib/network/kmip/index.js

@@ -342,6 +342,8 @@ class KMIP {
                 return cb(null, response);
             });
     }
+
+
 }
 
 

lib/network/probe/Utils.js

@@ -26,7 +26,7 @@ function sendError(res, log, error, optMessage) {
             httpCode: error.code,
             errorType: error.message,
             error: message,
-        },
+        }
     );
     res.writeHead(error.code);
     res.end(JSON.stringify({

lib/network/rest/RESTServer.js

@@ -45,6 +45,7 @@ function sendError(res, log, error, optMessage) {
  * start() to start listening to the configured port.
  */
 class RESTServer extends httpServer {
+
     /**
      * @constructor
      * @param {Object} params - constructor params

lib/network/rpc/level-net.js

@@ -17,6 +17,7 @@ const rpc = require('./rpc.js');
  * RPC client object accessing the sub-level transparently.
  */
 class LevelDbClient extends rpc.BaseClient {
+
     /**
      * @constructor
      *
@@ -77,6 +78,7 @@ class LevelDbClient extends rpc.BaseClient {
  * env.subDb (env is passed as first parameter of received RPC calls).
  */
 class LevelDbService extends rpc.BaseService {
+
     /**
      * @constructor
      *

lib/network/rpc/rpc.js

@@ -37,6 +37,7 @@ let streamRPCJSONObj;
  *   an error occurred).
  */
 class BaseClient extends EventEmitter {
+
     /**
      * @constructor
      *
@@ -250,6 +251,7 @@ class BaseClient extends EventEmitter {
  *
  */
 class BaseService {
+
     /**
      * @constructor
      *

lib/s3middleware/MD5Sum.js

@@ -6,6 +6,7 @@ const crypto = require('crypto');
  * data through a stream
  */
 class MD5Sum extends Transform {
+
     /**
      * @constructor
      */
@@ -39,6 +40,7 @@ class MD5Sum extends Transform {
         this.emit('hashed');
         callback(null);
     }
+
 }
 
 module.exports = MD5Sum;

lib/s3middleware/azureHelpers/mpuUtils.js

@@ -121,7 +121,7 @@ azureMpuUtils.putSinglePart = (errorWrapperFn, request, params, dataStoreName,
                     return cb(errors.BadDigest);
                 }
                 return cb(errors.InternalError.customizeDescription(
-                        `Error returned from Azure: ${err.message}`),
+                    `Error returned from Azure: ${err.message}`)
                 );
             }
             const md5 = result.headers['content-md5'] || '';

lib/s3middleware/convertToXml.js

@@ -33,7 +33,7 @@ convertMethods.listMultipartUploads = xmlParams => {
     xml.push('<?xml version="1.0" encoding="UTF-8"?>',
              '<ListMultipartUploadsResult ' +
                 'xmlns="http://s3.amazonaws.com/doc/2006-03-01/">',
-        `<Bucket>${escapeForXml(xmlParams.bucketName)}</Bucket>`,
+             `<Bucket>${escapeForXml(xmlParams.bucketName)}</Bucket>`
     );
 
     // For certain XML elements, if it is `undefined`, AWS returns either an
@@ -58,7 +58,7 @@ convertMethods.listMultipartUploads = xmlParams => {
     });
 
     xml.push(`<MaxUploads>${escapeForXml(l.MaxKeys)}</MaxUploads>`,
-        `<IsTruncated>${escapeForXml(l.IsTruncated)}</IsTruncated>`,
+             `<IsTruncated>${escapeForXml(l.IsTruncated)}</IsTruncated>`
     );
 
     l.Uploads.forEach(upload => {
@@ -84,14 +84,14 @@ convertMethods.listMultipartUploads = xmlParams => {
                  `<StorageClass>${escapeForXml(val.StorageClass)}` +
                     '</StorageClass>',
                  `<Initiated>${escapeForXml(val.Initiated)}</Initiated>`,
-            '</Upload>',
+                 '</Upload>'
         );
     });
 
     l.CommonPrefixes.forEach(prefix => {
         xml.push('<CommonPrefixes>',
                  `<Prefix>${escapeForXml(prefix)}</Prefix>`,
-            '</CommonPrefixes>',
+                 '</CommonPrefixes>'
         );
     });
 

lib/s3middleware/nullStream.js

@@ -5,6 +5,7 @@ const Readable = require('stream').Readable;
  * This class is used to produce zeros filled buffers for a reader consumption
  */
 class NullStream extends Readable {
+
     /**
      * Construct a new zeros filled buffers producer that will
      * produce as much bytes as specified by the range parameter, or the size

lib/s3routes/routesUtils.js

@@ -118,7 +118,7 @@ const XMLResponseBackend = {
             `<Message>${errCode.description}</Message>`,
             '<Resource></Resource>',
             `<RequestId>${log.getSerializedUids()}</RequestId>`,
-            '</Error>',
+            '</Error>'
         );
         const xmlStr = xml.join('');
         const bytesSent = Buffer.byteLength(xmlStr);
@@ -376,7 +376,7 @@ function retrieveData(locations, retrieveDataParams, response, log) {
                 // call end for all cases (error/success) per node.js docs
                 // recommendation
                 response.end();
-        },
+            }
     );
 }
 
@@ -591,7 +591,7 @@ const routesUtils = {
             `<h1>${err.code} ${response.statusMessage}</h1>`,
             '<ul>',
             `<li>Code: ${err.message}</li>`,
-            `<li>Message: ${err.description}</li>`,
+            `<li>Message: ${err.description}</li>`
         );
 
         if (!userErrorPageFailure && bucketName) {
@@ -601,7 +601,7 @@ const routesUtils = {
             `<li>RequestId: ${log.getSerializedUids()}</li>`,
             // AWS response contains HostId here.
             // TODO: consider adding
-            '</ul>',
+            '</ul>'
         );
         if (userErrorPageFailure) {
             html.push(
@@ -611,13 +611,13 @@ const routesUtils = {
                 '<ul>',
                 `<li>Code: ${err.message}</li>`,
                 `<li>Message: ${err.description}</li>`,
-                '</ul>',
+                '</ul>'
             );
         }
         html.push(
             '<hr/>',
             '</body>',
-            '</html>',
+            '</html>'
         );
 
         return response.end(html.join(''), 'utf8', () => {
@@ -847,7 +847,7 @@ const routesUtils = {
             return bucketName;
         }
         throw new Error(
-            `bad request: hostname ${host} is not in valid endpoints`,
+            `bad request: hostname ${host} is not in valid endpoints`
         );
     },
 

lib/storage/data/external/AwsClient.js

@@ -11,7 +11,7 @@ const { createLogger, logHelper, removeQuotes, trimXMetaPrefix } =
 
 const missingVerIdInternalError = errors.InternalError.customizeDescription(
     'Invalid state. Please ensure versioning is enabled ' +
-    'in AWS for the location constraint and try again.',
+    'in AWS for the location constraint and try again.'
 );
 
 class AwsClient {
@@ -94,7 +94,7 @@ class AwsClient {
                   err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             if (!data.VersionId && this._supportsVersioning) {
@@ -233,7 +233,7 @@ class AwsClient {
                 }
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             return callback();
@@ -307,7 +307,7 @@ class AwsClient {
                   err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             return callback(null, mpuResObj);
@@ -335,7 +335,7 @@ class AwsClient {
                     'on uploadPart', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                     .customizeDescription('Error returned from ' +
-                    `${this.type}: ${err.message}`),
+                    `${this.type}: ${err.message}`)
                 );
             }
             // Because we manually add quotes to ETag later, remove quotes here
@@ -363,7 +363,7 @@ class AwsClient {
                   err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             // build storedParts object to mimic Scality S3 backend returns
@@ -435,7 +435,7 @@ class AwsClient {
                 'completeMPU', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             if (!completeMpuRes.VersionId && this._supportsVersioning) {
@@ -453,7 +453,7 @@ class AwsClient {
                     'headObject', err, this._dataStoreName, this.clientType);
                     return callback(errors.ServiceUnavailable
                       .customizeDescription('Error returned from ' +
-                      `${this.type}: ${err.message}`),
+                      `${this.type}: ${err.message}`)
                     );
                 }
                 // remove quotes from eTag because they're added later
@@ -481,7 +481,7 @@ class AwsClient {
                 this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             return callback();
@@ -510,7 +510,7 @@ class AwsClient {
                   this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             return callback();
@@ -533,7 +533,7 @@ class AwsClient {
                 this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             return callback();
@@ -570,14 +570,14 @@ class AwsClient {
                     this._dataStoreName, this.clientType);
                     return callback(errors.AccessDenied
                       .customizeDescription('Error: Unable to access ' +
-                      `${sourceAwsBucketName} ${this.type} bucket`),
+                      `${sourceAwsBucketName} ${this.type} bucket`)
                     );
                 }
                 logHelper(log, 'error', 'error from data backend on ' +
                 'copyObject', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             if (!copyResult.VersionId && this._supportsVersioning) {
@@ -629,14 +629,14 @@ class AwsClient {
                     this._dataStoreName, this.clientType);
                     return callback(errors.AccessDenied
                       .customizeDescription('Error: Unable to access ' +
-                      `${sourceAwsBucketName} AWS bucket`),
+                      `${sourceAwsBucketName} AWS bucket`)
                     );
                 }
                 logHelper(log, 'error', 'error from data backend on ' +
                 'uploadPartCopy', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `${this.type}: ${err.message}`),
+                  `${this.type}: ${err.message}`)
                 );
             }
             const eTag = removeQuotes(res.CopyPartResult.ETag);

lib/storage/data/external/AzureClient.js

@@ -422,14 +422,14 @@ class AzureClient {
                         this._dataStoreName);
                         return callback(errors.AccessDenied
                         .customizeDescription('Error: Unable to access ' +
-                        `${sourceContainerName} Azure Container`),
+                        `${sourceContainerName} Azure Container`)
                         );
                     }
                     logHelper(log, 'error', 'error from data backend on ' +
                     'copyObject', err, this._dataStoreName);
                     return callback(errors.ServiceUnavailable
                     .customizeDescription('Error returned from ' +
-                    `AWS: ${err.message}`),
+                    `AWS: ${err.message}`)
                     );
                 }
                 if (res.copy.status === 'pending') {
@@ -443,12 +443,12 @@ class AzureClient {
                             'on abortCopyBlob', err, this._dataStoreName);
                             return callback(errors.ServiceUnavailable
                             .customizeDescription('Error returned from ' +
-                            `AWS on abortCopyBlob: ${err.message}`),
+                            `AWS on abortCopyBlob: ${err.message}`)
                             );
                         }
                         return callback(errors.InvalidObjectState
                         .customizeDescription('Error: Azure copy status was ' +
-                        'pending. It has been aborted successfully'),
+                        'pending. It has been aborted successfully')
                         );
                     });
                 }

lib/storage/data/external/GcpClient.js

@@ -123,7 +123,7 @@ class GcpClient extends AwsClient {
                   err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `GCP: ${err.message}`),
+                  `GCP: ${err.message}`)
                 );
             }
             return callback(null, mpuResObj);
@@ -168,7 +168,7 @@ class GcpClient extends AwsClient {
                 'completeMPU', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `GCP: ${err.message}`),
+                  `GCP: ${err.message}`)
                 );
             }
             if (!completeMpuRes.VersionId) {
@@ -210,7 +210,7 @@ class GcpClient extends AwsClient {
                   'on uploadPart', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `GCP: ${err.message}`),
+                  `GCP: ${err.message}`)
                 );
             }
             // remove quotes from eTag because they're added later
@@ -242,7 +242,7 @@ class GcpClient extends AwsClient {
         if (copySourceRange) {
             return callback(errors.NotImplemented
               .customizeDescription('Error returned from ' +
-                `${this.clientType}: copySourceRange not implemented`),
+                `${this.clientType}: copySourceRange not implemented`)
             );
         }
 
@@ -261,14 +261,14 @@ class GcpClient extends AwsClient {
                     this._dataStoreName, this.clientType);
                     return callback(errors.AccessDenied
                       .customizeDescription('Error: Unable to access ' +
-                      `${sourceGcpBucketName} GCP bucket`),
+                      `${sourceGcpBucketName} GCP bucket`)
                     );
                 }
                 logHelper(log, 'error', 'error from data backend on ' +
                 'uploadPartCopy', err, this._dataStoreName);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                  `GCP: ${err.message}`),
+                  `GCP: ${err.message}`)
                 );
             }
             // remove quotes from eTag because they're added later
@@ -291,7 +291,7 @@ class GcpClient extends AwsClient {
                     'on abortMPU', err, this._dataStoreName, this.clientType);
                 return callback(errors.ServiceUnavailable
                   .customizeDescription('Error returned from ' +
-                    `GCP: ${err.message}`),
+                    `GCP: ${err.message}`)
                 );
             }
             return callback();

lib/storage/data/external/PfsClient.js

@@ -45,7 +45,7 @@ class PfsClient {
             }
             return callback(null, keyContext.objectKey, '',
                 keyContext.metaHeaders['x-amz-meta-size'],
-                md5,
+                md5
             );
         }
         logHelper(log, 'error', 'Not implemented', errors.NotImplemented,

lib/storage/data/file/DataFileStore.js

@@ -35,6 +35,7 @@ const FOLDER_HASH = 3511;
  * directory hash structure under the configured dataPath.
  */
 class DataFileStore {
+
     /**
      * @constructor
      * @param {Object} dataConfig - configuration of the file backend

lib/storage/metadata/bucketclient/LogConsumer.js

@@ -30,6 +30,7 @@ class ListRecordStream extends stream.Transform {
  * @classdesc Proxy object to access raft log API
  */
 class LogConsumer {
+
     /**
      * @constructor
      *

lib/storage/metadata/conditions.js

@@ -14,13 +14,13 @@ const _operatorType1 = joi.string().valid(
     '$gt',
     '$gte',
     '$lt',
-    '$lte',
+    '$lte'
 );
 
 // supports strings, numbers, and boolean
 const _operatorType2 = joi.string().valid(
     '$eq',
-    '$ne',
+    '$ne'
 );
 
 const _valueType1 = joi.alternatives([

lib/storage/metadata/file/BucketFileInterface.js

@@ -17,6 +17,7 @@ const METASTORE = '__metastore';
 const itemScanRefreshDelay = 1000 * 30 * 60; // 30 minutes
 
 class BucketFileInterface {
+
     /**
      * @constructor
      * @param {object} [params] - constructor params

lib/storage/metadata/file/MetadataFileClient.js

@@ -8,6 +8,7 @@ const { RecordLogProxy } = require('./RecordLog.js');
 const werelogs = require('werelogs');
 
 class MetadataFileClient {
+
     /**
      * Construct a metadata client
      *

lib/storage/metadata/file/MetadataFileServer.js

@@ -25,6 +25,7 @@ const SYNC_OPTIONS = { sync: true };
 const SUBLEVEL_SEP = '::';
 
 class MetadataFileServer {
+
     /**
      * Construct a metadata server
      *

lib/storage/metadata/file/RecordLog.js

@@ -18,6 +18,7 @@ const DEFAULT_RECORD_LOG_NAME = 's3-recordlog';
  * object.
  */
 class RecordLogProxy extends rpc.BaseClient {
+
     constructor(params) {
         super(params);
 
@@ -101,6 +102,7 @@ class ListRecordStream extends stream.Transform {
  * updates can be transactional with each other.
  */
 class RecordLogService extends rpc.BaseService {
+
     /**
      * @constructor
      *

lib/storage/metadata/mongoclient/LogConsumer.js

@@ -9,6 +9,7 @@ const MongoUtils = require('./utils');
  * @classdesc Class to consume mongo oplog
  */
 class LogConsumer {
+
     /**
      * @constructor
      *

lib/storage/metadata/mongoclient/MongoClientInterface.js

@@ -538,7 +538,7 @@ class MongoClientInterface {
                 updateOne: {
                     // eslint-disable-next-line
                     filter: {
-                        '_id': objName,
+                        _id: objName,
                         'value.versionId': params.versionId,
                     },
                     update: {
@@ -607,7 +607,7 @@ class MongoClientInterface {
                 MongoUtils.serialize(mstObjVal);
                 // eslint-disable-next-line
                 c.update({
-                    '_id': objName,
+                    _id: objName,
                     'value.versionId': {
                         // We break the semantic correctness here with
                         // $gte instead of $gt because we do not have
@@ -760,7 +760,7 @@ class MongoClientInterface {
         MongoUtils.serialize(objVal);
         // eslint-disable-next-line
         c.findOneAndReplace({
-            '_id': objName,
+            _id: objName,
             'value.isPHD': true,
             'value.versionId': mst.versionId,
         }, {
@@ -822,7 +822,7 @@ class MongoClientInterface {
                     // version:
                     // eslint-disable-next-line
                     c.findOneAndDelete({
-                        '_id': objName,
+                        _id: objName,
                         'value.isPHD': true,
                         'value.versionId': mst.versionId,
                     }, {}, err => {
@@ -1616,7 +1616,7 @@ class MongoClientInterface {
                 const retResult = this._handleResults(collRes, isVer);
                 retResult.stalled = stalledCount;
                 return callback(null, retResult);
-            },
+            }
         );
     }
 

lib/storage/metadata/proxy/Server.js

@@ -11,6 +11,7 @@ const requiresOneWorker = {
 };
 
 class Server {
+
     /**
      * Create a new Metadata Proxy Server instance
      *

lib/testing/matrix.js

@@ -160,7 +160,7 @@ class TestMatrix {
                     const result = Object.keys(matrixChild.params)
                     .every(currentKey =>
                            Object.prototype.toString.call(
-                                matrixChild.params[currentKey],
+                               matrixChild.params[currentKey]
                             ).indexOf('Array') === -1);
 
                     if (result === true) {

package.json

@@ -33,7 +33,7 @@
     "fcntl": "github:scality/node-fcntl#0.2.0",
     "hdclient": "scality/hdclient#1.1.0",
     "https-proxy-agent": "^2.2.0",
-    "ioredis": "~4.28.3",
+    "ioredis": "4.9.5",
     "ipaddr.js": "1.9.1",
     "level": "~5.0.1",
     "level-sublevel": "~6.6.5",
@@ -53,19 +53,12 @@
     "ioctl": "^2.0.2"
   },
   "devDependencies": {
-    "@babel/core": "^7.0.0-0",
-    "@babel/preset-env": "^7.16.5",
-    "@babel/preset-typescript": "^7.16.5",
     "@sinonjs/fake-timers": "^6.0.1",
-    "@types/jest": "^27.0.3",
     "@types/node": "^16.11.7",
-    "babel-plugin-add-module-exports": "^1.0.4",
+    "eslint": "2.13.1",
-    "eslint": "^7.32.0",
     "eslint-config-airbnb": "6.2.0",
     "eslint-config-scality": "scality/Guidelines#ec33dfb",
-    "eslint-plugin-jest": "^24.7.0",
     "eslint-plugin-react": "^4.3.0",
-    "jest": "^27.4.5",
     "mocha": "8.0.1",
     "mongodb-memory-server": "^6.0.2",
     "nyc": "^15.1.0",
@@ -77,32 +70,12 @@
     "lint": "eslint $(git ls-files '*.js')",
     "lint_md": "mdlint $(git ls-files '*.md')",
     "lint_yml": "yamllint $(git ls-files '*.yml')",
-    "test": "jest tests/unit",
+    "test": "mocha --recursive --exit tests/unit",
-    "ft_test": "jest tests/functional --forceExit",
+    "ft_test": "find tests/functional -name \"*.js\" | grep -v \"utils/\" | xargs mocha --timeout 120000 --exit",
     "coverage": "yarn coverage_unit && yarn coverage_ft && yarn coverage_report",
-    "coverage_unit": "yarn test --coverage",
+    "coverage_unit": "nyc --silent yarn test",
-    "coverage_ft": "yarn ft_test --coverage",
+    "coverage_ft": "nyc --silent --no-clean yarn ft_test",
     "coverage_report": "nyc report --all --reporter=text-summary --reporter=lcov",
     "compile": "tsc"
-  },
-  "jest": {
-    "collectCoverage": true,
-    "maxWorkers": 1,
-    "roots": [
-      ".",
-      "lib",
-      "errors"
-    ],
-    "testPathIgnorePatterns": [
-      "/node_modules/",
-      "helpers?\\.js",
-      "Mock.*\\.js",
-      "Dummy.*\\.js",
-      "tests/functional/.*/utils\\.js",
-      "tests/functional/.*/utils/.*\\.js"
-    ],
-    "testMatch": [
-      "**/*.js"
-    ]
   }
 }

tests/functional/kmip/lowlevel.js

@@ -41,7 +41,7 @@ describe('KMIP Low Level Driver', () => {
                                  return done(err);
                              }
                              const responsePayload = response.lookup(
-                        'Response Message/Batch Item/Response Payload',
+                                 'Response Message/Batch Item/Response Payload'
                              )[0];
                              assert.deepStrictEqual(responsePayload,
                                                     requestPayload);

tests/functional/kmip/tls.js

@@ -7,7 +7,7 @@ const { logger } = require('../../utils/kmip/ersatz.js');
 
 describe('KMIP Connection Management', () => {
     let server;
-    beforeAll(done => {
+    before(done => {
         server = net.createServer(conn => {
             // abort the connection as soon as it is accepted
             conn.destroy();
@@ -15,7 +15,7 @@ describe('KMIP Connection Management', () => {
         server.listen(5696);
         server.on('listening', done);
     });
-    afterAll(done => {
+    after(done => {
         server.close(done);
     });
 

tests/functional/metadata/mongodb/mongoClientInterface.js

@@ -28,7 +28,7 @@ const mongoserver = new MongoMemoryReplSet({
 
 describe('MongoClientInterface', () => {
     let metadata;
-    beforeAll(done => {
+    before(done => {
         mongoserver.waitUntilRunning().then(() => {
             const opts = {
                 mongodb: {
@@ -44,7 +44,7 @@ describe('MongoClientInterface', () => {
         });
     });
 
-    afterAll(done => {
+    after(done => {
         async.series([
             next => metadata.close(next),
             next => mongoserver.stop()

tests/functional/metadataProxy/routesToMem.js

@@ -152,8 +152,8 @@ function _deleteObjects(objects, cb) {
 }
 
 describe('Basic Metadata Proxy Server test',
-    () => {
+         function bindToThis() {
-        jest.setTimeout(10000);
+             this.timeout(10000);
              it('Shoud get the metadataInformation', done => {
                  dispatcher.get('/default/metadataInformation',
                                 (err, response, body) => {
@@ -167,8 +167,8 @@ describe('Basic Metadata Proxy Server test',
              });
          });
 
-describe('Basic Metadata Proxy Server CRUD test', () => {
+describe('Basic Metadata Proxy Server CRUD test', function bindToThis() {
-    jest.setTimeout(10000);
+    this.timeout(10000);
 
     beforeEach(done => {
         dispatcher.post(`/default/bucket/${Bucket}`, bucketInfo,

tests/functional/metrics/StatsClient.js

@@ -28,7 +28,7 @@ describe('StatsClient class', () => {
 
     afterEach(() => redisClient.clear(() => {}));
 
-    afterAll(() => redisClient.disconnect());
+    after(() => redisClient.disconnect());
 
     it('should correctly record a new request by default one increment',
     done => {

tests/unit/algos/cache/LRUCache.spec.js

@@ -85,11 +85,11 @@ describe('LRUCache', () => {
         assert.strictEqual(lru.get(100), undefined);
     });
 
-    it('max 1000000 entries', () => {
+    it('max 1000000 entries', function lru1M() {
         // this test takes ~1-2 seconds on a laptop, nevertheless set a
         // large timeout to reduce the potential of flakiness on possibly
         // slower CI environment.
-        jest.setTimeout(30000);
+        this.timeout(30000);
 
         const lru = new LRUCache(1000000);
 

tests/unit/algos/list/delimiter.js

@@ -85,7 +85,7 @@ const nonAlphabeticalData = [
 
 const receivedData = data.map(item => ({ key: item.key, value: item.value }));
 const receivedNonAlphaData = nonAlphabeticalData.map(
-    item => ({ key: item.key, value: item.value }),
+    item => ({ key: item.key, value: item.value })
 );
 
 const tests = [

tests/unit/algos/stream/MergeStream.spec.js

@@ -189,8 +189,8 @@ describe('MergeStream', () => {
                           `${usePauseResume ? ' with pause/resume' : ''}` +
                           `${errorAtEnd ? ' with error' : ''}`;
                     it(`${nbEntries} sequential entries${fixtureDesc}`,
-                        (done) => {
+                    function bigMergeSequential(done) {
-                            jest.setTimeout(10000);
+                        this.timeout(10000);
                         const stream1 = [];
                         const stream2 = [];
                         for (let i = 0; i < nbEntries; ++i) {
@@ -204,8 +204,8 @@ describe('MergeStream', () => {
                             stream1, stream2, usePauseResume, errorAtEnd, done);
                     });
                     it(`${nbEntries} randomly mingled entries${fixtureDesc}`,
-                        (done) => {
+                    function bigMergeRandom(done) {
-                            jest.setTimeout(10000);
+                        this.timeout(10000);
                         const stream1 = [];
                         const stream2 = [];
                         let accu = nbEntries;

tests/unit/auth/chainBackend.js

@@ -257,7 +257,7 @@ describe('Auth Backend: Chain Backend', () => {
                     id3: 'email3@test.com',
                     // id4 should be overwritten
                     id4: 'email5@test.com',
-                },
+                }
             );
         });
     });

tests/unit/auth/v4/timeUtils.js

@@ -35,11 +35,11 @@ describe('convertUTCtoISO8601 function', () => {
 
 describe('checkTimeSkew function', () => {
     let clock;
-    beforeAll(() => {
+    before(() => {
         // Time is 2016-03-17T18:22:01.033Z
         clock = fakeTimers.install({ now: 1458238921033 });
     });
-    afterAll(() => {
+    after(() => {
         clock.uninstall();
     });
 

tests/unit/helpers.js

@@ -57,6 +57,7 @@ function zpad(key, length = 15) {
 }
 
 class DummyRequestLogger {
+
     constructor() {
         this.ops = [];
         this.counts = {

tests/unit/ipCheck.js

@@ -69,7 +69,7 @@ describe('Check IP matches a list of CIDR ranges', () => {
         [['192.168.1.1'], '192.168.1.1'],
     ].forEach(item =>
         it(`should match IP ${item[0][0]} without CIDR range`,
-            () => cidrListMatchCheck(item[0], item[1], true)),
+            () => cidrListMatchCheck(item[0], item[1], true))
     );
 
     it('should not range match if CIDR range is not provided',

tests/unit/metrics/ZenkoMetrics.spec.js

@@ -9,7 +9,7 @@ describe('ZenkoMetrics', () => {
     let summary;
     let petCounter;
 
-    beforeAll(() => {
+    before(() => {
         counter = ZenkoMetrics.createCounter({
             name: 'gizmo_counter',
             help: 'Count gizmos',

tests/unit/models/BucketInfo.js

@@ -631,7 +631,7 @@ Object.keys(acl).forEach(
                     dummyBucket.getUid(), testUid);
             });
         });
-    }),
+    })
 );
 
 describe('uid default', () => {

tests/unit/models/LifecycleConfiguration.js

@@ -1207,7 +1207,7 @@ describe('LifecycleConfiguration::getConfigJson', () => {
         `should return correct configuration: ${msg}`, () => {
             assert.deepStrictEqual(
                 LifecycleConfiguration.getConfigJson(input),
-                expected,
+                expected
             );
         }));
 });

tests/unit/network/probe/HealthProbeServer.spec.js

@@ -34,11 +34,11 @@ describe('network.probe.HealthProbeServer', () => {
             server.start();
         }
 
-        beforeAll(done => {
+        before(done => {
             setup(done);
         });
 
-        afterAll(done => {
+        after(done => {
             server.stop();
             done();
         });
@@ -73,11 +73,11 @@ describe('network.probe.HealthProbeServer', () => {
             done();
         }
 
-        beforeAll(done => {
+        before(done => {
             setup(done);
         });
 
-        afterAll(done => {
+        after(done => {
             server.stop();
             done();
         });
@@ -108,11 +108,11 @@ describe('network.probe.HealthProbeServer', () => {
             done();
         }
 
-        beforeAll(done => {
+        before(done => {
             setup(done);
         });
 
-        afterAll(done => {
+        after(done => {
             server.stop();
             done();
         });
@@ -143,11 +143,11 @@ describe('network.probe.HealthProbeServer', () => {
             done();
         }
 
-        beforeAll(done => {
+        before(done => {
             setup(done);
         });
 
-        afterAll(done => {
+        after(done => {
             server.stop();
             done();
         });
@@ -176,11 +176,11 @@ describe('network.probe.HealthProbeServer', () => {
             server.start();
         }
 
-        beforeAll(done => {
+        before(done => {
             setup(done);
         });
 
-        afterAll(done => {
+        after(done => {
             server.stop();
             done();
         });

tests/unit/network/probe/Utils.spec.js

@@ -47,7 +47,7 @@ describe('network.probe.Utils', () => {
                     {
                         errorType: 'MethodNotAllowed',
                         errorMessage: errors.MethodNotAllowed.description,
-                    },
+                    }
                 );
                 done();
             }),
@@ -64,7 +64,7 @@ describe('network.probe.Utils', () => {
                     {
                         errorType: 'MethodNotAllowed',
                         errorMessage: 'Very much not allowed',
-                    },
+                    }
                 );
                 done();
             }),

tests/unit/network/rest/index.js

@@ -53,11 +53,11 @@ describe('REST interface for blob data storage', () => {
         });
     }
 
-    beforeAll(done => {
+    before(done => {
         setup(done);
     });
 
-    afterAll(done => {
+    after(done => {
         server.stop();
         client.destroy();
         done();
@@ -135,7 +135,7 @@ describe('REST interface for blob data storage', () => {
                 `bytes ${expectedStart}-${expectedEnd}/${contents.length}`);
         }
 
-        beforeAll(done => {
+        before(done => {
             const rs = createReadStream(contents);
             client.put(rs, contents.length, '1', (err, key) => {
                 assert.ifError(err);

tests/unit/network/rpc/level-net.js

@@ -161,7 +161,7 @@ describe('level-net - LevelDB over network', () => {
         async.series(opList, cb);
     }
 
-    beforeAll(done => {
+    before(done => {
         temp.mkdir('level-net-testdb-', (err, dbDir) => {
             const rootDb = level(dbDir);
             db = sublevel(rootDb);
@@ -169,7 +169,7 @@ describe('level-net - LevelDB over network', () => {
         });
     });
 
-    afterAll(done => {
+    after(done => {
         client.once('disconnect', () => {
             server.close();
             done();
@@ -249,7 +249,7 @@ describe('level-net - LevelDB over network', () => {
                     .put(keyOfIter(i), valueOfIter(i), params, putCb);
             }
         }
-        beforeAll(done => {
+        before(done => {
             prefillKeys(done);
         });
         it('should be able to read keys back at random', done => {

tests/unit/network/rpc/rpc.js

@@ -53,11 +53,11 @@ describe('rpc - generic client/server RPC system', () => {
         miscClient.connect(done);
     }
 
-    beforeAll(done => {
+    before(done => {
         setupRPC(done);
     });
 
-    afterAll(done => {
+    after(done => {
         miscClient.once('disconnect', () => {
             server.close();
             done();

tests/unit/patches/locationConstraints.spec.js

@@ -317,9 +317,9 @@ describe('patch location constriants', () => {
                 patchLocations(
                     { [locationName]: locations },
                     { privateKey },
-                    mockLog,
+                    mockLog
                 ),
-                { [locationName]: expected },
+                { [locationName]: expected }
             );
         });
     });
@@ -330,9 +330,9 @@ describe('patch location constriants', () => {
             patchLocations(
                 undefined,
                 { privateKey },
-                mockLog,
+                mockLog
             ),
-            {},
+            {}
         );
     });
 
@@ -345,9 +345,9 @@ describe('patch location constriants', () => {
                     },
                 },
                 { privateKey },
-                mockLog,
+                mockLog
             ),
-            {},
+            {}
         );
     });
 });

tests/unit/s3middleware/LifecycleUtils.js

@@ -34,7 +34,7 @@ function getRuleIDs(rules) {
 describe('LifecycleUtils::getApplicableRules', () => {
     let lutils;
 
-    beforeAll(() => {
+    before(() => {
         lutils = new LifecycleUtils([
             'expiration',
             'noncurrentVersionExpiration',
@@ -434,7 +434,7 @@ describe('LifecycleUtils::getApplicableRules', () => {
 describe('LifecycleUtils::filterRules', () => {
     let lutils;
 
-    beforeAll(() => {
+    before(() => {
         lutils = new LifecycleUtils();
     });
 
@@ -522,7 +522,7 @@ describe('LifecycleUtils::filterRules', () => {
         const expRes1 = getRuleIDs(mBucketRules.filter(rule =>
             (rule.Filter && rule.Filter.Tag &&
             rule.Filter.Tag.Key === 'tag1' &&
-            rule.Filter.Tag.Value === 'val1'),
+            rule.Filter.Tag.Value === 'val1')
         ));
         assert.deepStrictEqual(expRes1, getRuleIDs(res1));
 
@@ -532,7 +532,7 @@ describe('LifecycleUtils::filterRules', () => {
         const expRes2 = getRuleIDs(mBucketRules.filter(rule =>
             rule.Filter && rule.Filter.Tag &&
             rule.Filter.Tag.Key === 'tag3-1' &&
-            rule.Filter.Tag.Value === 'val3',
+            rule.Filter.Tag.Value === 'val3'
         ));
         assert.deepStrictEqual(expRes2, getRuleIDs(res2));
     });
@@ -619,7 +619,7 @@ describe('LifecycleUtils::filterRules', () => {
 describe('LifecycleUtils::getApplicableTransition', () => {
     let lutils;
 
-    beforeAll(() => {
+    before(() => {
         lutils = new LifecycleUtils();
     });
 
@@ -792,7 +792,7 @@ describe('LifecycleUtils::getApplicableTransition', () => {
 describe('LifecycleUtils::compareTransitions', () => {
     let lutils;
 
-    beforeAll(() => {
+    before(() => {
         lutils = new LifecycleUtils();
     });
 

tests/unit/s3routes/routesUtils/responseStreamData.js

@@ -36,7 +36,7 @@ describe('routesUtils.responseStreamData', () => {
     let httpServer;
     let awsClient;
 
-    beforeAll(done => {
+    before(done => {
         awsClient = new AwsClient(awsConfig);
         httpServer = http.createServer((req, res) => {
             const objStream = new DummyObjectStream(0, 10000000);
@@ -47,7 +47,7 @@ describe('routesUtils.responseStreamData', () => {
         httpServer.on('error', err => assert.ifError(err));
     });
 
-    afterAll(() => {
+    after(() => {
         httpServer.close();
     });
 

tests/unit/storage/data/DummyObjectStream.spec.js

@@ -20,7 +20,6 @@ describe('DummyObjectStream', () => {
     it('should return a stream of 8-byte hex-encoded blocks', async () => {
         // FIXME we likely need an eslint update
         /* eslint-disable no-unused-expressions */
-        jest.setTimeout(30000);
         await testStream(0, 0, '');
         await testStream(50, 0, '');
         await testStream(0, 1, ' ');
@@ -54,5 +53,5 @@ describe('DummyObjectStream', () => {
               .join('');
         await testStream(567890123, 5 + 8 * 1024 * 1024 + 3, expectedLarge2);
         /* eslint-enable no-unused-expressions */
-    });
+    }).timeout(30000);
 });

tests/unit/storage/data/external/ExternalClients.js

@@ -54,7 +54,7 @@ describe('external backend clients', () => {
     backendClients.forEach(backend => {
         let testClient;
 
-        beforeAll(() => {
+        before(() => {
             testClient = new backend.Class(backend.config);
             testClient._client = new DummyService({ versioning: true });
         });

tests/unit/storage/data/external/GcpService.js

@@ -87,12 +87,12 @@ const operations = [
     },
 ];
 
-describe('GcpService request behavior', () => {
+describe('GcpService request behavior', function testSuite() {
-    jest.setTimeout(120000);
+    this.timeout(120000);
     let httpServer;
     let client;
 
-    beforeAll(done => {
+    before(done => {
         client = new GCP({
             endpoint: `http://${host}`,
             maxRetries: 0,
@@ -109,7 +109,7 @@ describe('GcpService request behavior', () => {
         });
     });
 
-    afterAll(() => {
+    after('Terminating Server', () => {
         httpServer.close();
     });
 
@@ -125,12 +125,12 @@ describe('GcpService request behavior', () => {
     });
 });
 
-describe('GcpService pathStyle tests', () => {
+describe('GcpService pathStyle tests', function testSuite() {
-    jest.setTimeout(120000);
+    this.timeout(120000);
     let httpServer;
     let client;
 
-    beforeAll(done => {
+    before(done => {
         client = new GCP({
             endpoint: `http://${host}`,
             maxRetries: 0,
@@ -147,7 +147,7 @@ describe('GcpService pathStyle tests', () => {
         });
     });
 
-    afterAll(() => {
+    after('Terminating Server', () => {
         httpServer.close();
     });
 
@@ -159,12 +159,12 @@ describe('GcpService pathStyle tests', () => {
     }));
 });
 
-describe('GcpService dnsStyle tests', () => {
+describe('GcpService dnsStyle tests', function testSuite() {
-    jest.setTimeout(120000);
+    this.timeout(120000);
     let httpServer;
     let client;
 
-    beforeAll(done => {
+    before(done => {
         client = new GCP({
             endpoint: `http://${host}`,
             maxRetries: 0,
@@ -181,7 +181,7 @@ describe('GcpService dnsStyle tests', () => {
         });
     });
 
-    afterAll(() => {
+    after('Terminating Server', () => {
         httpServer.close();
     });
 

tests/unit/storage/data/wrapperClientRoutes.js

@@ -64,7 +64,7 @@ function getDataWrapper() {
 let dw;
 
 describe('Routes from DataWrapper to backend client', () => {
-    beforeAll(() => {
+    before(() => {
         dw = getDataWrapper();
     });
 

tests/unit/storage/metadata/bucketclient/LogConsumer.js

@@ -82,6 +82,7 @@ const malformedLogEntry = new MockStream(malformedLogEntryData);
 
 // mock a simple bucketclient to get a fake raft log
 class BucketClientMock {
+
     getRaftLog(raftId, start, limit, targetLeader, reqUids, callback) {
         switch (raftId) {
         case 0:
@@ -116,11 +117,11 @@ describe('raft record log client', () => {
         done();
     }
 
-    beforeAll(done => {
+    before(done => {
         setup(done);
     });
 
-    afterAll(done => {
+    after(done => {
         done();
     });
 

tests/unit/storage/metadata/file/RecordLog.js

@@ -66,7 +66,7 @@ describe('record log - persistent log of metadata operations', () => {
         done();
     }
 
-    beforeAll(done => {
+    before(done => {
         temp.mkdir('record-log-testdir-', (err, dbDir) => {
             const rootDb = level(dbDir);
             db = sublevel(rootDb);
@@ -74,7 +74,7 @@ describe('record log - persistent log of metadata operations', () => {
         });
     });
 
-    afterAll(done => {
+    after(done => {
         server.close();
         done();
     });
@@ -207,7 +207,7 @@ describe('record log - persistent log of metadata operations', () => {
     describe('readRecords', () => {
         let logProxy;
 
-        beforeAll(done => {
+        before(done => {
             logProxy = createScratchRecordLog(cliLogger, err => {
                 assert.ifError(err);
                 // fill the log with 1000 entries
@@ -228,7 +228,7 @@ describe('record log - persistent log of metadata operations', () => {
             });
         });
 
-        afterAll(done => closeRecordLog(logProxy, () => {
+        after(done => closeRecordLog(logProxy, () => {
             logProxy = undefined;
             done();
         }));

tests/unit/storage/metadata/mongoclient/MongoClientInterface.js

@@ -395,7 +395,7 @@ describe('MongoClientInterface::_processEntryData', () => {
     tests.forEach(([msg, isTransient, params, expected]) => it(msg, () => {
         assert.deepStrictEqual(
             mongoTestClient._processEntryData(params, isTransient),
-            expected,
+            expected
         );
     }));
 });
@@ -498,7 +498,7 @@ describe('MongoClientInterface::_isReplicationEntryStalled', () => {
     tests.forEach(([msg, params, expected]) => it(msg, () => {
         assert.deepStrictEqual(
             mongoTestClient._isReplicationEntryStalled(params, testDate),
-            expected,
+            expected
         );
     }));
 });
@@ -556,7 +556,7 @@ function uploadObjects(client, bucketName, objectList, callback) {
 describe('MongoClientInterface, tests', () => {
     const hr = 1000 * 60 * 60;
     let client;
-    beforeAll(done => {
+    before(done => {
         mongoserver.waitUntilRunning().then(() => {
             const opts = {
                 replicaSetHosts: 'localhost:27018',
@@ -573,7 +573,7 @@ describe('MongoClientInterface, tests', () => {
         });
     });
 
-    afterAll(done => {
+    after(done => {
         async.series([
             next => client.close(next),
             next => mongoserver.stop()

tests/unit/stringHash.js

@@ -32,8 +32,8 @@ describe('StringHash', () => {
         done();
     });
     it(`Should distribute uniformly with a maximum of ${ERROR}% of deviation`,
-        (done) => {
+        function f(done) {
-            jest.setTimeout(20000);
+            this.timeout(20000);
             const strings = new Array(STRING_COUNT).fill('')
                                 .map(() => randomString(10));
             const arr = new Array(ARRAY_LENGTH).fill(0);

tests/utils/kmip/LoopbackServerChannel.js

@@ -177,7 +177,7 @@ class LoopbackServerChannel extends EchoChannel {
                                     serverExtensions.map(extension =>
                                                          this.KMIP.TextString(
                                                              extension.name,
-                            extension.value),
+                                                             extension.value)
                                                         )));
         }
         if (queryFunctions.includes('Query Extension Map')) {

tests/utils/kmip/ersatz.js

@@ -50,6 +50,7 @@ class EchoChannel extends EventEmitter {
         this.clogged = true;
         return this;
     }
+
 }
 
 class MirrorChannel extends EchoChannel {