Method handleFind

src/Routers/AggregateRouter.js:8–80

(req)

export class AggregateRouter extends ClassesRouter {
  async handleFind(req) {
    const body = Object.assign(req.body || {}, ClassesRouter.JSONFromQuery(req.query));
    const options = {};
    if (body.distinct) {
      options.distinct = String(body.distinct);
    }
    if (body.hint) {
      options.hint = body.hint;
      delete body.hint;
    }
    if (body.explain) {
      options.explain = body.explain;
      delete body.explain;
    }
    if (body.comment) {
      options.comment = body.comment;
      delete body.comment;
    }
    if (body.readPreference) {
      options.readPreference = body.readPreference;
      delete body.readPreference;
    }
    if (typeof body.rawValues === 'boolean') {
      options.rawValues = body.rawValues;
      delete body.rawValues;
    }
    if (typeof body.rawFieldNames === 'boolean') {
      options.rawFieldNames = body.rawFieldNames;
      delete body.rawFieldNames;
    }
    const queryOptions = (req.config && req.config.query) || {};
    if (options.rawValues === undefined && typeof queryOptions.aggregationRawValues === 'boolean') {
      options.rawValues = queryOptions.aggregationRawValues;
    }
    if (
      options.rawFieldNames === undefined &&
      typeof queryOptions.aggregationRawFieldNames === 'boolean'
    ) {
      options.rawFieldNames = queryOptions.aggregationRawFieldNames;
    }
    options.pipeline = AggregateRouter.getPipeline(body);
    if (typeof body.where === 'string') {
      try {
        body.where = JSON.parse(body.where);
      } catch {
        throw new Parse.Error(Parse.Error.INVALID_JSON, 'where parameter is not valid JSON');
      }
    }
    try {
      const response = await rest.find(
        req.config,
        req.auth,
        this.className(req),
        body.where,
        options,
        req.info.clientSDK,
        req.info.context
      );