Function validateQueryAndHeaders

lib/utilities/validateQueryAndHeaders.js:24–64

* validateQueryAndHeaders - Check request for unsupported queries or headers * @param {object} request - request object * @param {object} log - Werelogs logger * @return {object} - empty object or object with error boolean property

(request, log)

 * @return {object} - empty object or object with error boolean property
 */
function validateQueryAndHeaders(request, log) {
    const reqMethod = request.method;
    const reqQuery = request.query;
    const reqHeaders = request.headers;
    const isBucketQuery = !request.objectKey;
    // if the request is at bucket level, check for unsupported bucket queries
    if (isBucketQuery) {
        const unsupportedQuery =
            _validateKeys(constants.unsupportedBucketQueries, reqQuery);
        if (unsupportedQuery) {
            log.debug('encountered unsupported query', {
                query: unsupportedQuery,
                method: 'validateQueryAndHeaders',
            });
            return { error: errors.NotImplemented };
        }
    }
    const unsupportedQuery = _validateKeys(constants.unsupportedQueries,
        reqQuery);
    if (unsupportedQuery) {
        log.debug('encountered unsupported query', {
            query: unsupportedQuery,
            method: 'validateQueryAndHeaders',
        });
        return { error: errors.NotImplemented };
    }
    const unsupportedHeader = _validateKeys(constants.unsupportedHeaders,
        reqHeaders);
    if (unsupportedHeader) {
        log.debug('encountered unsupported header', {
            header: unsupportedHeader,
            method: 'validateQueryAndHeaders',
        });
        // for now only unsupported headers are encryption headers and we only
        // return NotImplemented on a PUT
        if (reqMethod.toUpperCase() === 'PUT') {
            return { error: errors.NotImplemented };
        }
    }
    return {};
}

module.exports = validateQueryAndHeaders;