Revert "create collection"

This reverts commit bd8fb4b.

Author: baileympearson

src/operations/create_collection.ts

@@ -1,17 +1,16 @@
-import { type Connection } from '..';
 import type { Document } from '../bson';
 import {
   MIN_SUPPORTED_QE_SERVER_VERSION,
   MIN_SUPPORTED_QE_WIRE_VERSION
 } from '../cmap/wire_protocol/constants';
-import { MongoDBResponse } from '../cmap/wire_protocol/responses';
 import { Collection } from '../collection';
 import type { Db } from '../db';
 import { MongoCompatibilityError } from '../error';
 import type { PkFactory } from '../mongo_client';
+import type { Server } from '../sdam/server';
 import type { ClientSession } from '../sessions';
 import { TimeoutContext } from '../timeout';
-import { type CommandOperationOptions, ModernizedCommandOperation } from './command';
+import { CommandOperation, type CommandOperationOptions } from './command';
 import { executeOperation } from './execute_operation';
 import { CreateIndexesOperation } from './indexes';
 import { Aspect, defineAspects } from './operation';
@@ -111,8 +110,7 @@ const INVALID_QE_VERSION =
   'Driver support of Queryable Encryption is incompatible with server. Upgrade server to use Queryable Encryption.';
 
 /** @internal */
-export class CreateCollectionOperation extends ModernizedCommandOperation<Collection> {
-  override SERVER_COMMAND_RESPONSE_TYPE = MongoDBResponse;
+export class CreateCollectionOperation extends CommandOperation<Collection> {
   override options: CreateCollectionOptions;
   db: Db;
   name: string;
@@ -129,20 +127,25 @@ export class CreateCollectionOperation extends ModernizedCommandOperation<Collec
     return 'create' as const;
   }
 
-  override buildCommandDocument(_connection: Connection, _session?: ClientSession): Document {
-    const cmd: Document = { create: this.name };
-    for (const [option, value] of Object.entries(this.options)) {
+  override async execute(
+    server: Server,
+    session: ClientSession | undefined,
+    timeoutContext: TimeoutContext
+  ): Promise<Collection> {
+    const db = this.db;
+    const name = this.name;
+    const options = this.options;
+
+    const cmd: Document = { create: name };
+    for (const [option, value] of Object.entries(options)) {
       if (value != null && typeof value !== 'function' && !ILLEGAL_COMMAND_FIELDS.has(option)) {
         cmd[option] = value;
       }
     }
-    return cmd;
-  }
 
-  override handleOk(
-    _response: InstanceType<typeof this.SERVER_COMMAND_RESPONSE_TYPE>
-  ): Collection<Document> {
-    return new Collection(this.db, this.name, this.options);
+    // otherwise just execute the command
+    await super.executeCommand(server, session, cmd, timeoutContext);
+    return new Collection(db, name, options);
   }
 }
 
@@ -164,17 +167,23 @@ export async function createCollections<TSchema extends Document>(
 
   if (encryptedFields) {
     class CreateSupportingFLEv2CollectionOperation extends CreateCollectionOperation {
-      override buildCommandDocument(connection: Connection, session?: ClientSession): Document {
+      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 (
-          !connection.description.loadBalanced &&
-          Number(connection.description.maxWireVersion) < MIN_SUPPORTED_QE_WIRE_VERSION
+          !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.buildCommandDocument(connection, session);
+        return super.execute(server, session, timeoutContext);
       }
     }