Function metadataSearch

lib/api/metadataSearch.js:45–147

* metadataSearch - Return list of objects in bucket that meet the search query, supports v1 & v2 * @param {AuthInfo} authInfo - Instance of AuthInfo class with * requester's info * @param {object} request - http request object * @param {function} log - Werelogs r

(authInfo, request, log, callback)

 * @return {undefined}
 */
function metadataSearch(authInfo, request, log, callback) {
    const params = request.query;
    const bucketName = request.bucketName;
    const v2 = params['list-type'];
    if (v2 !== undefined && Number.parseInt(v2, 10) !== 2) {
        return callback(errorInstances.InvalidArgument.customizeDescription('Invalid ' +
            'List Type specified in Request'));
    }
    log.debug('processing request', { method: 'metadataSearch' });
    const encoding = params['encoding-type'];
    if (encoding !== undefined && encoding !== 'url') {
        monitoring.promMetrics(
            'GET', bucketName, 400, 'metadataSearch');
        return callback(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, 'metadataSearch');
        return callback(errors.InvalidArgument);
    }
    // AWS only returns 1000 keys even if max keys are greater.
    // Max keys stated in response xml can be greater than actual
    // keys returned.
    const actualMaxKeys = Math.min(constants.listingHardLimit, requestMaxKeys);

    const metadataValParams = {
        authInfo,
        bucketName,
        requestType: request.apiMethods || 'metadataSearch',
        request,
    };
    const listParams = {
        listingType: 'DelimiterMaster',
        maxKeys: actualMaxKeys,
        delimiter: params.delimiter,
        prefix: params.prefix,
    };
    try {
        const validatedAst = validateSearchParams(params.search).ast;
        listParams.mongifiedSearch = parseWhere(validatedAst);
    } catch (err) {
        log.debug(err.message, {
            stack: err.stack,
        });
        monitoring.promMetrics(
            'GET', bucketName, 400, 'metadataSearch');
        return callback(errorInstances.InvalidArgument
            .customizeDescription('Invalid sql where clause ' +
                'sent as search query'));
    }
    if (v2) {
        listParams.v2 = true;
        listParams.startAfter = params['start-after'];
        listParams.continuationToken =
            decryptToken(params['continuation-token']);