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

Fix basic fields projection.

Browse Source
This commit is contained in:
Slava Kim
2013-10-29 21:37:06 -07:00
committed by David Glasser
parent 2bbd69ad2c
commit 8a00f1d713
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
packages/mongo-livedata/oplog.js
View File

@@ -43,12 +43,12 @@ MongoConnection.prototype._observeChangesWithOplog = function (
var add = function (doc) {
var id = doc._id;
var fields = projection(doc);
var fields = _.clone(doc);
delete fields._id;
if (published.has(id))
throw Error("tried to add something already published " + id);
published.set(id, fields);
callbacks.added && callbacks.added(id, EJSON.clone(fields));
callbacks.added && callbacks.added(id, projection(fields));
};
var remove = function (id) {
@@ -58,10 +58,8 @@ MongoConnection.prototype._observeChangesWithOplog = function (
callbacks.removed && callbacks.removed(id);
};
// XXX it doesn't mutate newDoc anymore since we apply projection function but
// be careful refactoring and moving out projection.
var handleDoc = function (id, newDoc) {
newDoc = projection(newDoc);
newDoc = _.clone(newDoc);
var matchesNow = newDoc && selector(newDoc);
var matchedBefore = published.has(id);
if (matchesNow && !matchedBefore) {
@@ -77,6 +75,7 @@ MongoConnection.prototype._observeChangesWithOplog = function (
if (callbacks.changed) {
var changed = LocalCollection._makeChangedFields(
EJSON.clone(newDoc), oldDoc);
changed = projection(changed);
if (!_.isEmpty(changed))
callbacks.changed(id, changed);
}