fix: Parse.Query.distinct fails due to invalid aggregate stage 'hint'

spec/ParseQuery.spec.js

@@ -6,6 +6,8 @@
 
 const Parse = require('parse/node');
 const request = require('../lib/request');
+const ParseServerRESTController = require('../lib/ParseServerRESTController').ParseServerRESTController;
+const ParseServer = require('../lib/ParseServer').default;
 
 const masterKeyHeaders = {
   'X-Parse-Application-Id': 'test',
@@ -5275,4 +5277,33 @@ describe('Parse.Query testing', () => {
     // Validate
     expect(result.executionStats).not.toBeUndefined();
   });
+
+  it('should query with distinct within eachBatch and direct access enabled', async () => {
+    await reconfigureServer({
+      directAccess: true,
+    });
+
+    Parse.CoreManager.setRESTController(
+      ParseServerRESTController(Parse.applicationId, ParseServer.promiseRouter({ appId: Parse.applicationId }))
+    );
+
+    const user = new Parse.User();
+    user.set('username', 'foo');
+    user.set('password', 'bar');
+    await user.save();
+
+    const score = new Parse.Object('Score');
+    score.set('player', user);
+    score.set('score', 1);
+    await score.save();
+
+    await new Parse.Query('_User')
+      .equalTo('objectId', user.id)
+      .eachBatch(async ([user]) => {
+        const score = await new Parse.Query('Score')
+          .equalTo('player', user)
+          .distinct('score', { useMasterKey: true });
+        expect(score).toEqual([1]);
+      }, { useMasterKey: true });
+  });
 });

src/Routers/AggregateRouter.js

@@ -1,7 +1,7 @@
-import ClassesRouter from './ClassesRouter';
-import rest from '../rest';
-import * as middleware from '../middlewares';
 import Parse from 'parse/node';
+import * as middleware from '../middlewares';
+import rest from '../rest';
+import ClassesRouter from './ClassesRouter';
 import UsersRouter from './UsersRouter';
 
 export class AggregateRouter extends ClassesRouter {
@@ -11,20 +11,20 @@
     if (body.distinct) {
       options.distinct = String(body.distinct);
     }
-    if (body.hint) {
-      options.hint = body.hint;
+    if (Object.prototype.hasOwnProperty.call(body, 'hint')) {
+      if (body.hint) options.hint = body.hint;
       delete body.hint;
     }
-    if (body.explain) {
-      options.explain = body.explain;
+    if (Object.prototype.hasOwnProperty.call(body, 'explain')) {
+      if (body.explain) options.explain = body.explain;
       delete body.explain;
     }
-    if (body.comment) {
-      options.comment = body.comment;
+    if (Object.prototype.hasOwnProperty.call(body, 'comment')) {
+      if (body.comment) options.comment = body.comment;
       delete body.comment;
     }
-    if (body.readPreference) {
-      options.readPreference = body.readPreference;
+    if (Object.prototype.hasOwnProperty.call(body, 'readPreference')) {
+      if (body.readPreference) options.readPreference = body.readPreference;
       delete body.readPreference;
     }
     options.pipeline = AggregateRouter.getPipeline(body);
@@ -52,7 +52,7 @@
   }
 
   /* Builds a pipeline from the body. Originally the body could be passed as a single object,
-   * and now we support many options
+   * and now we support many options.
    *
    * Array
    *
@@ -71,7 +71,7 @@
    *
    * body: {
    *   pipeline: {
-   *     group: { objectId: '$name' },
+   *     $group: { objectId: '$name' },
    *   }
    * }
    *