fix(updateDocument): corrected bug in cases where matchedCount and modifiedCount did not match #48

Author: TillaTheHun0

adapter.ts

@@ -221,8 +221,8 @@ export function adapter({
       .chain(({ name: actualName }) =>
         $database(actualName)
           .replaceOne({ _id: id }, doc, { upsert: true })
-          .chain(({ matchedCount, modifiedCount }) =>
-            matchedCount + modifiedCount === 2 ? Async.Resolved({ ok: true, id }) : Async.Rejected(
+          .chain(({ matchedCount, upsertedCount }) =>
+            upsertedCount || matchedCount ? Async.Resolved({ ok: true, id }) : Async.Rejected(
               HyperErr({
                 status: 404,
                 msg: `Could not update document with _id ${id}`,

clients/atlas-data.ts

@@ -147,6 +147,7 @@ export class Collection<T extends Document> implements MongoCollectionClient<T>
     return this.api<{
       matchedCount: number
       modifiedCount: number
+      upsertedCount: number
       upsertedId?: string
     }>('replaceOne', {
       filter,

clients/native.ts

@@ -86,6 +86,7 @@ class Collection<T extends Document> implements MongoCollectionClient<T> {
   ): Promise<{
     matchedCount: number
     modifiedCount: number
+    upsertedCount: number
     upsertedId?: string | undefined
   }> {
     const res = await this.collection.replaceOne(
@@ -97,6 +98,7 @@ class Collection<T extends Document> implements MongoCollectionClient<T> {
     return res as {
       matchedCount: number
       modifiedCount: number
+      upsertedCount: number
       upsertedId?: string | undefined
     }
   }

clients/types.ts

@@ -44,6 +44,7 @@ export interface MongoCollectionClient<T extends Document> {
   ): Promise<{
     matchedCount: number
     modifiedCount: number
+    upsertedCount: number
     upsertedId?: string
   }>
 

test/suite.ts

@@ -222,6 +222,29 @@ async (
       await a.removeDatabase(DB)
     })
 
+    await t.step('should noop if the document was not modified', async () => {
+      await a.createDatabase(DB)
+
+      await a.createDocument({
+        db: DB,
+        id: 'foobar',
+        doc: { foo: 'bar' },
+      })
+
+      // Same document shape
+      const noop = await a.updateDocument({
+        db: DB,
+        id: 'foobar',
+        doc: { foo: 'bar' },
+      })
+
+      assertObjectMatch(noop as any, { ok: true, id: 'foobar' })
+      const res = await a.retrieveDocument({ db: DB, id: 'foobar' })
+      assertObjectMatch(res as any, { _id: 'foobar', foo: 'bar' })
+
+      await a.removeDatabase(DB)
+    })
+
     await t.step(
       'should return a HyperErr(404) if the database does not exist',
       async () => {