CLDSRV-754: add GetBucketLogging and PutBucketLogging endpoints

Author: leif-scality

lib/api/api.js

@@ -75,6 +75,8 @@ const { tagConditionKeyAuth } = require('./apiUtils/authorization/tagConditionKe
 const { isRequesterASessionUser } = require('./apiUtils/authorization/permissionChecks');
 const checkHttpHeadersSize = require('./apiUtils/object/checkHttpHeadersSize');
 const { validateMethodChecksumNoChunking } = require('./apiUtils/integrity/validateChecksums');
+const bucketPutLogging = require('./bucketPutLogging');
+const bucketGetLogging = require('./bucketGetLogging');
 
 const monitoringMap = policies.actionMaps.actionMonitoringMapS3;
 
@@ -380,6 +382,8 @@ const api = {
     serviceGet,
     websiteGet: website,
     websiteHead: website,
+    bucketPutLogging,
+    bucketGetLogging,
 };
 
 module.exports = api;

lib/api/bucketGetLogging.js

@@ -0,0 +1,55 @@
+const { standardMetadataValidateBucket } = require('../metadata/metadataUtils');
+const { checkExpectedBucketOwner } = require('./apiUtils/authorization/bucketOwner');
+const monitoring = require('../utilities/monitoringHandler');
+const { waterfall } = require('async');
+
+const BucketLoggingStatusNotFoundBody = '<?xml version="1.0" encoding="UTF-8"?>\n' +
+    '<BucketLoggingStatus xmlns="http://doc.s3.amazonaws.com/2006-03-01" />';
+
+function bucketGetLogging(authInfo, request, log, callback) {
+    log.debug('processing request', { method: 'bucketGetLogging' });
+
+    const bucketName = request.bucketName;
+    const metadataValParams = {
+        authInfo,
+        bucketName,
+        requestType: request.apiMethods || 'bucketGetLogging',
+        request,
+    };
+
+    return waterfall([
+        next => standardMetadataValidateBucket(metadataValParams, request.actionImplicitDenies, log, (err, bucket) => {
+            if (err) {
+                return next(err);
+            }
+
+            return next(null, bucket);
+        }),
+        (bucket, next) => checkExpectedBucketOwner(request.headers, bucket, log, err => {
+            if (err) {
+                return next(err);
+            }
+
+            return next(null, bucket);
+        }),
+        (bucket, next) => {
+            const bucketLoggingStatus = bucket.getBucketLoggingStatus();
+            if (!bucketLoggingStatus) {
+                return next(null, BucketLoggingStatusNotFoundBody);
+            }
+
+            return next(null, bucketLoggingStatus.toXML());
+        }
+    ], (err, body) => {
+        if (err) {
+            log.trace('error processing request', { error: err, method: 'bucketGetLogging' });
+            monitoring.promMetrics('GET', bucketName, err.code, 'bucketGetLogging');
+            return callback(err);
+        }
+
+        monitoring.promMetrics('GET', bucketName, '200', 'bucketGetLogging');
+        return callback(null, body);
+    });
+}
+
+module.exports = bucketGetLogging;

lib/api/bucketPutLogging.js

@@ -0,0 +1,63 @@
+const { waterfall } = require('async');
+const { standardMetadataValidateBucket } = require('../metadata/metadataUtils');
+const { checkExpectedBucketOwner } = require('./apiUtils/authorization/bucketOwner');
+const BucketLoggingStatus = require('arsenal').models.BucketLoggingStatus;
+const metadata = require('../metadata/wrapper');
+const monitoring = require('../utilities/monitoringHandler');
+
+function bucketPutLogging(authInfo, request, log, callback) {
+    log.debug('processing request', { method: 'bucketPutLogging' });
+
+    const bucketName = request.bucketName;
+    const parsed = BucketLoggingStatus.fromXML(request.post);
+    if (parsed.error) {
+        log.trace('error processing request', { error: parsed.error, method: 'bucketPutLogging' });
+        monitoring.promMetrics('PUT', bucketName, parsed.error.arsenalError, 'bucketPutLogging');
+        return callback(parsed.error.arsenalError);
+    }
+
+    const metadataValParams = {
+        authInfo,
+        bucketName,
+        requestType: request.apiMethods || 'bucketPutLogging',
+        request,
+    };
+
+    return waterfall([
+        next => standardMetadataValidateBucket(metadataValParams, request.actionImplicitDenies, log, (err, bucket) => {
+            if (err) {
+                return next(err);
+            }
+
+            return next(null, bucket);
+        }),
+        (bucket, next) => checkExpectedBucketOwner(request.headers, bucket, log, err => {
+            if (err) {
+                return next(err);
+            }
+
+            return next(null, bucket);
+        }),
+        (bucket, next) => {
+            bucket.setBucketLoggingStatus(parsed.res);
+            return metadata.updateBucket(bucket.getName(), bucket, log, err => {
+                if (err) {
+                    return next(err);
+                }
+
+                return next();
+            });
+        },
+    ], err => {
+        if (err) {
+            log.trace('error processing request', { error: err, method: 'bucketPutLogging' });
+            monitoring.promMetrics('PUT', bucketName, err.code, 'bucketPutLogging');
+            return callback(err);
+        }
+
+        monitoring.promMetrics('PUT', bucketName, '200', 'bucketPutLogging');
+        return callback();
+    });
+}
+
+module.exports = bucketPutLogging;