Function createMpuObject

tests/unit/api/objectGetAttributes.js:259–315

()

    const partBody = Buffer.from('I am a part\n', 'utf8');

    const createMpuObject = async () => {
        const initiateRequest = {
            bucketName,
            namespace,
            objectKey: objectName,
            headers: { host: `${bucketName}.s3.amazonaws.com` },
            url: `/${objectName}?uploads`,
            actionImplicitDenies: false,
        };

        const [result] = await initiateMultipartUploadAsync(authInfo, initiateRequest, log);
        const json = await parseStringPromise(result);
        const testUploadId = json.InitiateMultipartUploadResult.UploadId[0];
        const partHash = crypto.createHash('md5').update(partBody).digest('hex');

        const completeParts = [];
        for (let i = 1; i <= partCount; i++) {
            const partRequest = new DummyRequest(
                {
                    bucketName,
                    namespace,
                    objectKey: objectName,
                    headers: {
                        host: `${bucketName}.s3.amazonaws.com`,
                        'content-length': '5242880',
                    },
                    parsedContentLength: 5242880,
                    url: `/${objectName}?partNumber=${i}&uploadId=${testUploadId}`,
                    query: {
                        partNumber: String(i),
                        uploadId: testUploadId,
                    },
                    partHash,
                },
                partBody,
            );
            await objectPutPartAsync(authInfo, partRequest, undefined, log);
            completeParts.push(`<Part><PartNumber>${i}</PartNumber><ETag>"${partHash}"</ETag></Part>`);
        }

        const completeBody =
            `<CompleteMultipartUpload>${completeParts.join('')}</CompleteMultipartUpload>`;

        const completeRequest = {
            bucketName,
            namespace,
            objectKey: objectName,
            parsedHost: 's3.amazonaws.com',
            url: `/${objectName}?uploadId=${testUploadId}`,
            headers: { host: `${bucketName}.s3.amazonaws.com` },
            query: { uploadId: testUploadId },
            post: completeBody,
            actionImplicitDenies: false,
        };

        await completeMultipartUploadAsync(authInfo, completeRequest, log);
    };