external/MeshCentral
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshCentral.git synced 2025-03-09 15:40:18 +00:00
Code Issues Releases Wiki Activity

Added MongoDbChangeStream option.

Browse source
This commit is contained in:
Ylian Saint-Hilaire 2019-05-28 17:42:11 -07:00
parent 0e7c091530
commit 88b0b8601c
3 changed files with 8 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

6
db.js
View file

@ -230,8 +230,8 @@ module.exports.CreateDB = function (parent, func) {
});
// Setup the changeStream on the MongoDB main collection if possible
try {
obj.fileChangeStream = obj.file.watch([{ $match: { 'fullDocument.type': { $in: [ 'node', 'mesh', 'user' ] } } }], { fullDocument: 'updateLookup' });
if (parent.args.mongodbchangestream == true) {
obj.fileChangeStream = obj.file.watch([{ $match: { 'fullDocument.type': { $in: ['node', 'mesh', 'user'] } } }], { fullDocument: 'updateLookup' });
obj.fileChangeStream.on('change', function (change) {
switch (change.fullDocument.type) {
case 'node': { dbNodeChange(change); break; } // A node has changed
@ -240,7 +240,7 @@ module.exports.CreateDB = function (parent, func) {
}
});
obj.changeStream = true;
} catch (ex) { }
}
// Setup MongoDB events collection and indexes
obj.eventsfile = db.collection('events'); // Collection containing all events