wip

Author: nbbeeken

src/index.ts

@@ -45,6 +45,7 @@ export {
 export { ClientEncryption } from './client-side-encryption/client_encryption';
 export { ChangeStreamCursor } from './cursor/change_stream_cursor';
 export {
+  ConnectionPoolClosedError,
   MongoAPIError,
   MongoAWSError,
   MongoAzureError,
@@ -53,6 +54,7 @@ export {
   MongoClientBulkWriteCursorError,
   MongoClientBulkWriteError,
   MongoClientBulkWriteExecutionError,
+  MongoClientClosedError,
   MongoCompatibilityError,
   MongoCursorExhaustedError,
   MongoCursorInUseError,

src/mongo_client.ts

@@ -636,7 +636,9 @@ export class MongoClient extends TypedEventEmitter<MongoClientEvents> implements
   }
 
   /**
-   * Cleans up client-side resources used by the MongoCLient and .  This includes:
+   * Cleans up client-side resources used by the MongoClient.
+   *
+   * This includes:
    *
    * - Closes all open, unused connections (see note).
    * - Ends all in-use sessions with {@link ClientSession#endSession|ClientSession.endSession()}.

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

@@ -63,6 +63,7 @@ describe('Change Streams', function () {
     await csDb.createCollection('test').catch(() => null);
     collection = csDb.collection('test');
     changeStream = collection.watch();
+    changeStream.on('error', () => null);
   });
 
   afterEach(async () => {
@@ -702,15 +703,19 @@ describe('Change Streams', function () {
 
       const outStream = new PassThrough({ objectMode: true });
 
-      // @ts-expect-error: transform requires a Document return type
-      changeStream.stream({ transform: JSON.stringify }).pipe(outStream);
+      const transform = doc => ({ doc: JSON.stringify(doc) });
+      changeStream
+        .stream({ transform })
+        .on('error', () => null)
+        .pipe(outStream)
+        .on('error', () => null);
 
       const willBeData = once(outStream, 'data');
 
       await collection.insertMany([{ a: 1 }]);
 
       const [data] = await willBeData;
-      const parsedEvent = JSON.parse(data);
+      const parsedEvent = JSON.parse(data.doc);
       expect(parsedEvent).to.have.nested.property('fullDocument.a', 1);
 
       outStream.destroy();

test/integration/index_management.test.ts

@@ -770,20 +770,19 @@ describe('Indexes', function () {
 
           expect(events).to.be.an('array').with.lengthOf(1);
           expect(events[0]).nested.property('command.commitQuorum').to.equal(0);
-          await collection.drop(err => {
-            expect(err).to.not.exist;
-          });
+          await collection.drop();
         }
       };
     }
     it(
       'should run command with commitQuorum if specified on db.createIndex',
-      commitQuorumTest((db, collection) =>
-        db.createIndex(collection.collectionName, 'a', {
-          // @ts-expect-error revaluate this?
-          writeConcern: { w: 'majority' },
-          commitQuorum: 0
-        })
+      commitQuorumTest(
+        async (db, collection) =>
+          await db.createIndex(collection.collectionName, 'a', {
+            // @ts-expect-error revaluate this?
+            writeConcern: { w: 'majority' },
+            commitQuorum: 0
+          })
       )
     );
     it(

test/integration/node-specific/examples/causal_consistency.test.js

@@ -31,8 +31,8 @@ describe('examples(causal-consistency):', function () {
   it('supports causal consistency', async function () {
     const session = client.startSession({ causalConsistency: true });
 
-    collection.insertOne({ darmok: 'jalad' }, { session });
-    collection.updateOne({ darmok: 'jalad' }, { $set: { darmok: 'tanagra' } }, { session });
+    await collection.insertOne({ darmok: 'jalad' }, { session });
+    await collection.updateOne({ darmok: 'jalad' }, { $set: { darmok: 'tanagra' } }, { session });
 
     const results = await collection.find({}, { session }).toArray();