SERVER-34662 fix $changeStream parsing to check that its argument is an object

1 files changed, 11 insertions, 0 deletions

diff --git a/jstests/change_streams/change_stream.js b/jstests/change_streams/change_stream.js
index d0f3755bc17..0d392b99bcc 100644
--- a/jstests/change_streams/change_stream.js
+++ b/jstests/change_streams/change_stream.js
@@ -16,6 +16,17 @@
     assertDropAndRecreateCollection(db, "t1");
     assertDropAndRecreateCollection(db, "t2");
 
+    // Test that $changeStream only accepts an object as its argument.
+    function checkArgFails(arg) {
+        assert.commandFailedWithCode(
+            db.runCommand({aggregate: "t1", pipeline: [{$changeStream: arg}], cursor: {}}), 50808);
+    }
+
+    checkArgFails(1);
+    checkArgFails("invalid");
+    checkArgFails(false);
+    checkArgFails([1, 2, "invalid", {x: 1}]);
+
     // Test that a change stream cannot be opened on collections in the "admin", "config", or
     // "local" databases.
     assertInvalidChangeStreamNss("admin", "testColl");