Function createBucket

lib/api/apiUtils/bucket/bucketCreation.js:166–295

* Creates bucket * @param {AuthInfo} authInfo - Instance of AuthInfo class with * requester's info * @param {string} bucketName - name of bucket * @param {object} headers - request headers * @param {string} locationConstraint - locationConstraint provided in *

(authInfo, bucketName, headers,
    locationConstraint, log, cb)

 * @return {undefined}
 */
function createBucket(authInfo, bucketName, headers,
    locationConstraint, log, cb) {
    // Prefer using undefined instead of null for unused properties so they are not present in metadata payload
    log.trace('Creating bucket');
    assert.strictEqual(typeof bucketName, 'string');
    const canonicalID = authInfo.getCanonicalID();
    const ownerDisplayName =
        authInfo.getAccountDisplayName();
    const creationDate = new Date().toJSON();
    const isNFSEnabled = headers['x-scal-nfs-enabled'] === 'true' || undefined;
    const headerObjectLock = headers['x-amz-bucket-object-lock-enabled'];
    const objectLockEnabled
        = headerObjectLock && headerObjectLock.toLowerCase() === 'true';
    const bucket = new BucketInfo(bucketName, canonicalID, ownerDisplayName,
        creationDate, BucketInfo.currentModelVersion(), undefined, undefined, undefined, undefined,
        undefined, undefined, undefined, undefined, undefined, undefined, undefined, undefined, undefined, isNFSEnabled,
        undefined, undefined, objectLockEnabled);
    let locationConstraintVal = null;

    if (locationConstraint) {
        const [locationConstraintStr, ingestion] =
            locationConstraint.split(zenkoSeparator);
        if (locationConstraintStr) {
            locationConstraintVal = locationConstraintStr;
            bucket.setLocationConstraint(locationConstraintStr);
        }
        if (ingestion === 'ingest') {
            bucket.enableIngestion();
            //automatically enable versioning for ingestion buckets
            bucket.setVersioningConfiguration({ Status: 'Enabled' });
        }
    }
    if (objectLockEnabled) {
        // default versioning configuration AWS sets
        // when a bucket is created with object lock
        const versioningConfiguration = {
            Status: 'Enabled',
            MfaDelete: 'Disabled',
        };
        bucket.setVersioningConfiguration(versioningConfiguration);
    }
    const parseAclParams = {
        headers,
        resourceType: 'bucket',
        acl: bucket.acl,
        log,
    };
    async.parallel({
        prepareNewBucketMD: function prepareNewBucketMD(callback) {
            acl.parseAclFromHeaders(parseAclParams, (err, parsedACL) => {
                if (err) {
                    log.debug('error parsing acl from headers', {
                        error: err,
                    });
                    return callback(err);
                }
                bucket.setFullAcl(parsedACL);
                return callback(null, bucket);