fix: type

Author: durran

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

@@ -170,6 +170,26 @@ describe('Change Streams', function () {
     }
   });
 
+  it('contains a wallType date property on the change', {
+    metadata: { requires: { topology: 'replicaset', mongodb: '>=6.0.0' } },
+    async test() {
+      const collection = db.collection('wallTimeTest');
+      const changeStream = collection.watch(pipeline);
+
+      const willBeChanges = on(changeStream, 'change');
+      await once(changeStream.cursor, 'init');
+
+      await collection.insertOne({ d: 4 });
+
+      const change = (await willBeChanges.next()).value[0];
+
+      await changeStream.close();
+
+      expect(change).to.have.property('wallTime');
+      expect(change.wallType).to.be.instanceOf(Date);
+    }
+  });
+
   it('should create a ChangeStream on a collection and emit change events', {
     metadata: { requires: { topology: 'replicaset' } },
     async test() {
@@ -1259,8 +1279,7 @@ describe('Change Streams', function () {
       // Running on replicaset because other topologies are finiky with the cluster-wide events
       // Dropping and renaming and creating collections in order to achieve a clean slate isn't worth the goal of these tests
       // We just want to show that the new ChangeStreamDocument type information can reproduced in a real env
-      topologies: ['replicaset'],
-      minServerVersion: '6.0'
+      topologies: ['replicaset']
     })
     .createEntities([
       { client: { id: 'client0' } },
@@ -1326,7 +1345,6 @@ describe('Change Streams', function () {
             operationType: 'drop',
             ns: { db: 'dbToDrop', coll: 'collInDbToDrop' },
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$exists: false },
             lsid: { $$exists: false }
           }
@@ -1339,7 +1357,6 @@ describe('Change Streams', function () {
             operationType: 'dropDatabase',
             ns: { db: 'dbToDrop', coll: { $$exists: false } },
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$exists: false },
             lsid: { $$exists: false }
           }
@@ -1352,7 +1369,6 @@ describe('Change Streams', function () {
             operationType: 'drop',
             ns: { db: 'dbToDrop', coll: 'collInDbToDrop' },
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$exists: false },
             lsid: { $$exists: false }
           }
@@ -1364,7 +1380,6 @@ describe('Change Streams', function () {
             _id: { $$exists: true },
             operationType: 'invalidate',
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$exists: false },
             lsid: { $$exists: false }
           }
@@ -1425,7 +1440,6 @@ describe('Change Streams', function () {
             documentKey: { _id: 3 },
             ns: { db: 'changeStreamDocShape', coll: 'collection0' },
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$type: ['long', 'int'] },
             lsid: { $$sessionLsid: 'session0' }
           }
@@ -1478,7 +1492,6 @@ describe('Change Streams', function () {
             documentKey: { _id: 3 },
             ns: { db: 'renameDb', coll: 'collToRename' },
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$exists: false },
             lsid: { $$exists: false }
           }
@@ -1504,7 +1517,6 @@ describe('Change Streams', function () {
             ns: { db: 'renameDb', coll: 'collToRename' },
             to: { db: 'renameDb', coll: 'newCollectionName' },
             clusterTime: { $$type: 'timestamp' },
-            wallTime: { $$type: 'date' },
             txnNumber: { $$exists: false },
             lsid: { $$exists: false }
           }