Function _storetheMPObject

lib/api/initiateMultipartUpload.js:215–305

(destinationBucket, corsHeaders, serverSideEncryption)

    }

    function _storetheMPObject(destinationBucket, corsHeaders, serverSideEncryption) {
        let cipherBundle = null;
        if (serverSideEncryption) {
            const { algorithm, configuredMasterKeyId, masterKeyId } = serverSideEncryption;
            if (configuredMasterKeyId) {
                log.debug('using user configured kms master key id');
            }
            cipherBundle = {
                algorithm,
                masterKeyId: configuredMasterKeyId || masterKeyId,
            };
        }
        const backendInfoObj = locationConstraintCheck(request, null,
            destinationBucket, log);
        if (backendInfoObj.err) {
            return process.nextTick(() => {
                callback(backendInfoObj.err);
            });
        }
        const locConstraint = backendInfoObj.controllingLC;
        metadataStoreParams.controllingLocationConstraint = locConstraint;
        metadataStoreParams.dataStoreName = locConstraint;

        if (request.headers) {
            const objectLockValError =
                validateHeaders(destinationBucket, request.headers, log);
            if (objectLockValError) {
                return callback(objectLockValError);
            }
        }
        const defaultRetention = destinationBucket.getObjectLockConfiguration();
        const finalObjectLockInfo =
            compareObjectLockInformation(request.headers, defaultRetention);

        if (finalObjectLockInfo.retentionInfo) {
            metadataStoreParams.retentionMode =
                finalObjectLockInfo.retentionInfo.mode;
            metadataStoreParams.retentionDate =
                finalObjectLockInfo.retentionInfo.date;
        }
        if (finalObjectLockInfo.legalHold) {
            metadataStoreParams.legalHold = finalObjectLockInfo.legalHold;
        }

        let uploadId;
        const mpuInfo = {
            objectKey,
            metaHeaders,
            bucketName,
            locConstraint,
            destinationBucket,
            tagging,
        };

        const putVersionId = request.headers['x-scal-s3-version-id'];
        const isPutVersion = putVersionId || putVersionId === '';
        if (isPutVersion &&
            locConstraint === destinationBucket.getLocationConstraint() &&