Function bucketPutLifecycle

lib/api/bucketPutLifecycle.js:23–80

* Bucket Put Lifecycle - Create or update bucket lifecycle configuration * @param {AuthInfo} authInfo - Instance of AuthInfo class with requester's info * @param {object} request - http request object * @param {object} log - Werelogs logger * @param {function} callback - callback to server * @r

(authInfo, request, log, callback)

 */

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

    const { bucketName } = request;
    const metadataValParams = {
        authInfo,
        bucketName,
        requestType: request.apiMethods || 'bucketPutLifecycle',
        request,
    };
    return waterfall([
        next => parseXML(request.post, log, next),
        (parsedXml, next) => {
            const lcConfigClass =
                new LifecycleConfiguration(parsedXml, config);
            // if there was an error getting lifecycle configuration,
            // returned configObj will contain 'error' key
            process.nextTick(() => {
                const configObj = lcConfigClass.getLifecycleConfiguration();
                if (configObj.error) {
                    return next(configObj.error);
                }
                return next(null, configObj);
            });
        },
        (lcConfig, next) => standardMetadataValidateBucket(metadataValParams, request.actionImplicitDenies, log,
            (err, bucket) => {
                if (err) {
                    return next(err, bucket);
                }
                return next(null, bucket, lcConfig);
            }),
        (bucket, lcConfig, next) => {
            if (!bucket.getUid()) {
                bucket.setUid(uuid());
            }
            bucket.setLifecycleConfiguration(lcConfig);
            metadata.updateBucket(bucket.getName(), bucket, log, err =>
                next(err, bucket));
        },
    ], (err, bucket) => {
        const corsHeaders = collectCorsHeaders(request.headers.origin,
            request.method, bucket);
        if (err) {
            log.trace('error processing request', { error: err,
                method: 'bucketPutLifecycle' });
            monitoring.promMetrics(
                'PUT', bucketName, err.code, 'putBucketLifecycle');
            return callback(err, corsHeaders);
        }
        pushMetric('putBucketLifecycle', log, {
            authInfo,
            bucket: bucketName,
        });
        monitoring.promMetrics('PUT', bucketName, '200', 'putBucketLifecycle');
        return callback(null, corsHeaders);
    });
}