Function bucketGet

lib/api/bucketGet.js:287–406

* bucketGet - Return list of objects in bucket, supports v1 & v2 * @param {AuthInfo} authInfo - Instance of AuthInfo class with * requester's info * @param {object} request - http request object * @param {function} log - Werelogs request logger * @param {functi

(authInfo, request, log, callback)

 * @throws {Error}
 */
async function bucketGet(authInfo, request, log, callback) {
    if (callback) {
        return bucketGet(authInfo, request, log)
            .then(result => callback(null, ...result))
            .catch(err => callback(err, null, err.additionalResHeaders));
    }

    const params = request.query;
    const bucketName = request.bucketName;
    const v2 = params['list-type'];

    const optionalAttributes = parseAttributesHeaders(
        request.headers,
        'x-amz-optional-object-attributes',
        OPTIONAL_ATTRIBUTES,
    );

    if (v2 !== undefined && Number.parseInt(v2, 10) !== 2) {
        throw errorInstances.InvalidArgument.customizeDescription('Invalid List Type specified in Request');
    }

    if (v2) {
        log.addDefaultFields({ action: 'ListObjectsV2' });
        if (request.serverAccessLog) {
            // eslint-disable-next-line no-param-reassign
            request.serverAccessLog.analyticsAction = 'ListObjectsV2';
        }
    } else if (params.versions !== undefined) {
        log.addDefaultFields({ action: 'ListObjectVersions' });
        if (request.serverAccessLog) {
            // eslint-disable-next-line no-param-reassign
            request.serverAccessLog.analyticsAction = 'ListObjectVersions';
        }
    }
    log.debug('processing request', { method: 'bucketGet' });
    const encoding = params['encoding-type'];
    if (encoding !== undefined && encoding !== 'url') {
        monitoring.promMetrics('GET', bucketName, 400, 'listBucket');
        throw errorInstances.InvalidArgument.customizeDescription('Invalid Encoding Method specified in Request');
    }

    const requestMaxKeys = params['max-keys'] ? Number.parseInt(params['max-keys'], 10) : 1000;
    if (Number.isNaN(requestMaxKeys) || requestMaxKeys < 0) {
        monitoring.promMetrics('GET', bucketName, 400, 'listBucket');
        throw errors.InvalidArgument;
    }
    const actualMaxKeys = Math.min(constants.listingHardLimit, requestMaxKeys);

    const metadataValParams = {
        authInfo,
        bucketName,
        requestType: request.apiMethods || 'bucketGet',
        request,
    };
    const listParams = {
        listingType: 'DelimiterMaster',
        maxKeys: actualMaxKeys,
        prefix: params.prefix,