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

.

Browse Source
This commit is contained in:
Patrick Schubert
2024-02-20 14:11:40 +01:00
parent f0dcdd2971
commit 4a028bb310
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/mongo/mongo_driver.js
View File

@@ -988,20 +988,22 @@ Cursor.prototype.getTransform = function () {
return this._cursorDescription.options.transform;
};
const oplogCollectionWarnings = [];
// When you call Meteor.publish() with a function that returns a Cursor, we need
// to transmute it into the equivalent subscription. This is the function that
// does that.
Cursor.prototype._publishCursor = function (sub) {
var self = this;
var collection = self._cursorDescription.collectionName;
const oplogOptions = self?._mongo?._oplogHandle?._oplogOptions || {};
const { includeCollections, excludeCollections } = oplogOptions;
if (excludeCollections?.length && excludeCollections.includes(collection)) {
if (excludeCollections?.length && excludeCollections.includes(collection) && !oplogCollectionWarnings.includes(collection)) {
console.warn(`Meteor.settings.packages.mongo.oplogExcludeCollections includes the collection ${collection} - no subscriptions/publications on this collection will return any updates`);
oplogCollectionWarnings.push(collection); // we only want to show the warnings once per collection!
}
if (includeCollections?.length && !includeCollections.includes(collection)) {
if (includeCollections?.length && !includeCollections.includes(collection) && !oplogCollectionWarnings.includes(collection)) {
console.warn(`Meteor.settings.packages.mongo.oplogIncludeCollections does not include the collection ${collection} - no subscriptions/publications on this collection will return any updates`);
oplogCollectionWarnings.push(collection); // we only want to show the warnings once per collection!
}
return Mongo.Collection._publishCursor(self, sub, collection);
};