DocumentCollection+Collection: add dropIndex

Author: devmatteini

.changeset/breezy-cheetahs-juggle.md

@@ -0,0 +1,5 @@
+---
+"effect-mongodb": patch
+---
+
+Add dropIndex function in Collection and DocumentCollection

packages/effect-mongodb/src/Collection.ts

@@ -16,6 +16,7 @@ import type {
   DeleteResult,
   Document,
   DropCollectionOptions,
+  DropIndexesOptions,
   FindOptions as MongoFindOptions,
   IndexDescription,
   IndexSpecification,
@@ -353,6 +354,32 @@ export const createIndex: {
     )
 )
 
+export const dropIndex: {
+  (
+    indexName: string,
+    options?: DropIndexesOptions
+  ): <A extends Document, I extends Document, R>(
+    collection: Collection<A, I, R>
+  ) => Effect.Effect<void, MongoError.MongoError, R>
+  <A extends Document, I extends Document, R>(
+    collection: Collection<A, I, R>,
+    indexName: string,
+    options?: DropIndexesOptions
+  ): Effect.Effect<void, MongoError.MongoError, R>
+} = F.dual(
+  (args) => isCollection(args[0]),
+  <A extends Document, I extends Document, R>(
+    collection: Collection<A, I, R>,
+    indexName: string,
+    options?: DropIndexesOptions
+  ): Effect.Effect<void, MongoError.MongoError, R> =>
+    F.pipe(
+      Effect.promise(() => collection.collection.dropIndex(indexName, options)),
+      Effect.asVoid,
+      Effect.catchAllDefect(MongoError.mongoErrorDie<void>("dropIndex error"))
+    )
+)
+
 export const aggregate: {
   <B extends Document, BI extends Document, BR>(
     pipeline: Array<Document>,

packages/effect-mongodb/src/DocumentCollection.ts

@@ -15,6 +15,7 @@ import type {
   DeleteResult,
   Document,
   DropCollectionOptions,
+  DropIndexesOptions,
   Filter,
   FindOptions,
   IndexDescription,
@@ -324,6 +325,29 @@ export const createIndex: {
     )
 )
 
+export const dropIndex: {
+  (
+    indexName: string,
+    options?: DropIndexesOptions
+  ): (collection: DocumentCollection) => Effect.Effect<Document, MongoError.MongoError>
+  (
+    collection: DocumentCollection,
+    indexName: string,
+    options?: DropIndexesOptions
+  ): Effect.Effect<Document, MongoError.MongoError>
+} = F.dual(
+  (args) => isDocumentCollection(args[0]),
+  (
+    collection: DocumentCollection,
+    indexName: string,
+    options?: DropIndexesOptions
+  ): Effect.Effect<Document, MongoError.MongoError> =>
+    F.pipe(
+      Effect.promise(() => collection.collection.dropIndex(indexName, options)),
+      Effect.catchAllDefect(MongoError.mongoErrorDie<Document>("dropIndex error"))
+    )
+)
+
 export const aggregate: {
   (
     pipeline?: Array<Document>,