Function putMPU

tests/unit/api/objectReplicationMD.js:165–204

(key, body, cb)

// Initiate an MPU, put a part with the given body, and complete the MPU.
function putMPU(key, body, cb) {
    const uploadId = '9a0364b9e99bb480dd25e1f0284c8555';
    createShadowBucket(key, uploadId);
    const partBody = Buffer.from(body, 'utf8');
    const md5Hash = crypto.createHash('md5').update(partBody);
    const calculatedHash = md5Hash.digest('hex');
    const partKey = `${uploadId}${constants.splitter}00001`;
    const obj = {
        partLocations: [{
            key: 1,
            dataStoreName: 'scality-internal-mem',
            dataStoreETag: `1:${calculatedHash}`,
        }],
        key: partKey,
    };
    obj['content-md5'] = calculatedHash;
    obj['content-length'] = body.length;
    metadata.keyMaps.get(mpuShadowBucket).set(partKey, new Map);
    const partMap = metadata.keyMaps.get(mpuShadowBucket).get(partKey);
    Object.assign(partMap, obj);
    const postBody =
        '<CompleteMultipartUpload>' +
            '<Part>' +
                '<PartNumber>1</PartNumber>' +
                `<ETag>"${calculatedHash}"</ETag>` +
            '</Part>' +
        '</CompleteMultipartUpload>';
    const req = {
        bucketName,
        namespace,
        objectKey: key,
        parsedHost: 's3.amazonaws.com',
        url: `/${key}?uploadId=${uploadId}`,
        headers: { host: `${bucketName}.s3.amazonaws.com` },
        query: { uploadId },
        post: postBody,
        actionImplicitDenies: false,
    };
    return completeMultipartUpload(authInfo, req, log, cb);
}

// Copy an object where replication does not apply.
function copyObject(sourceObjectKey, copyObjectKey, hasContent, cb) {