Function bucketPutLogging

lib/api/bucketPutLogging.js:13–89

(authInfo, request, log, callback)

    'The owner for the bucket to be logged and the target bucket must be the same.';

function bucketPutLogging(authInfo, request, log, callback) {
    log.debug('processing request', { method: 'bucketPutLogging' });

    if (!config.serverAccessLogs || config.serverAccessLogs.mode !== serverAccessLogsModes.ENABLED) {
        return callback(errorInstances.NotImplemented);
    }

    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) => {
            const loggingEnabled = parsed.res.getLoggingEnabled();
            if (!loggingEnabled) {
                return next(null, bucket);
            }

            return metadata.getBucket(loggingEnabled.TargetBucket, log, (err, targetBucket) => {
                if (err) {
                    return next(errorInstances.InvalidTargetBucketForLogging.customizeDescription(err.description));
                }

                if (targetBucket.getOwner() !== bucket.getOwner()) {
                    return next(errorInstances.InvalidTargetBucketForLogging
                        .customizeDescription(ERROR_MSG_SOURCE_TARGET_BUCKET_OWNER_MISMATCH));
                }

                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);