Develop

lib/graphql/applyPaginationToMongoAggregate.js

@@ -34,7 +34,11 @@ export default async function applyPaginationToMongoAggregate(collection, pipeli
 
   if (last) {
     // Get the new count after applying before/after
-    const totalCount = await collection.aggregate(pipeline).count();
+    const lastPipeline = [...pipeline];
+    lastPipeline.push({
+      "$count": "count"
+    });
+    const totalCount = await collection.aggregate(lastPipeline).count;
     if (totalCount > last) {
       skip = totalCount - last;
     }
@@ -54,7 +58,10 @@ export default async function applyPaginationToMongoAggregate(collection, pipeli
         prevPipeline.push({
           "$skip": skip - 1
         });
-        const prevCursorCount = await collection.aggregate(prevPipeline).count();
+        prevPipeline.push({
+          "$count": "count"
+        });
+        const prevCursorCount = await collection.aggregate(prevPipeline).count;
         hasPreviousPage = prevCursorCount > limit;
       }
     }
@@ -67,7 +74,10 @@ export default async function applyPaginationToMongoAggregate(collection, pipeli
     nextPipeline.push({
       "$limit": limit + 1
     });
-    const nextCursorCount = await collection.aggregate(nextPipeline).count();
+    nextPipeline.push({
+      "$count": "count"
+    });
+    const nextCursorCount = await collection.aggregate(nextPipeline).count;
     hasNextPage = nextCursorCount > limit;
   }
 

lib/graphql/getPaginatedResponseFromAggregate.js

@@ -66,7 +66,7 @@ async function getPaginatedResponseFromAggregate(collection, pipeline, args, {
        * Set `totalCount` inside of our objects, since we'll replace the root in the next stage.
        */
       $set: {
-        "$objects.totalCount": "$totalCount"
+        "objects.totalCount": "$totalCount"
       }
     }, {
       /**