move prose test to to server only

Author: baileympearson

test/integration/client-side-operations-timeout/client_side_operations_timeout.prose.test.ts

@@ -8,6 +8,7 @@ import { pipeline } from 'stream/promises';
 
 import { type CommandStartedEvent } from '../../../mongodb';
 import {
+  type AnyClientBulkWriteModel,
   type CommandSucceededEvent,
   GridFSBucket,
   MongoBulkWriteError,
@@ -19,6 +20,7 @@ import {
   promiseWithResolvers
 } from '../../mongodb';
 import { type FailPoint } from '../../tools/utils';
+import { filterForCommands } from '../shared';
 
 // TODO(NODE-5824): Implement CSOT prose tests
 describe('CSOT spec prose tests', function () {
@@ -1106,7 +1108,7 @@ describe('CSOT spec prose tests', function () {
 
   describe(
     '11. Multi-batch bulkWrites',
-    { requires: { mongodb: '>=8.0', serverless: 'forbid' } },
+    { requires: { mongodb: '>=8.0', serverless: 'forbid', topology: 'single' } },
     function () {
       /**
        * ### 11. Multi-batch bulkWrites
@@ -1154,47 +1156,42 @@ describe('CSOT spec prose tests', function () {
        *
        * 7. Verify that two `bulkWrite` commands were executed as part of the `MongoClient.bulkWrite` call.
        */
-      const failpoint: FailPoint = {
-        configureFailPoint: 'failCommand',
-        mode: {
-          times: 2
-        },
-        data: {
-          failCommands: ['bulkWrite'],
-          blockConnection: true,
-          blockTimeMS: 1010
-        }
-      };
 
-      let maxBsonObjectSize: number;
-      let maxMessageSizeBytes: number;
+      let models: AnyClientBulkWriteModel[];
+      const writes: CommandStartedEvent[] = [];
 
       beforeEach(async function () {
         await internalClient
           .db('db')
           .collection('coll')
           .drop()
           .catch(() => null);
-        await internalClient.db('admin').command(failpoint);
-
-        const hello = await internalClient.db('admin').command({ hello: 1 });
-        maxBsonObjectSize = hello.maxBsonObjectSize;
-        maxMessageSizeBytes = hello.maxMessageSizeBytes;
-
-        client = this.configuration.newClient({ timeoutMS: 2000, monitorCommands: true });
-      });
+        await internalClient.db('admin').command(<FailPoint>{
+          configureFailPoint: 'failCommand',
+          mode: {
+            times: 2
+          },
+          data: {
+            failCommands: ['bulkWrite'],
+            blockConnection: true,
+            blockTimeMS: 1010
+          }
+        });
 
-      it('performs two bulkWrites which fail to complete before 2000 ms', async function () {
-        const writes = [];
-        client.on('commandStarted', ev => writes.push(ev));
+        const { maxBsonObjectSize, maxMessageSizeBytes } = await this.configuration.hello();
 
         const length = maxMessageSizeBytes / maxBsonObjectSize + 1;
-        const models = Array.from({ length }, () => ({
+        models = Array.from({ length }, () => ({
           namespace: 'db.coll',
           name: 'insertOne' as const,
           document: { a: 'b'.repeat(maxBsonObjectSize - 500) }
         }));
 
+        client = this.configuration.newClient({ timeoutMS: 2000, monitorCommands: true });
+        client.on('commandStarted', filterForCommands('bulkWrite', writes));
+      });
+
+      it('performs two bulkWrites which fail to complete before 2000 ms', async function () {
         const error = await client.bulkWrite(models).catch(error => error);
 
         expect(error, error.stack).to.be.instanceOf(MongoOperationTimeoutError);