fix(change-streams): don't copy irrelevant resume options

mongodb · Aug 13, 2019 · f190072 · f190072
1 parent f6dd6c9
commit f190072
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/lib/change_stream.js b/lib/change_stream.js
@@ -272,10 +272,14 @@ class ChangeStreamCursor extends Cursor {
       if (this.options[optionName]) result[optionName] = this.options[optionName];
     }
 
-    if (this.resumeToken) {
-      Object.assign(result, { resumeAfter: this.resumeToken });
-    } else if (this.startAtOperationTime && maxWireVersion(this.server) >= 7) {
-      Object.assign(result, { startAtOperationTime: this.startAtOperationTime });
+    if (this.resumeToken || this.startAtOperationTime) {
+      ['resumeAfter', 'startAfter', 'startAtOperationTime'].forEach(key => delete result[key]);
+
+      if (this.resumeToken) {
+        result.resumeAfter = this.resumeToken;
+      } else if (this.startAtOperationTime && maxWireVersion(this.server) >= 7) {
+        result.startAtOperationTime = this.startAtOperationTime;
+      }
     }
 
     return result;