Function findObjectVersionByUploadId

lib/services.js:431–484

* Finds a specific object version by its uploadId by listing and filtering all versions. * This is used during MPU abort to clean up potentially orphaned object metadata. * @param {string} bucketName - The name of the bucket. * @param {string} objectKey - The key of the object. *

(bucketName, objectKey, uploadId, log, cb)

     * @returns {undefined}
     */
    findObjectVersionByUploadId(bucketName, objectKey, uploadId, log, cb) {
        let keyMarker = null;
        let versionIdMarker = null;
        let foundVersion = null;
        let shouldContinue = true;

        return async.whilst(
            () => shouldContinue && !foundVersion,
            callback => {
                const listParams = {
                    listingType: 'DelimiterVersions',
                    // To only list the specific key, we need to add the versionId separator
                    prefix: `${objectKey}${versioning.VersioningConstants.VersionId.Separator}`,
                    maxKeys: 1000,
                };

                if (keyMarker) {
                    listParams.keyMarker = keyMarker;
                }
                if (versionIdMarker) {
                    listParams.versionIdMarker = versionIdMarker;
                }

                return this.getObjectListing(bucketName, listParams, log, (err, listResponse) => {
                    if (err) {
                        log.error('error listing object versions', { error: err });
                        return callback(err);
                    }

                    // Check each version in current batch for matching uploadId
                    const matchedVersion = (listResponse.Versions || []).find(version =>
                        version.key === objectKey &&
                        version.value &&
                        version.value.uploadId === uploadId
                    );

                    if (matchedVersion) {
                        foundVersion = matchedVersion.value;
                    }

                    // Set up for next iteration if needed
                    if (listResponse.IsTruncated && !foundVersion) {
                        keyMarker = listResponse.NextKeyMarker;
                        versionIdMarker = listResponse.NextVersionIdMarker;
                    } else {
                        shouldContinue = false;
                    }

                    return callback();
                });
            },
            err => cb(err, err ? null : foundVersion)
        );
    },

    /**
     * Gets list of objects ready to be lifecycled