This commit is contained in:
Andris Reinman 2017-03-12 13:24:48 +02:00
parent 14b16799fa
commit b535afeb3d

View file

@ -537,6 +537,8 @@ server.onStore = function (path, update, session, callback) {
}));
}
this.logger.info('UPDATED: %s', updated ? 'YES' : 'NO');
if (updated) {
database.collection('messages').findOneAndUpdate({
_id: message._id
@ -553,6 +555,8 @@ server.onStore = function (path, update, session, callback) {
message: message._id
});
this.logger.info('NOTIFY: %s', JSON.stringify(notifyEntries));
if (notifyEntries.length > 100) {
setImmediate(() => this.notifier.addEntries(username, path, notifyEntries, processNext));
notifyEntries = [];