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 test: 'mongo-livedata - oplog - include selector fields'

Browse Source
This commit is contained in:
denihs
2023-02-16 06:58:51 -04:00
parent a0fd56d31d
commit 1837e495c5
1 changed files with 43 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
packages/mongo/mongo_livedata_tests.js
View File

@@ -3495,47 +3495,53 @@ Meteor.isServer &&
await observeWithoutOplog.stop();
});
Meteor.isServer && Tinytest.add("mongo-livedata - oplog - include selector fields", function (test) {
var collName = "includeSelector" + Random.id();
var coll = new Mongo.Collection(collName);
Meteor.isServer &&
Tinytest.addAsync(
'mongo-livedata - oplog - include selector fields',
async function(test) {
var collName = 'includeSelector' + Random.id();
var coll = new Mongo.Collection(collName);
var docId = coll.insert({a: 1, b: [3, 2], c: 'foo'});
test.isTrue(docId);
var docId = await coll.insertAsync({ a: 1, b: [3, 2], c: 'foo' });
test.isTrue(docId);
// Wait until we've processed the insert oplog entry. (If the insert shows up
// during the observeChanges, the bug in question is not consistently
// reproduced.) We don't have to do this for polling observe (eg
// --disable-oplog).
waitUntilOplogCaughtUp();
// Wait until we've processed the insert oplog entry. (If the insert shows up
// during the observeChanges, the bug in question is not consistently
// reproduced.) We don't have to do this for polling observe (eg
// --disable-oplog).
await waitUntilOplogCaughtUp();
var output = [];
var handle = coll.find({a: 1, b: 2}, {fields: {c: 1}}).observeChanges({
added: function (id, fields) {
output.push(['added', id, fields]);
},
changed: function (id, fields) {
output.push(['changed', id, fields]);
},
removed: function (id) {
output.push(['removed', id]);
var output = [];
var handle = await coll
.find({ a: 1, b: 2 }, { fields: { c: 1 } })
.observeChanges({
added: function(id, fields) {
output.push(['added', id, fields]);
},
changed: function(id, fields) {
output.push(['changed', id, fields]);
},
removed: function(id) {
output.push(['removed', id]);
},
});
// Initially should match the document.
test.length(output, 1);
test.equal(output.shift(), ['added', docId, { c: 'foo' }]);
// Update in such a way that, if we only knew about the published field 'c'
// and the changed field 'b' (but not the field 'a'), we would think it didn't
// match any more. (This is a regression test for a bug that existed because
// we used to not use the shared projection in the initial query.)
await runInFence(async function() {
await coll.updateAsync(docId, { $set: { 'b.0': 2, c: 'bar' } });
});
test.length(output, 1);
test.equal(output.shift(), ['changed', docId, { c: 'bar' }]);
handle.stop();
}
});
// Initially should match the document.
test.length(output, 1);
test.equal(output.shift(), ['added', docId, {c: 'foo'}]);
// Update in such a way that, if we only knew about the published field 'c'
// and the changed field 'b' (but not the field 'a'), we would think it didn't
// match any more. (This is a regression test for a bug that existed because
// we used to not use the shared projection in the initial query.)
runInFence(function () {
coll.update(docId, {$set: {'b.0': 2, c: 'bar'}});
});
test.length(output, 1);
test.equal(output.shift(), ['changed', docId, {c: 'bar'}]);
handle.stop();
});
);
Meteor.isServer && Tinytest.add("mongo-livedata - oplog - transform", function (test) {
var collName = "oplogTransform" + Random.id();