atomic upsertWithWhere

Signed-off-by: = <mrbatista@users.noreply.github.com>

Author: mrbatista

.gitignore

@@ -2,3 +2,4 @@ node_modules
 coverage
 .idea
 .nyc_output/
+.history

lib/mongodb.js

@@ -1692,6 +1692,77 @@ MongoDB.prototype.update = MongoDB.prototype.updateAll = function updateAll(
   );
 };
 
+MongoDB.prototype.upsertWithWhere = function upsertWithWhere(
+  modelName,
+  where,
+  data,
+  options,
+  cb,
+) {
+  const self = this;
+
+  if (self.debug) {
+    debug('upsertWithWhere', modelName, where, data);
+  }
+
+  let updateData = Object.assign({}, data);
+
+  const idValue = self.getIdValue(modelName, updateData);
+  const idName = self.idName(modelName);
+
+  where = self.buildWhere(modelName, where, options);
+
+  if (idValue === null || idValue === undefined) {
+    delete updateData[idName]; // Allow MongoDB to generate the id
+  } else {
+    const oid = self.coerceId(modelName, idValue, options); // Is it an Object ID?c
+    updateData._id = oid; // Set it to _id
+    if (idName !== '_id') {
+      delete updateData[idName];
+    }
+  }
+
+  updateData = self.toDatabase(modelName, updateData);
+
+  // Check for other operators and sanitize the data obj
+  updateData = self.parseUpdateData(modelName, updateData, options);
+
+  this.execute(
+    modelName,
+    'findOneAndUpdate',
+    where,
+    updateData,
+    {
+      upsert: true,
+      returnOriginal: false,
+      sort: [['_id', 'asc']],
+    },
+    function(err, result) {
+      if (err) return cb && cb(err);
+
+      if (self.debug)
+        debug('upsertWithWhere.callback', modelName, where, updateData, err, info);
+
+      const object = result && result.value;
+      self.setIdValue(modelName, object, object._id);
+      if (object && idName !== '_id') {
+        delete object._id;
+      }
+
+      let info;
+      if (result && result.lastErrorObject) {
+        info = {isNewInstance: !result.lastErrorObject.updatedExisting};
+      } else {
+        debug('upsertWithWhere result format not recognized: %j', result);
+      }
+
+      if (cb) {
+        cb(err, self.fromDatabase(modelName, object), info);
+      }
+    },
+  );
+};
+
 /**
  * Disconnect from MongoDB
  */