Function _getMPUBucket

lib/api/initiateMultipartUpload.js:153–213

(destinationBucket, log, corsHeaders,
    uploadId, cipherBundle, locConstraint, callback)

    }

    function _getMPUBucket(destinationBucket, log, corsHeaders,
    uploadId, cipherBundle, locConstraint, callback) {
        const xmlParams = {
            bucketName,
            objectKey,
            uploadId,
        };
        const xml = convertToXml('initiateMultipartUpload', xmlParams);
        metadataStoreParams.uploadId = uploadId;

        services.getMPUBucket(destinationBucket, bucketName, log,
            (err, MPUbucket) => {
                if (err) {
                    log.trace('error getting MPUbucket', {
                        error: err,
                    });
                    return callback(err);
                }
                // BACKWARD: Remove to remove the old splitter
                if (MPUbucket.getMdBucketModelVersion() < 2) {
                    metadataStoreParams.splitter = constants.oldSplitter;
                }
                return services.metadataStoreMPObject(MPUbucket.getName(),
                    cipherBundle, metadataStoreParams,
                    log, (err, mpuMD) => {
                        if (err) {
                            log.trace('error storing multipart object', {
                                error: err,
                            });
                            monitoring.promMetrics('PUT', bucketName, err.code,
                                'initiateMultipartUpload');
                            return callback(err, null, corsHeaders);
                        }
                        log.addDefaultFields({ uploadId });
                        log.trace('successfully initiated mpu');
                        pushMetric('initiateMultipartUpload', log, {
                            authInfo,
                            bucket: bucketName,
                            keys: [objectKey],
                            location: locConstraint,
                        });

                        // TODO: rename corsHeaders to headers
                        setExpirationHeaders(corsHeaders, {
                            lifecycleConfig: destinationBucket.getLifecycleConfiguration(),
                            mpuParams: {
                                key: mpuMD.key,
                                date: mpuMD.initiated,
                            },
                        });

                        setSSEHeaders(corsHeaders,
                            mpuMD['x-amz-server-side-encryption'],
                            mpuMD['x-amz-server-side-encryption-aws-kms-key-id']);

                        monitoring.promMetrics('PUT', bucketName, '200',
                            'initiateMultipartUpload');
                        return callback(null, xml, corsHeaders);