SERVER-58423 Parse and validate change stream open parameter "fullDocument"

1 files changed, 26 insertions, 0 deletions

diff --git a/jstests/change_streams/lookup_pit_post_image.js b/jstests/change_streams/lookup_pit_post_image.js
new file mode 100644
index 00000000000..5bb2bc9ec14
--- /dev/null
+++ b/jstests/change_streams/lookup_pit_post_image.js
@@ -0,0 +1,26 @@
+// Tests the behaviour of $changeStream's 'fullDocument' option when retrieving point-in-time
+// post-images.
+(function() {
+"use strict";
+
+load("jstests/libs/collection_drop_recreate.js");  // For assertDropAndRecreateCollection.
+load("jstests/libs/change_stream_util.js");        // For isChangeStreamPreAndPostImagesEnabled.
+
+const testDB = db.getSiblingDB(jsTestName());
+const coll = assertDropAndRecreateCollection(testDB, "test");
+
+if (!isChangeStreamPreAndPostImagesEnabled(db)) {
+    // If feature flag is off, creating changeStream with new fullDocument arguments should throw.
+    assert.throwsWithCode(() => coll.watch([], {fullDocument: 'whenAvailable'}),
+                          ErrorCodes.BadValue);
+    assert.throwsWithCode(() => coll.watch([], {fullDocument: 'required'}), ErrorCodes.BadValue);
+
+    jsTestLog(
+        'Skipping test because featureFlagChangeStreamsPreAndPostImages feature flag is not enabled');
+    return;
+}
+
+// Open the change streams with new fullDocument parameters.
+assert.doesNotThrow(() => coll.watch([], {fullDocument: 'whenAvailable'}));
+assert.doesNotThrow(() => coll.watch([], {fullDocument: 'required'}));
+}());