Function _uploadMpuObject

tests/unit/api/multipartUpload.js:155–183

(params = {})

const _bucketPut = util.promisify(bucketPut);

async function _uploadMpuObject(params = {}) {
    const _initiateMultipartUpload = async (...params) => {
        const result = await util.promisify(initiateMultipartUpload)(...params);
        const json = await parseStringPromise(result);
        return json.InitiateMultipartUploadResult.UploadId[0];
    };
    const _objectPutPart = util.promisify(objectPutPart);
    const _completeMultipartUpload = (...params) => util.promisify(cb =>
        completeMultipartUpload(...params, (err, xml, headers) => cb(err, { xml, headers })))();

    const headers = { ...initiateRequest.headers };
    if (params.location) {
        headers[constants.objectLocationConstraintHeader] = params.location;
    }
    if (params.versionID) {
        headers['x-scal-s3-version-id'] = params.versionID;
    }

    const uploadId = await _initiateMultipartUpload(authInfo, { ...initiateRequest, headers }, log);

    const partRequest = _createPutPartRequest(uploadId, 1, Buffer.from('I am a part\n', 'utf8'));
    partRequest.headers = headers;
    const eTag = await _objectPutPart(authInfo, partRequest, undefined, log);

    const completeRequest = _createCompleteMpuRequest(uploadId, [{ partNumber: 1, eTag }]);
    const resp = await _completeMultipartUpload(authInfo, { ...completeRequest, headers }, log);

    return resp.headers;
}

describe('Multipart Upload API', () => {
    beforeEach(() => {