test: Change tests to use native MongoDB aggregation pipeline syntax

.github/workflows/ci.yml

@@ -34,6 +34,9 @@ jobs:
     steps:
     - name: Fix usage of insecure GitHub protocol
       run: sudo git config --system url."https://github".insteadOf "git://github"
+    - name: Fix git protocol for Node 14
+      if: ${{ startsWith(matrix.NODE_VERSION, '14.') }}
+      run: sudo git config --system url."https://github".insteadOf "ssh://git@github"
     - uses: actions/checkout@v2
     - name: Use Node.js
       uses: actions/setup-node@v1

integration/test/ParseQueryAggregateTest.js

@@ -14,7 +14,7 @@ describe('Parse Aggregate Query', () => {
 
   it('aggregate pipeline object query', done => {
     const pipeline = {
-      group: { objectId: '$name' },
+      $group: { _id: '$name' },
     };
     const query = new Parse.Query(TestObject);
     query.aggregate(pipeline).then(results => {
@@ -24,7 +24,7 @@ describe('Parse Aggregate Query', () => {
   });
 
   it('aggregate pipeline array query', done => {
-    const pipeline = [{ group: { objectId: '$name' } }];
+    const pipeline = [{ $group: { _id: '$name' } }];
     const query = new Parse.Query(TestObject);
     query.aggregate(pipeline).then(results => {
       assert.equal(results.length, 3);
@@ -53,17 +53,17 @@ describe('Parse Aggregate Query', () => {
 
     const pipeline = [
       {
-        match: { name: 'Hello' },
+        $match: { name: 'Hello' },
       },
       {
         // Transform className$objectId to objectId and store in new field tempPointer
-        project: {
+        $project: {
           tempPointer: { $substr: ['$_p_pointer', 11, -1] }, // Remove TestObject$
         },
       },
       {
         // Left Join, replace objectId stored in tempPointer with an actual object
-        lookup: {
+        $lookup: {
           from: 'TestObject',
           localField: 'tempPointer',
           foreignField: '_id',
@@ -72,12 +72,12 @@ describe('Parse Aggregate Query', () => {
       },
       {
         // lookup returns an array, Deconstructs an array field to objects
-        unwind: {
+        $unwind: {
           path: '$tempPointer',
         },
       },
       {
-        match: { 'tempPointer.value': 2 },
+        $match: { 'tempPointer.value': 2 },
       },
     ];
     await Parse.Object.saveAll([pointer1, pointer2, pointer3, obj1, obj2, obj3]);
@@ -91,7 +91,7 @@ describe('Parse Aggregate Query', () => {
 
   it('aggregate pipeline on top of a simple query', async done => {
     const pipeline = {
-      group: { objectId: '$name' },
+      $group: { _id: '$name' },
     };
     let results = await new Parse.Query(TestObject).equalTo('name', 'foo').aggregate(pipeline);
 

src/ParseQuery.js

@@ -832,7 +832,7 @@ class ParseQuery {
       if (!Array.isArray(pipeline)) {
         pipeline = [pipeline];
       }
-      pipeline.unshift({ match: this._where });
+      pipeline.unshift({ $match: this._where });
     }
 
     const params = {