chore: limit server type

Author: nbbeeken

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

@@ -597,112 +597,118 @@ describe('CSOT spec prose tests', function () {
       'TODO(DRIVERS-2347): Requires this ticket to be implemented before we can assert on connection CSOT behaviour';
   });
 
-  describe(
-    '9. endSession',
-    { requires: { topology: ['replicaset', 'sharded', 'load-balanced'] } },
-    () => {
-      /**
-       * This test MUST only be run against replica sets and sharded clusters with server version 4.4 or higher. It MUST be
-       * run three times: once with the timeout specified via the MongoClient `timeoutMS` option, once with the timeout
-       * specified via the ClientSession `defaultTimeoutMS` option, and once more with the timeout specified via the
-       * `timeoutMS` option for the `endSession` operation. In all cases, the timeout MUST be set to 10 milliseconds.
-       *
-       * 1. Using `internalClient`, drop the `db.coll` collection.
-       * 1. Using `internalClient`, set the following fail point:
-       * ```js
-       * {
-       *     configureFailPoint: failCommand,
-       *     mode: { times: 1 },
-       *     data: {
-       *         failCommands: ["abortTransaction"],
-       *         blockConnection: true,
-       *         blockTimeMS: 15
-       *     }
-       * }
-       * ```
-       * 1. Create a new MongoClient (referred to as `client`) and an explicit ClientSession derived from that MongoClient (referred to as `session`).
-       * 1. Execute the following code:
-       * ```ts
-       *   coll = client.database("db").collection("coll")
-       *   session.start_transaction()
-       *   coll.insert_one({x: 1}, session=session)
-       * ```
-       * 1. Using `session`, execute `session.end_session`
-       *    - Expect this to fail with a timeout error after no more than 15ms.
-       */
-      const failpoint: FailPoint = {
-        configureFailPoint: 'failCommand',
-        mode: { times: 1 },
-        data: {
-          failCommands: ['abortTransaction'],
-          blockConnection: true,
-          blockTimeMS: 60
-        }
-      };
-
-      beforeEach(async function () {
-        if (!semver.satisfies(this.configuration.version, '>=4.4')) {
-          this.skipReason = 'Requires server version 4.4+';
-          this.skip();
-        }
-        const internalClient = this.configuration.newClient();
-        await internalClient
-          .db('db')
-          .collection('coll')
-          .drop()
-          .catch(() => null);
-        await internalClient.db('admin').command(failpoint);
-        await internalClient.close();
-      });
+  describe('9. endSession', () => {
+    /**
+     * This test MUST only be run against replica sets and sharded clusters with server version 4.4 or higher. It MUST be
+     * run three times: once with the timeout specified via the MongoClient `timeoutMS` option, once with the timeout
+     * specified via the ClientSession `defaultTimeoutMS` option, and once more with the timeout specified via the
+     * `timeoutMS` option for the `endSession` operation. In all cases, the timeout MUST be set to 10 milliseconds.
+     *
+     * 1. Using `internalClient`, drop the `db.coll` collection.
+     * 1. Using `internalClient`, set the following fail point:
+     * ```js
+     * {
+     *     configureFailPoint: failCommand,
+     *     mode: { times: 1 },
+     *     data: {
+     *         failCommands: ["abortTransaction"],
+     *         blockConnection: true,
+     *         blockTimeMS: 15
+     *     }
+     * }
+     * ```
+     * 1. Create a new MongoClient (referred to as `client`) and an explicit ClientSession derived from that MongoClient (referred to as `session`).
+     * 1. Execute the following code:
+     * ```ts
+     *   coll = client.database("db").collection("coll")
+     *   session.start_transaction()
+     *   coll.insert_one({x: 1}, session=session)
+     * ```
+     * 1. Using `session`, execute `session.end_session`
+     *    - Expect this to fail with a timeout error after no more than 15ms.
+     */
+    const failpoint: FailPoint = {
+      configureFailPoint: 'failCommand',
+      mode: { times: 1 },
+      data: {
+        failCommands: ['abortTransaction'],
+        blockConnection: true,
+        blockTimeMS: 60
+      }
+    };
+
+    beforeEach(async function () {
+      if (!semver.satisfies(this.configuration.version, '>=4.4')) {
+        this.skipReason = 'Requires server version 4.4+';
+        this.skip();
+      }
+
+      if (
+        !['Sharded', 'ReplicaSetWithPrimary', 'ReplicaSetNoPrimary'].includes(
+          this.configuration.topologyType
+        )
+      ) {
+        this.skipReason = 'Requires replicaset or sharded clusters';
+        this.skip();
+      }
+
+      const internalClient = this.configuration.newClient();
+      await internalClient
+        .db('db')
+        .collection('coll')
+        .drop()
+        .catch(() => null);
+      await internalClient.db('admin').command(failpoint);
+      await internalClient.close();
+    });
 
-      let client: MongoClient;
+    let client: MongoClient;
 
-      afterEach(async function () {
-        if (semver.satisfies(this.configuration.version, '>=4.4')) {
-          const internalClient = this.configuration.newClient();
-          await internalClient.db('admin').command({ ...failpoint, mode: 'off' });
-          await internalClient.close();
-        }
-        await client?.close();
-      });
+    afterEach(async function () {
+      if (semver.satisfies(this.configuration.version, '>=4.4')) {
+        const internalClient = this.configuration.newClient();
+        await internalClient.db('admin').command({ ...failpoint, mode: 'off' });
+        await internalClient.close();
+      }
+      await client?.close();
+    });
 
-      describe('when timeoutMS is provided to the client', () => {
-        it('throws a timeout error from endSession', async function () {
-          client = this.configuration.newClient({ timeoutMS: 50, monitorCommands: true });
-          const coll = client.db('db').collection('coll');
-          const session = client.startSession();
-          session.startTransaction();
-          await coll.insertOne({ x: 1 }, { session });
-          const error = await session.endSession().catch(error => error);
-          expect(error).to.be.instanceOf(MongoOperationTimeoutError);
-        });
+    describe('when timeoutMS is provided to the client', () => {
+      it('throws a timeout error from endSession', async function () {
+        client = this.configuration.newClient({ timeoutMS: 50, monitorCommands: true });
+        const coll = client.db('db').collection('coll');
+        const session = client.startSession();
+        session.startTransaction();
+        await coll.insertOne({ x: 1 }, { session });
+        const error = await session.endSession().catch(error => error);
+        expect(error).to.be.instanceOf(MongoOperationTimeoutError);
       });
+    });
 
-      describe('when defaultTimeoutMS is provided to startSession', () => {
-        it('throws a timeout error from endSession', async function () {
-          client = this.configuration.newClient();
-          const coll = client.db('db').collection('coll');
-          const session = client.startSession({ defaultTimeoutMS: 50 });
-          session.startTransaction();
-          await coll.insertOne({ x: 1 }, { session });
-          const error = await session.endSession().catch(error => error);
-          expect(error).to.be.instanceOf(MongoOperationTimeoutError);
-        });
+    describe('when defaultTimeoutMS is provided to startSession', () => {
+      it('throws a timeout error from endSession', async function () {
+        client = this.configuration.newClient();
+        const coll = client.db('db').collection('coll');
+        const session = client.startSession({ defaultTimeoutMS: 50 });
+        session.startTransaction();
+        await coll.insertOne({ x: 1 }, { session });
+        const error = await session.endSession().catch(error => error);
+        expect(error).to.be.instanceOf(MongoOperationTimeoutError);
       });
+    });
 
-      describe('when timeoutMS is provided to endSession', () => {
-        it('throws a timeout error from endSession', async function () {
-          client = this.configuration.newClient();
-          const coll = client.db('db').collection('coll');
-          const session = client.startSession();
-          session.startTransaction();
-          await coll.insertOne({ x: 1 }, { session });
-          const error = await session.endSession({ timeoutMS: 50 }).catch(error => error);
-          expect(error).to.be.instanceOf(MongoOperationTimeoutError);
-        });
+    describe('when timeoutMS is provided to endSession', () => {
+      it('throws a timeout error from endSession', async function () {
+        client = this.configuration.newClient();
+        const coll = client.db('db').collection('coll');
+        const session = client.startSession();
+        session.startTransaction();
+        await coll.insertOne({ x: 1 }, { session });
+        const error = await session.endSession({ timeoutMS: 50 }).catch(error => error);
+        expect(error).to.be.instanceOf(MongoOperationTimeoutError);
       });
-    }
-  );
+    });
+  });
 
   describe(
     '10. Convenient Transactions',