everything passing?

Author: baileympearson

test/integration/connection-monitoring-and-pooling/connection.test.ts

@@ -268,7 +268,15 @@ describe('Connection', function () {
         // This test exists to prevent regression of processing many messages inside one chunk.
         it(
           'processes all of them and emits heartbeats',
-          { requires: { topology: 'replicaset', mongodb: '>=4.4' } },
+          {
+            requires: {
+              topology: 'replicaset',
+              mongodb: '>=4.4',
+              // When compression is enabled, processing heartbeat events is asynchronous.
+              predicate: () =>
+                process.env.COMPRESSOR ? 'test requires that compression is disabled' : true
+            }
+          },
           async function () {
             let hbSuccess = 0;
             client.on('serverHeartbeatSucceeded', () => (hbSuccess += 1));
@@ -291,6 +299,7 @@ describe('Connection', function () {
 
             // All of the hb will be emitted synchronously in the next tick as the entire chunk is processed.
             await processTick();
+
             expect(hbSuccess).to.be.greaterThan(1000);
           }
         );

test/integration/node-specific/bson-options/utf8_validation.test.ts

@@ -95,9 +95,8 @@ describe('parsing of utf8-invalid documents with cursors', function () {
       if (providedBuffer.includes(targetBytes)) {
         if (providedBuffer.split(targetBytes).length !== 2) {
           sinon.restore();
-          const message = `too many target bytes sequences: received ${
-            providedBuffer.split(targetBytes).length
-          }`;
+          const message = `too many target bytes sequences: received ${providedBuffer.split(targetBytes).length
+            }`;
           throw new Error(message);
         }
         const buffer = Buffer.from(providedBuffer.replace(targetBytes, 'c301'.repeat(8)), 'hex');
@@ -121,7 +120,7 @@ describe('parsing of utf8-invalid documents with cursors', function () {
   beforeEach(async function () {
     if (typeof compressionPredicate() === 'string') {
       this.currentTest.skipReason = compressionPredicate() as string;
-      this.currentTest.skip();
+      this.skip();
     }
     client = this.configuration.newClient();
     await client.connect();
@@ -134,7 +133,7 @@ describe('parsing of utf8-invalid documents with cursors', function () {
 
   afterEach(async function () {
     sinon.restore();
-    await client.close();
+    await client?.close();
   });
 
   context('when utf-8 validation is explicitly disabled', function () {

test/tools/unified-spec-runner/entities.ts

@@ -212,7 +212,7 @@ export class UnifiedMongoClient extends MongoClient {
       ...getEnvironmentalOptions(),
       ...(description.serverApi ? { serverApi: description.serverApi } : {}),
       // TODO(NODE-5785): We need to increase the truncation length because signature.hash is a Buffer making hellos too long
-      mongodbLogMaxDocumentLength: 1250
+      mongodbLogMaxDocumentLength: 1300
     };
 
     let logCollector: { buffer: LogMessage[]; write: (log: Log) => void } | undefined;

test/tools/unified-spec-runner/match.ts

@@ -461,16 +461,14 @@ function compareCommandStartedEvents(
   if (expected!.commandName) {
     expect(
       expected!.commandName,
-      `expected ${prefix}.commandName to equal ${expected!.commandName} but received ${
-        actual.commandName
+      `expected ${prefix}.commandName to equal ${expected!.commandName} but received ${actual.commandName
       }`
     ).to.equal(actual.commandName);
   }
   if (expected!.databaseName) {
     expect(
       expected!.databaseName,
-      `expected ${prefix}.databaseName to equal ${expected!.databaseName} but received ${
-        actual.databaseName
+      `expected ${prefix}.databaseName to equal ${expected!.databaseName} but received ${actual.databaseName
       }`
     ).to.equal(actual.databaseName);
   }
@@ -488,8 +486,7 @@ function compareCommandSucceededEvents(
   if (expected!.commandName) {
     expect(
       expected!.commandName,
-      `expected ${prefix}.commandName to equal ${expected!.commandName} but received ${
-        actual.commandName
+      `expected ${prefix}.commandName to equal ${expected!.commandName} but received ${actual.commandName
       }`
     ).to.equal(actual.commandName);
   }
@@ -504,8 +501,7 @@ function compareCommandFailedEvents(
   if (expected!.commandName) {
     expect(
       expected!.commandName,
-      `expected ${prefix}.commandName to equal ${expected!.commandName} but received ${
-        actual.commandName
+      `expected ${prefix}.commandName to equal ${expected!.commandName} but received ${actual.commandName
       }`
     ).to.equal(actual.commandName);
   }