remove 'IndexExistsOperation'

Author: baileympearson

src/collection.ts

@@ -55,7 +55,6 @@ import {
   type DropIndexesOptions,
   DropIndexOperation,
   type IndexDescription,
-  IndexExistsOperation,
   IndexInformationOperation,
   type IndexSpecification,
   type ListIndexesOptions
@@ -91,7 +90,8 @@ import {
   DEFAULT_PK_FACTORY,
   MongoDBCollectionNamespace,
   normalizeHintField,
-  resolveOptions
+  resolveOptions,
+  setDifference
 } from './utils';
 import { WriteConcern, type WriteConcernOptions } from './write_concern';
 
@@ -684,10 +684,12 @@ export class Collection<TSchema extends Document = Document> {
     indexes: string | string[],
     options?: IndexInformationOptions
   ): Promise<boolean> {
-    return executeOperation(
-      this.client,
-      new IndexExistsOperation(this as TODO_NODE_3286, indexes, resolveOptions(this, options))
-    );
+    const indexNames: Set<string> = new Set([indexes].flat());
+    const allIndexes: string[] = await this.listIndexes(options)
+      .map(({ name }) => name)
+      .toArray();
+
+    return setDifference(indexNames, allIndexes).size === 0;
   }
 
   /**

src/operations/indexes.ts

@@ -337,43 +337,6 @@ export class ListIndexesOperation extends CommandOperation<Document> {
   }
 }
 
-/** @internal */
-export class IndexExistsOperation extends AbstractOperation<boolean> {
-  override options: IndexInformationOptions;
-  collection: Collection;
-  indexes: string | string[];
-
-  constructor(
-    collection: Collection,
-    indexes: string | string[],
-    options: IndexInformationOptions
-  ) {
-    super(options);
-    this.options = options;
-    this.collection = collection;
-    this.indexes = indexes;
-  }
-
-  override get commandName() {
-    return 'listIndexes' as const;
-  }
-
-  override async execute(server: Server, session: ClientSession | undefined): Promise<boolean> {
-    const coll = this.collection;
-    const indexes = this.indexes;
-
-    const info = await indexInformation(coll.s.db, coll.collectionName, {
-      ...this.options,
-      readPreference: this.readPreference,
-      session
-    });
-    // Let's check for the index names
-    if (!Array.isArray(indexes)) return info[indexes] != null;
-    // All keys found return true
-    return indexes.every(indexName => info[indexName] != null);
-  }
-}
-
 /** @internal */
 export class IndexInformationOperation extends AbstractOperation<Document> {
   override options: IndexInformationOptions;

test/integration/crud/abstract_operation.test.ts

@@ -19,7 +19,6 @@ describe('abstract operation', async function () {
       'OptionsOperation',
       'IsCappedOperation',
       'BulkWriteOperation',
-      'IndexExistsOperation',
       'IndexOperation',
       'CollectionsOperation',
       'IndexInformationOperation'
@@ -157,11 +156,6 @@ describe('abstract operation', async function () {
         subclassType: mongodb.ListIndexesOperation,
         correctCommandName: 'listIndexes'
       },
-      {
-        subclassCreator: () => new mongodb.IndexExistsOperation(collection, 'a', {}),
-        subclassType: mongodb.IndexExistsOperation,
-        correctCommandName: 'listIndexes'
-      },
       {
         subclassCreator: () => new mongodb.IndexInformationOperation(db, 'a', {}),
         subclassType: mongodb.IndexInformationOperation,