github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

Actually implement minimongo upsert.

Browse Source 
Got a little over-confident there...
This commit is contained in:
Emily Stark
2013-09-26 14:22:23 -07:00
parent 86565853b1
commit 0286395700
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
packages/minimongo/minimongo.js
View File

@@ -473,6 +473,7 @@ LocalCollection.prototype.insert = function (doc, callback) {
LocalCollection._recomputeResults(self.queries[qid]);
});
self._observeQueue.drain();
// Defer because the caller likely doesn't expect the callback to be run
// immediately.
if (callback)
@@ -589,7 +590,20 @@ LocalCollection.prototype.update = function (selector, mod, options, callback) {
qidToOriginalResults[qid]);
});
self._observeQueue.drain();
var result = { numberAffected: updateCount };
var insertedId;
if (updateCount === 0 && options.upsert) {
var newDoc = _.clone(selector);
LocalCollection._modify(newDoc, mod);
insertedId = self.insert(newDoc);
updateCount = 1;
}
var result = {
numberAffected: updateCount
};
if (insertedId !== undefined)
result.insertedId = insertedId;
if (callback)
Meteor.defer(function () {
callback(null, result);