Fix Aggregate Match Pointer (#4643)

Author: dplewis

spec/ParseQuery.Aggregate.spec.js

@@ -13,6 +13,10 @@ const masterKeyOptions = {
   json: true
 }
 
+const PointerObject = Parse.Object.extend({
+  className: "PointerObject"
+});
+
 const loadTestData = () => {
   const data1 = {score: 10, name: 'foo', sender: {group: 'A'}, views: 900, size: ['S', 'M']};
   const data2 = {score: 10, name: 'foo', sender: {group: 'A'}, views: 800, size: ['M', 'L']};
@@ -448,8 +452,8 @@ describe('Parse.Query Aggregate testing', () => {
   });
 
   it('match pointer query', (done) => {
-    const pointer1 = new TestObject();
-    const pointer2 = new TestObject();
+    const pointer1 = new PointerObject();
+    const pointer2 = new PointerObject();
     const obj1 = new TestObject({ pointer: pointer1 });
     const obj2 = new TestObject({ pointer: pointer2 });
     const obj3 = new TestObject({ pointer: pointer1 });
@@ -618,8 +622,8 @@ describe('Parse.Query Aggregate testing', () => {
   });
 
   it('distinct pointer', (done) => {
-    const pointer1 = new TestObject();
-    const pointer2 = new TestObject();
+    const pointer1 = new PointerObject();
+    const pointer2 = new PointerObject();
     const obj1 = new TestObject({ pointer: pointer1 });
     const obj2 = new TestObject({ pointer: pointer2 });
     const obj3 = new TestObject({ pointer: pointer1 });

src/Adapters/Storage/Mongo/MongoStorageAdapter.js

@@ -567,7 +567,7 @@ export class MongoStorageAdapter implements StorageAdapter {
       if (stage.$match) {
         for (const field in stage.$match) {
           if (schema.fields[field] && schema.fields[field].type === 'Pointer') {
-            const transformMatch = { [`_p_${field}`] : `${className}$${stage.$match[field]}` };
+            const transformMatch = { [`_p_${field}`] : `${schema.fields[field].targetClass}$${stage.$match[field]}` };
             stage.$match = transformMatch;
           }
           if (field === 'objectId') {

src/Routers/PurgeRouter.js

@@ -1,5 +1,6 @@
 import PromiseRouter from '../PromiseRouter';
 import * as middleware from '../middlewares';
+import Parse from 'parse/node';
 
 export class PurgeRouter extends PromiseRouter {