add in more sensitive/granular tests - can revert if needed

Author: aditi-khare-mongoDB

results.json

@@ -0,0 +1,16 @@
+[
+  {
+    "info": {
+      "test_name": "findManyAndToArrayOld",
+      "tags": [
+        "js-bson"
+      ]
+    },
+    "metrics": [
+      {
+        "name": "megabytes_per_second",
+        "value": 92.01875393495698
+      }
+    ]
+  }
+]

t.mjs

@@ -0,0 +1,33 @@
+import * as fs from 'fs/promises';
+
+import { MongoClient } from './lib/index.js';
+
+const client = await MongoClient.connect('mongodb://localhost/');
+const cursor = client.db('test').aggregate([
+  {
+    $documents: [
+      JSON.parse(
+        await fs.readFile(
+          'test/benchmarks/driverBench/spec/single_and_multi_document/tweet.json',
+          'utf8'
+        )
+      )
+    ]
+  },
+  {
+    $set: {
+      field: {
+        $reduce: {
+          input: [...Array(20).keys()],
+          initialValue: [0],
+          in: { $concatArrays: ['$$value', '$$value'] }
+        }
+      }
+    }
+  },
+  { $unwind: '$field' },
+  { $limit: 1000000 }
+]);
+
+await cursor.toArray();
+await client.close();

test/benchmarks/mongoBench/suites/multiBench.js

@@ -155,6 +155,86 @@ function makeMultiBench(suite) {
         })
         .teardown(dropDb)
         .teardown(disconnectClient)
+    ).benchmark('aggregateAMillionDocuments', benchmark =>
+      benchmark
+        .taskSize(16)
+        .setup(makeMakeClient(mongodbDriver))
+        .setup(connectClient)
+        .setup(initDb)
+        .setup(dropDb)
+        .task(async function () {
+          await this.db
+            .aggregate([
+              { $documents: [{}] },
+              {
+                $set: {
+                  field: {
+                    $reduce: {
+                      input: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19],
+                      initialValue: [0],
+                      in: { $concatArrays: ['$$value', '$$value'] }
+                    }
+                  }
+                }
+              },
+              { $unwind: '$field' },
+              { $limit: 1000000 }
+            ])
+            .toArray();
+        })
+        .teardown(dropDb)
+        .teardown(disconnectClient)
+    )
+    .benchmark('aggregateAMillionTweets', benchmark =>
+      benchmark
+        .taskSize(1500)
+        .setup(makeLoadJSON('tweet.json'))
+        .setup(makeMakeClient(mongodbDriver))
+        .setup(connectClient)
+        .setup(initDb)
+        .setup(dropDb)
+        .task(async function () {
+          await this.db
+            .aggregate([
+              { $documents: [this.doc] },
+              {
+                $set: {
+                  id: {
+                    $reduce: {
+                      input: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19],
+                      initialValue: [0],
+                      in: { $concatArrays: ['$$value', '$$value'] }
+                    }
+                  }
+                }
+              },
+              { $unwind: '$id' },
+              { $limit: 1000000 }
+            ])
+            .toArray();
+        })
+        .teardown(dropDb)
+        .teardown(disconnectClient)
+    )
+    .benchmark('findManyAndEmptyAMillionCursor', benchmark =>
+      benchmark
+        .taskSize(16.22)
+        .setup(makeMakeClient(mongodbDriver))
+        .setup(connectClient)
+        .setup(initDb)
+        .setup(dropDb)
+        .setup(initCollection)
+        .setup(async function () {
+          await this.collection.insertMany(Array.from({ length: 1_000_000 }, () => ({ field: 0 })));
+        })
+        .task(async function findManyAndEmptyCursor() {
+          // eslint-disable-next-line @typescript-eslint/no-unused-vars
+          for await (const _ of this.collection.find({})) {
+            // do nothing
+          }
+        })
+        .teardown(dropDb)
+        .teardown(disconnectClient)
     );
 }