test(NODE-6858): lower heartbeat to handle primary termination

Author: tadjik1

src/error.ts

@@ -1551,9 +1551,9 @@ export function isResumableError(error?: Error, wireVersion?: number): boolean {
     return true;
   }
 
-  if (error instanceof MongoServerSelectionError) {
-    return true;
-  }
+  // if (error instanceof MongoServerSelectionError) {
+  //   return true;
+  // }
 
   if (wireVersion != null && wireVersion >= 9) {
     // DRIVERS-1308: For 4.4 drivers running against 4.4 servers, drivers will add a special case to treat the CursorNotFound error code as resumable

test/integration/change-streams/change_stream.test.ts

@@ -1820,7 +1820,7 @@ describe('Change Streams', function () {
   });
 });
 
-describe('ChangeStream resumability', function () {
+describe.only('ChangeStream resumability', function () {
   let client: MongoClient;
   let collection: Collection;
   let changeStream: ChangeStream;
@@ -1888,11 +1888,15 @@ describe('ChangeStream resumability', function () {
     // so generating unique appname instead of cleaning for each test is an easier solution
     appName = new UUID().toString();
 
-    client = this.configuration.newClient({
-      monitorCommands: true,
-      serverSelectionTimeoutMS: 5_000,
-      appName: appName
-    });
+    client = this.configuration.newClient(
+      {},
+      {
+        monitorCommands: true,
+        serverSelectionTimeoutMS: 5_000,
+        heartbeatFrequencyMS: 500,
+        appName: appName
+      }
+    );
     client.on('commandStarted', filterForCommands(['aggregate'], aggregateEvents));
     collection = client.db(dbName).collection(collectionName);
   });
@@ -2085,7 +2089,8 @@ describe('ChangeStream resumability', function () {
               .db('admin')
               .command({ replSetFreeze: 0 }, { readPreference: ReadPreference.SECONDARY });
             await client.db('admin').command({ replSetStepDown: 30, force: true });
-            await sleep(1500);
+
+            await sleep(500);
 
             const change = await changeStream.next();
             expect(change).to.containSubset({ operationType: 'insert', fullDocument: { a: 1 } });
@@ -2438,7 +2443,8 @@ describe('ChangeStream resumability', function () {
               .db('admin')
               .command({ replSetFreeze: 0 }, { readPreference: ReadPreference.SECONDARY });
             await client.db('admin').command({ replSetStepDown: 30, force: true });
-            await sleep(1500);
+
+            await sleep(500);
 
             const change = await changeStream.tryNext();
             expect(change).to.containSubset({ operationType: 'insert', fullDocument: { a: 1 } });
@@ -2615,7 +2621,8 @@ describe('ChangeStream resumability', function () {
               .db('admin')
               .command({ replSetFreeze: 0 }, { readPreference: ReadPreference.SECONDARY });
             await client.db('admin').command({ replSetStepDown: 30, force: true });
-            await sleep(1500);
+
+            await sleep(500);
 
             const change = await changeStreamIterator.next();
             expect(change.value).to.containSubset({