effect-mongodb: add updateOne to Collection and DocumentCollection

Author: VenomAV

.changeset/chilly-boats-peel.md

@@ -0,0 +1,5 @@
+---
+"effect-mongodb": patch
+---
+
+Add `updateOne` to `Collection` and `DocumentCollection`

packages/effect-mongodb/dtslint/Collection.ts

@@ -74,6 +74,16 @@ Collection.deleteMany(collection, { birthday: "2024-11-28" })
 // $ExpectType Effect<DeleteResult, MongoError, never>
 F.pipe(collection, Collection.deleteMany({ birthday: "2024-11-28" }))
 
+// -------------------------------------------------------------------------------------
+// updateOne
+// -------------------------------------------------------------------------------------
+
+// $ExpectType Effect<UpdateResult<{ readonly birthday: string; }>, MongoError, never>
+Collection.updateOne(collection, { birthday: "2024-11-28" }, { $set: { birthday: "2024-11-29" } })
+
+// $ExpectType Effect<UpdateResult<{ readonly birthday: string; }>, MongoError, never>
+F.pipe(collection, Collection.updateOne({ birthday: "2024-11-28" }, { $set: { birthday: "2024-11-29" } }))
+
 // -------------------------------------------------------------------------------------
 // updateMany
 // -------------------------------------------------------------------------------------

packages/effect-mongodb/dtslint/DocumentCollection.ts

@@ -76,6 +76,16 @@ DocumentCollection.deleteMany(collection, { birthday: "2024-11-28" })
 // $ExpectType Effect<DeleteResult, MongoError, never>
 F.pipe(collection, DocumentCollection.deleteMany({ birthday: "2024-11-28" }))
 
+// -------------------------------------------------------------------------------------
+// updateOne
+// -------------------------------------------------------------------------------------
+
+// $ExpectType Effect<UpdateResult<Document>, MongoError, never>
+DocumentCollection.updateOne(collection, { birthday: "2024-11-28" }, { $set: { birthday: "2024-11-29" } })
+
+// $ExpectType Effect<UpdateResult<Document>, MongoError, never>
+F.pipe(collection, DocumentCollection.updateOne({ birthday: "2024-11-28" }, { $set: { birthday: "2024-11-29" } }))
+
 // -------------------------------------------------------------------------------------
 // updateMany
 // -------------------------------------------------------------------------------------

packages/effect-mongodb/src/Collection.ts

@@ -202,6 +202,37 @@ export const deleteMany: {
     )
 )
 
+export const updateOne: {
+  <I extends Document>(
+    filter: Filter<I>,
+    update: UpdateFilter<I> | ReadonlyArray<Document>,
+    options?: UpdateOptions
+  ): <A extends Document, I2 extends I, R>(
+    collection: Collection<A, I2, R>
+  ) => Effect.Effect<UpdateResult<I2>, MongoError.MongoError, R>
+  <A extends Document, I extends Document, R>(
+    collection: Collection<A, I, R>,
+    filter: Filter<I>,
+    update: UpdateFilter<I> | ReadonlyArray<Document>,
+    options?: UpdateOptions
+  ): Effect.Effect<UpdateResult<I>, MongoError.MongoError, R>
+} = F.dual(
+  (args) => isCollection(args[0]),
+  <A extends Document, I extends Document, R>(
+    collection: Collection<A, I, R>,
+    filter: Filter<I>,
+    update: UpdateFilter<I> | ReadonlyArray<Document>,
+    options?: UpdateOptions
+  ): Effect.Effect<UpdateResult<I>, MongoError.MongoError, R> =>
+    Effect.promise(() =>
+      collection.collection.updateOne(
+        filter,
+        Array.isArray(update) ? [...update] : update as UpdateFilter<Document>,
+        options
+      )
+    ).pipe(Effect.catchAllDefect(mongoErrorOrDie(errorSource(collection, "updateOne"))))
+)
+
 export const updateMany: {
   <I extends Document>(
     filter: Filter<I>,

packages/effect-mongodb/src/DocumentCollection.ts

@@ -194,6 +194,36 @@ export const deleteMany: {
     )
 )
 
+export const updateOne: {
+  (
+    filter: Filter<Document>,
+    update: UpdateFilter<Document> | ReadonlyArray<Document>,
+    options?: UpdateOptions
+  ): (
+    collection: DocumentCollection
+  ) => Effect.Effect<UpdateResult, MongoError.MongoError>
+  (
+    collection: DocumentCollection,
+    filter: Filter<Document>,
+    update: UpdateFilter<Document> | ReadonlyArray<Document>,
+    options?: UpdateOptions
+  ): Effect.Effect<UpdateResult, MongoError.MongoError>
+} = F.dual(
+  (args) => isDocumentCollection(args[0]),
+  (
+    collection: DocumentCollection,
+    filter: Filter<Document>,
+    update: UpdateFilter<Document> | ReadonlyArray<Document>,
+    options?: UpdateOptions
+  ): Effect.Effect<UpdateResult, MongoError.MongoError> =>
+    F.pipe(
+      Effect.promise(() =>
+        collection.collection.updateOne(filter, Array.isArray(update) ? [...update] : update, options)
+      ),
+      Effect.catchAllDefect(mongoErrorOrDie(errorSource(collection, "updateOne")))
+    )
+)
+
 export const updateMany: {
   (
     filter: Filter<Document>,