diff options
Diffstat (limited to 'ui/imports/api/messages/server/publications.js')
-rw-r--r-- | ui/imports/api/messages/server/publications.js | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/ui/imports/api/messages/server/publications.js b/ui/imports/api/messages/server/publications.js index 6b147f0..8c5b59d 100644 --- a/ui/imports/api/messages/server/publications.js +++ b/ui/imports/api/messages/server/publications.js @@ -103,6 +103,22 @@ Meteor.publish('messages/count?backDelta&level', function (backDelta, level) { return new Counter(counterName, Messages.find(query)); }); +Meteor.publish('messages/count?backDelta&level&env', function (backDelta, level, env) { + const counterName = `messages/count?backDelta=${backDelta}&level=${level}&env=${env}`; + console.log(`subscribe - counter: ${counterName}`); + + let begining = moment().subtract(backDelta); + let query = { + level: level, + environment: env, + timestamp: { $gte: begining.toDate() } + }; + + console.log(`query: ${R.toString(query)}`); + + return new Counter(counterName, Messages.find(query)); +}); + Meteor.publish('messages/count?level&env', function (level, env) { const counterName = `messages/count?level=${level}&env=${env}`; console.log(`subscribe - counter: ${counterName}`); |