don't use option

Author: baileympearson

src/operations/create_collection.ts

@@ -37,8 +37,7 @@ const ILLEGAL_COMMAND_FIELDS = new Set([
   'bsonRegExp',
   'serializeFunctions',
   'ignoreUndefined',
-  'enableUtf8Validation',
-  'isEncryptedCollection'
+  'enableUtf8Validation'
 ]);
 
 /** @public
@@ -104,9 +103,6 @@ export interface CreateCollectionOptions extends CommandOperationOptions {
    * change streams that listen on this collection.
    */
   changeStreamPreAndPostImages?: { enabled: boolean };
-
-  /** @internal */
-  isEncryptedCollection?: boolean;
 }
 
 /* @internal */
@@ -136,19 +132,6 @@ export class CreateCollectionOperation extends CommandOperation<Collection> {
     session: ClientSession | undefined,
     timeoutContext: TimeoutContext
   ): Promise<Collection> {
-    if (this.options.isEncryptedCollection) {
-      // Creating a QE collection required min server of 7.0.0
-      // TODO(NODE-5353): Get wire version information from connection.
-      if (
-        !server.loadBalanced &&
-        server.description.maxWireVersion < MIN_SUPPORTED_QE_WIRE_VERSION
-      ) {
-        throw new MongoCompatibilityError(
-          `${INVALID_QE_VERSION} The minimum server version required is ${MIN_SUPPORTED_QE_SERVER_VERSION}`
-        );
-      }
-    }
-
     const db = this.db;
     const name = this.name;
     const options = this.options;
@@ -183,17 +166,37 @@ export async function createCollections<TSchema extends Document>(
     db.client.s.options.autoEncryption?.encryptedFieldsMap?.[`${db.databaseName}.${name}`];
 
   if (encryptedFields) {
+    class CreateSupportingFLEv2CollectionOperation extends CreateCollectionOperation {
+      override execute(
+        server: Server,
+        session: ClientSession | undefined,
+        timeoutContext: TimeoutContext
+      ): Promise<Collection> {
+        // Creating a QE collection required min server of 7.0.0
+        // TODO(NODE-5353): Get wire version information from connection.
+        if (
+          !server.loadBalanced &&
+          server.description.maxWireVersion < MIN_SUPPORTED_QE_WIRE_VERSION
+        ) {
+          throw new MongoCompatibilityError(
+            `${INVALID_QE_VERSION} The minimum server version required is ${MIN_SUPPORTED_QE_SERVER_VERSION}`
+          );
+        }
+
+        return super.execute(server, session, timeoutContext);
+      }
+    }
+
     // Create auxilliary collections for queryable encryption support.
     const escCollection = encryptedFields.escCollection ?? `enxcol_.${name}.esc`;
     const ecocCollection = encryptedFields.ecocCollection ?? `enxcol_.${name}.ecoc`;
 
     for (const collectionName of [escCollection, ecocCollection]) {
-      const createOp = new CreateCollectionOperation(db, collectionName, {
+      const createOp = new CreateSupportingFLEv2CollectionOperation(db, collectionName, {
         clusteredIndex: {
           key: { _id: 1 },
           unique: true
         },
-        isEncryptedCollection: true,
         session: options.session
       });
       await executeOperation(db.client, createOp, timeoutContext);