located area of problem

Author: IslandRhythms

lib/drivers/node-mongodb-native/collection.js

@@ -94,6 +94,7 @@ function iter(i) {
   NativeCollection.prototype[i] = function() {
     const collection = this._getCollection();
     const args = Array.from(arguments);
+    console.log('what is args', args, args[0][0] ? args[0][0].updateOne : '');
     const _this = this;
     const globalDebug = _this &&
       _this.conn &&
@@ -119,7 +120,6 @@ function iter(i) {
         throw error;
       }
     }
-
     let _args = args;
     let callback = null;
     if (this._shouldBufferCommands() && this.buffer) {

lib/helpers/model/castBulkWrite.js

@@ -66,15 +66,7 @@ module.exports = function castBulkWrite(originalModel, op, options) {
 
         _addDiscriminatorToObject(schema, op['updateOne']['filter']);
 
-        if (model.schema.$timestamps != null && op['updateOne'].timestamps !== false) {
-          const createdAt = model.schema.$timestamps.createdAt;
-          const updatedAt = model.schema.$timestamps.updatedAt;
-          applyTimestampsToUpdate(now, createdAt, updatedAt, op['updateOne']['update'], {});
-        }
-
-        if (op['updateOne'].timestamps !== false) {
-          applyTimestampsToChildren(now, op['updateOne']['update'], model.schema);
-        }
+        
 
         const shouldSetDefaultsOnInsert = op['updateOne'].setDefaultsOnInsert == null ?
           globalSetDefaultsOnInsert :
@@ -96,11 +88,23 @@ module.exports = function castBulkWrite(originalModel, op, options) {
           strict: strict,
           upsert: op['updateOne'].upsert
         });
-
+        console.log('what is op before', op);
+        // problem is here
         op['updateOne']['update'] = castUpdate(model.schema, op['updateOne']['update'], {
           strict: strict,
           upsert: op['updateOne'].upsert
         }, model, op['updateOne']['filter']);
+        console.log('what is op after', op);
+
+        if (model.schema.$timestamps != null && op['updateOne'].timestamps !== false) {
+          const createdAt = model.schema.$timestamps.createdAt;
+          const updatedAt = model.schema.$timestamps.updatedAt;
+          applyTimestampsToUpdate(now, createdAt, updatedAt, op['updateOne']['update'], {});
+        }
+
+        if (op['updateOne'].timestamps !== false) {
+          applyTimestampsToChildren(now, op['updateOne']['update'], model.schema);
+        }
       } catch (error) {
         return callback(error, null);
       }

lib/helpers/query/castUpdate.js

@@ -99,7 +99,7 @@ module.exports = function castUpdate(schema, obj, options, context, filter) {
     const op = ops[i];
     val = ret[op];
     hasDollarKey = hasDollarKey || op.startsWith('$');
-
+    console.log('what is val', val);
     if (val &&
         typeof val === 'object' &&
         !Buffer.isBuffer(val) &&
@@ -110,7 +110,6 @@ module.exports = function castUpdate(schema, obj, options, context, filter) {
           + 'Expected an object, received ' + typeof val;
       throw new Error(msg);
     }
-
     if (op.startsWith('$') && utils.isEmptyObject(val)) {
       delete ret[op];
     }

lib/model.js

@@ -3335,7 +3335,6 @@ Model.bulkWrite = async function bulkWrite(ops, options) {
   const ordered = options.ordered == null ? true : options.ordered;
 
   const validations = ops.map(op => castBulkWrite(this, op, options));
-
   return new Promise((resolve, reject) => {
     if (ordered) {
       each(validations, (fn, cb) => fn(cb), error => {
@@ -3352,7 +3351,6 @@ Model.bulkWrite = async function bulkWrite(ops, options) {
             if (error) {
               return reject(error);
             }
-
             resolve(res);
           });
         } catch (err) {
@@ -3424,7 +3422,6 @@ Model.bulkWrite = async function bulkWrite(ops, options) {
             res.mongoose.results = results;
           }
         }
-
         resolve(res);
       });
     }

test/model.test.js

@@ -6417,7 +6417,7 @@ describe('Model', function() {
           update: { $set: timeDoc }
         }
       }]);
-      assert.deepStrictEqual(beforeSet, timeDoc)
+      assert.deepStrictEqual(beforeSet._doc, timeDoc)
 
       const timelessDoc = await Timeless.create({
         name: 'Timeless Test'