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

new mongo package options to only oplog tail() certain collections or exclude certain collections

Browse Source
This commit is contained in:
Patrick Schubert
2024-02-16 16:59:00 +01:00
parent c26569d224
commit 2ffc7bc91e
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
packages/mongo/oplog_tailing.js
View File

@@ -241,6 +241,29 @@ Object.assign(OplogHandle.prototype, {
self._lastProcessedTS = lastOplogEntry.ts;
}
// these 2 settings allow you to either only watch certain collections (oplogWatchCollections), or exclude some collections you don't want to watch for oplog updates (oplogExcludeCollections)
const includeCollections = Meteor.settings?.packages?.mongo?.oplogWatchCollections;
const excludeCollections = Meteor.settings?.packages?.mongo?.oplogExcludeCollections;
if (includeCollections?.length && excludeCollections?.length) {
throw new Error("Can't use both mongo oplog settings oplogWatchCollections and oplogExcludeCollections at the same time.");
}
if (excludeCollections?.length) {
oplogSelector.ns = {
$regex: oplogSelector.ns,
$nin: excludeCollections.map((collName) => `${self._dbName}.${collName}`)
}
}
else if (includeCollections?.length) {
oplogSelector = { $and: [
{ $or: [
{ ns: /^admin\.\$cmd/ },
{ ns: { $in: includeCollections.map((collName) => `${self._dbName}.${collName}`) } }
] },
{ $or: oplogSelector.$or }, // the initial $or to select only certain operations (op)
{ ts: oplogSelector.ts }
] };
}
var cursorDescription = new CursorDescription(
OPLOG_COLLECTION, oplogSelector, {tailable: true});