fix(mongodb): Ensure transactions are used properly in create (#2699)

feathersjs · Jul 19, 2022 · fe22615 · fe22615
1 parent f886640
commit fe22615
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/packages/mongodb/src/adapter.ts b/packages/mongodb/src/adapter.ts
@@ -215,15 +215,18 @@ export class MongoDbAdapter<
 
       return entry
     }
+
     const promise = Array.isArray(data)
       ? model
           .insertMany(data.map(setId), writeOptions)
           .then(async (result) =>
-            Promise.all(Object.values(result.insertedIds).map(async (_id) => model.findOne({ _id })))
+            Promise.all(
+              Object.values(result.insertedIds).map(async (_id) => model.findOne({ _id }, params.mongodb))
+            )
           )
       : model
           .insertOne(setId(data), writeOptions)
-          .then(async (result) => model.findOne({ _id: result.insertedId }))
+          .then(async (result) => model.findOne({ _id: result.insertedId }, params.mongodb))
 
     return promise.then(select(params, this.id)).catch(errorHandler)
   }