chore: poc blacklist

Author: durran

src/change_stream.ts

@@ -20,7 +20,7 @@ import type { AggregateOptions } from './operations/aggregate';
 import type { OperationParent } from './operations/command';
 import type { ServerSessionId } from './sessions';
 import { CSOTTimeoutContext, type TimeoutContext } from './timeout';
-import { getTopology, type MongoDBNamespace, squashError } from './utils';
+import { type AnyOptions, getTopology, type MongoDBNamespace, squashError } from './utils';
 
 const CHANGE_DOMAIN_TYPES = {
   COLLECTION: Symbol('Collection'),
@@ -34,6 +34,34 @@ const NO_RESUME_TOKEN_ERROR =
   'A change stream document has been received that lacks a resume token (_id).';
 const CHANGESTREAM_CLOSED_ERROR = 'ChangeStream is closed';
 
+const INVALID_STAGE_OPTIONS = [
+  'raw',
+  'useBigInt64',
+  'promoteLongs',
+  'promoteValues',
+  'promoteBuffers',
+  'ignoreUndefined',
+  'bsonRegExp',
+  'serializeFunctions',
+  'fieldsAsRaw',
+  'enableUtf8Validation',
+  'timeoutMS',
+  'readPreference'
+];
+
+export function filterOutOptions(options: AnyOptions, names: ReadonlyArray<string>): AnyOptions {
+  const filterOptions: AnyOptions = {};
+
+  for (const name in options) {
+    if (!names.includes(name)) {
+      filterOptions[name] = options[name];
+    }
+  }
+
+  // Filtered options
+  return filterOptions;
+}
+
 /**
  * Represents the logical starting point for a new ChangeStream or resuming a ChangeStream on the server.
  * @see https://www.mongodb.com/docs/manual/changeStreams/#std-label-change-stream-resume
@@ -891,7 +919,7 @@ export class ChangeStream<
   private _createChangeStreamCursor(
     options: ChangeStreamOptions | ChangeStreamCursorOptions
   ): ChangeStreamCursor<TSchema, TChange> {
-    const changeStreamStageOptions: Document = { ...options };
+    const changeStreamStageOptions: Document = filterOutOptions(options, INVALID_STAGE_OPTIONS);
     if (this.type === CHANGE_DOMAIN_TYPES.CLUSTER) {
       changeStreamStageOptions.allChangesForCluster = true;
     }