Reformat

Command: yarn lint --fix

Issue: CLDSRV-723

Author: williamlardier

bin/search_bucket.js

@@ -10,14 +10,14 @@ const https = require('https');
 const logger = require('../lib/utilities/logger');
 
 function _performSearch(host,
-                        port,
-                        bucketName,
-                        query,
-                        listVersions,
-                        accessKey,
-                        secretKey,
-                        sessionToken,
-                        verbose, ssl) {
+    port,
+    bucketName,
+    query,
+    listVersions,
+    accessKey,
+    secretKey,
+    sessionToken,
+    verbose, ssl) {
     const escapedSearch = encodeURIComponent(query);
     const options = {
         host,

constants.js

@@ -122,9 +122,9 @@ const constants = {
     // declare here all existing service accounts and their properties
     // (if any, otherwise an empty object)
     serviceAccountProperties: {
-        replication: {},
-        lifecycle: {},
-        gc: {},
+        'replication': {},
+        'lifecycle': {},
+        'gc': {},
         'md-ingestion': {
             canReplicate: true,
         },

dataserver.js

@@ -31,7 +31,7 @@ if (config.backends.data === 'file' ||
     dataServer.setup(err => {
         if (err) {
             logger.error('Error initializing REST data server',
-                         { error: err });
+                { error: err });
             return;
         }
         dataServer.start();

lib/Config.js

@@ -220,7 +220,7 @@ const api = {
                 // issue 100 Continue to the client
                 writeContinue(request, response);
                 const MAX_POST_LENGTH = request.method === 'POST' ?
-                      1024 * 1024 : 1024 * 1024 / 2; // 1 MB or 512 KB
+                    1024 * 1024 : 1024 * 1024 / 2; // 1 MB or 512 KB
                 const post = [];
                 let postLength = 0;
                 request.on('data', chunk => {
@@ -241,7 +241,7 @@ const api = {
                 request.on('end', () => {
                     if (postLength > MAX_POST_LENGTH) {
                         log.error('body length is too long for request type',
-                                  { postLength });
+                            { postLength });
                         return next(errors.InvalidRequest);
                     }
                     // Convert array of post buffers into one string
@@ -287,8 +287,8 @@ const api = {
                 }, {});
             }
             const methodCallback = (err, ...results) => async.forEachLimit(request.finalizerHooks, 5,
-                    (hook, done) => hook(err, done),
-                    () => callback(err, ...results));
+                (hook, done) => hook(err, done),
+                () => callback(err, ...results));
 
             if (apiMethod === 'objectPut' || apiMethod === 'objectPutPart') {
                 request._response = response;

lib/api/api.js

@@ -428,7 +428,7 @@ function evaluateBucketPolicyWithIAM(bucket, requestTypesInput, canonicalID, aut
             arn = authInfo.getArn();
         }
         return processBucketPolicy(_requestType, bucket, canonicalID, arn, bucket.getOwner(), log,
-        request, true, results, actionImplicitDenies);
+            request, true, results, actionImplicitDenies);
     });
 }
 

lib/api/apiUtils/authorization/permissionChecks.js

@@ -75,11 +75,11 @@ function prepareRequestContexts(apiMethod, request, sourceBucket,
         // In the API, we then ignore these authorization results, and we can use
         // any information returned, e.g., the quota.
         const requestContextMultiObjectDelete = generateRequestContext('objectDelete');
-          requestContexts.push(requestContextMultiObjectDelete);
+        requestContexts.push(requestContextMultiObjectDelete);
     } else if (apiMethodAfterVersionCheck === 'objectCopy'
         || apiMethodAfterVersionCheck === 'objectPutCopyPart') {
         const objectGetAction = sourceVersionId ? 'objectGetVersion' :
-          'objectGet';
+            'objectGet';
         const reqQuery = Object.assign({}, request.query,
             { versionId: sourceVersionId });
         const getRequestContext = new RequestContext(request.headers,
@@ -107,7 +107,7 @@ function prepareRequestContexts(apiMethod, request, sourceBucket,
                || apiMethodAfterVersionCheck === 'objectGetVersion') {
         const objectGetTaggingAction = (request.query &&
           request.query.versionId) ? 'objectGetTaggingVersion' :
-          'objectGetTagging';
+            'objectGetTagging';
         if (request.headers['x-amz-version-id']) {
             const objectGetVersionAction = 'objectGetVersion';
             const getVersionResourceVersion =
@@ -212,7 +212,7 @@ function prepareRequestContexts(apiMethod, request, sourceBucket,
     } else if (apiMethodAfterVersionCheck === 'initiateMultipartUpload' ||
       apiMethodAfterVersionCheck === 'objectPutPart' ||
       apiMethodAfterVersionCheck === 'completeMultipartUpload'
-      ) {
+    ) {
         if (request.headers['x-scal-s3-version-id'] ||
         request.headers['x-scal-s3-version-id'] === '') {
             const putVersionRequestContext =

lib/api/apiUtils/authorization/prepareRequestContexts.js

@@ -93,7 +93,7 @@ const _validator = {
     validateNumberRules(length) {
         if (length > 100) {
             return errorInstances.InvalidRequest
-            .customizeDescription(customizedErrs.numberRules);
+                .customizeDescription(customizedErrs.numberRules);
         }
         return true;
     },
@@ -323,20 +323,20 @@ function parseCorsXml(xml, log, cb) {
 function convertToXml(arrayRules) {
     const xml = [];
     xml.push('<?xml version="1.0" encoding="UTF-8" standalone="yes"?>',
-    '<CORSConfiguration>');
+        '<CORSConfiguration>');
     arrayRules.forEach(rule => {
         xml.push('<CORSRule>');
         ['allowedMethods', 'allowedOrigins', 'allowedHeaders', 'exposeHeaders']
-        .forEach(key => {
-            if (rule[key]) {
-                const element = key.charAt(0).toUpperCase() +
+            .forEach(key => {
+                if (rule[key]) {
+                    const element = key.charAt(0).toUpperCase() +
                     key.slice(1, -1);
-                rule[key].forEach(value => {
-                    xml.push(`<${element}>${escapeForXml(value)}` +
+                    rule[key].forEach(value => {
+                        xml.push(`<${element}>${escapeForXml(value)}` +
                     `</${element}>`);
-                });
-            }
-        });
+                    });
+                }
+            });
         if (rule.id) {
             xml.push(`<ID>${escapeForXml(rule.id)}</ID>`);
         }

lib/api/apiUtils/bucket/bucketCors.js

@@ -255,10 +255,10 @@ function createBucket(authInfo, bucketName, headers,
             // and no SSE settings were specified during bucket creation.
             // Bucket-specific SSE headers override the default encryption.
             const sseConfig = config.globalEncryptionEnabled && !bucketSseConfig.algorithm
-            ? {
-                algorithm: 'AES256',
-                mandatory: true,
-            } : bucketSseConfig;
+                ? {
+                    algorithm: 'AES256',
+                    mandatory: true,
+                } : bucketSseConfig;
 
             return bucketLevelServerSideEncryption(
                 bucket, sseConfig, log,
@@ -271,7 +271,7 @@ function createBucket(authInfo, bucketName, headers,
                         'new bucket without flags; adding transient label');
                     newBucketMD.addTransientFlag();
                     return freshStartCreateBucket(newBucketMD, canonicalID,
-                                                  log, cb);
+                        log, cb);
                 });
         }
         if (existingBucketMD.hasTransientFlag() ||

lib/api/apiUtils/bucket/bucketCreation.js

@@ -25,9 +25,9 @@ function bucketShield(bucket, requestType) {
         invisiblyDelete(bucket.getName(), bucket.getOwner());
         return true;
     }
-     // If request is initiateMultipartUpload (requestType objectPut),
-     // objectPut, bucketPutACL or bucketDelete, proceed with request.
-     // Otherwise return an error to the client
+    // If request is initiateMultipartUpload (requestType objectPut),
+    // objectPut, bucketPutACL or bucketDelete, proceed with request.
+    // Otherwise return an error to the client
     if ((bucket.hasDeletedFlag() || bucket.hasTransientFlag()) &&
         (requestType !== 'objectPut' &&
         requestType !== 'initiateMultipartUpload' &&