Function routeIndexingAPIs

lib/routes/routeBackbeat.js:1606–1640

(request, response, userInfo, log, callback)

const indexingSchema = joi.array().items(indexEntrySchema).min(1);

function routeIndexingAPIs(request, response, userInfo, log, callback) {
    const route = backbeatRoutes[request.method][request.resourceType];

    if (!['GET', 'POST'].includes(request.method)) {
        return callback(errors.MethodNotAllowed);
    }

    if (request.method === 'GET') {
        return route(request, response, userInfo, log, callback);
    }

    const op = request.query.operation;

    if (!op || typeof route[op] !== 'function') {
        log.error('Invalid operation parameter', { operation: op });
        return callback(errors.BadRequest);
    }

    return _getRequestPayload(request, (err, payload) => {
        if (err) {
            return callback(err);
        }

        let parsedIndex;

        try {
            parsedIndex = joi.attempt(JSON.parse(payload), indexingSchema, 'invalid payload');
        } catch (err) {
            log.error('Unable to parse index request body', { error: err });
            return callback(errors.BadRequest);
        }

        return route[op](parsedIndex, request, response, userInfo, log, callback);
    });
}

function routeBackbeatAPIProxy(request, response, requestContexts, log) {
    const path = request.url.replace('/_/backbeat/api/', '/_/');