fix(cursor): bubble up resumeTokenChanged event from change streams

lib/cursor/ChangeStream.js

@@ -6,6 +6,12 @@
 
 const EventEmitter = require('events').EventEmitter;
 
+/*!
+ * ignore
+ */
+
+const driverChangeStreamEvents = ['close', 'change', 'end', 'error', 'resumeTokenChanged'];
+
 /*!
  * ignore
  */
@@ -52,7 +58,7 @@ class ChangeStream extends EventEmitter {
           this.closed = true;
         });
 
-        ['close', 'change', 'end', 'error'].forEach(ev => {
+        driverChangeStreamEvents.forEach(ev => {
           this.driverChangeStream.on(ev, data => {
             // Sometimes Node driver still polls after close, so
             // avoid any uncaught exceptions due to closed change streams
@@ -75,7 +81,7 @@ class ChangeStream extends EventEmitter {
       this.closed = true;
     });
 
-    ['close', 'change', 'end', 'error'].forEach(ev => {
+    driverChangeStreamEvents.forEach(ev => {
       this.driverChangeStream.on(ev, data => {
         // Sometimes Node driver still polls after close, so
         // avoid any uncaught exceptions due to closed change streams

test/model.test.js

@@ -3404,7 +3404,7 @@ describe('Model', function() {
         let listener;
 
         before(function() {
-          if (!process.env.REPLICA_SET) {
+          if (!process.env.REPLICA_SET && !process.env.START_REPLICA_SET) {
             this.skip();
           }
         });
@@ -3436,6 +3436,20 @@ describe('Model', function() {
             doc._id.toHexString());
         });
 
+        it('bubbles up resumeTokenChanged events (gh-13607)', async function() {
+          const MyModel = db.model('Test', new Schema({ name: String }));
+
+          const resumeTokenChangedEvent = new Promise(resolve => {
+            changeStream = MyModel.watch();
+            listener = data => resolve(data);
+            changeStream.once('resumeTokenChanged', listener);
+          });
+
+          await MyModel.create({ name: 'test' });
+          const { _data } = await resumeTokenChangedEvent;
+          assert.ok(_data);
+        });
+
         it('using next() and hasNext() (gh-11527)', async function() {
           const MyModel = db.model('Test', new Schema({ name: String }));