test?

Author: baileympearson

test/integration/crud/explain.test.ts

@@ -10,7 +10,12 @@ import {
   MongoOperationTimeoutError,
   MongoServerError
 } from '../../mongodb';
-import { clearFailPoint, configureFailPoint, measureDuration } from '../../tools/utils';
+import {
+  clearFailPoint,
+  configureFailPoint,
+  measureDuration,
+  waitUntilPoolsFilled
+} from '../../tools/utils';
 import { filterForCommands } from '../shared';
 
 const explain = [true, false, 'queryPlanner', 'allPlansExecution', 'executionStats', 'invalid'];
@@ -312,16 +317,22 @@ describe('CRUD API explain option', function () {
     }
 
     beforeEach(async function () {
-      client = this.configuration.newClient({}, { monitorCommands: true });
+      client = this.configuration.newClient(
+        {},
+        { monitorCommands: true, minPoolSize: 5, appName: 'explain-test' }
+      );
       client.on('commandStarted', filterForCommands('explain', commands));
 
+      waitUntilPoolsFilled(client, AbortSignal.timeout(30_000), 4);
+
       await configureFailPoint(this.configuration, {
         configureFailPoint: 'failCommand',
         mode: { times: 1 },
         data: {
           failCommands: ['explain'],
           blockConnection: true,
-          blockTimeMS: 1000
+          blockTimeMS: 1000,
+          appName: 'explain-tests'
         }
       });
     });
@@ -525,7 +536,7 @@ describe('CRUD API explain option', function () {
             cursor.explain({ verbosity: 'queryPlanner' }).catch(e => e)
           );
           expect(result).to.be.instanceOf(MongoOperationTimeoutError);
-          expect(duration).to.be.within(1000, 1000 + 100);
+          expect(duration).to.be.within(1000 - 100, 1000 + 100);
         });
       });
 
@@ -537,7 +548,7 @@ describe('CRUD API explain option', function () {
             cursor.explain({ verbosity: 'queryPlanner' }, { timeoutMS: 1000 }).catch(e => e)
           );
           expect(result).to.be.instanceOf(MongoOperationTimeoutError);
-          expect(duration).to.be.within(1000, 1000 + 100);
+          expect(duration).to.be.within(1000 - 100, 1000 + 100);
         });
       });
 
@@ -548,7 +559,7 @@ describe('CRUD API explain option', function () {
             cursor.explain({ verbosity: 'queryPlanner' }, { timeoutMS: 1000 }).catch(e => e)
           );
           expect(result).to.be.instanceOf(MongoOperationTimeoutError);
-          expect(duration).to.be.within(1000, 1000 + 100);
+          expect(duration).to.be.within(1000 - 100, 1000 + 100);
         });
       });
 
@@ -560,7 +571,7 @@ describe('CRUD API explain option', function () {
           );
 
           expect(result).to.be.instanceOf(MongoOperationTimeoutError);
-          expect(duration).to.be.within(1000, 1000 + 100);
+          expect(duration).to.be.within(1000 - 100, 1000 + 100);
         });
       });
 
@@ -572,7 +583,7 @@ describe('CRUD API explain option', function () {
           );
 
           expect(result).to.be.instanceOf(MongoOperationTimeoutError);
-          expect(duration).to.be.within(1000, 1000 + 100);
+          expect(duration).to.be.within(1000 - 100, 1000 + 100);
         });
       });
 
@@ -582,7 +593,7 @@ describe('CRUD API explain option', function () {
           const { duration, result } = await measureDuration(() =>
             cursor.explain({ verbosity: 'queryPlanner' }, { timeoutMS: 1000 }).catch(e => e)
           );
-          expect(duration).to.be.within(1000, 1000 + 100);
+          expect(duration).to.be.within(1000 - 100, 1000 + 100);
           expect(result).to.be.instanceOf(MongoOperationTimeoutError);
         });
       });

test/tools/runner/config.ts

@@ -7,6 +7,7 @@ import {
   type AuthMechanism,
   HostAddress,
   MongoClient,
+  type MongoClientOptions,
   type ServerApi,
   TopologyType,
   type WriteConcernSettings
@@ -176,7 +177,7 @@ export class TestConfiguration {
     return uri.indexOf('MONGODB-OIDC') > -1 && uri.indexOf(`ENVIRONMENT:${env}`) > -1;
   }
 
-  newClient(urlOrQueryOptions?: string | Record<string, any>, serverOptions?: Record<string, any>) {
+  newClient(urlOrQueryOptions?: string | Record<string, any>, serverOptions?: MongoClientOptions) {
     serverOptions = Object.assign({}, getEnvironmentalOptions(), serverOptions);
 
     // Support MongoClient constructor form (url, options) for `newClient`.