diff options
author | Koren Lev <korenlev@gmail.com> | 2017-09-06 19:47:54 +0300 |
---|---|---|
committer | Koren Lev <korenlev@gmail.com> | 2017-09-06 19:47:54 +0300 |
commit | fc2702ba260b7a8705ee9f2d1f606af8dfa768da (patch) | |
tree | 1a9be5648c0148a0624de550351b5dfe75b6c5d4 /ui/imports/api/messages/server/publications.js | |
parent | 7e0fce9122cc61aef397c7a4e2780fb018404513 (diff) |
ui updates
Change-Id: I2d3f87e34a74ce21bbb9e3df989b6527337b7228
Signed-off-by: Koren Lev <korenlev@gmail.com>
Diffstat (limited to 'ui/imports/api/messages/server/publications.js')
-rw-r--r-- | ui/imports/api/messages/server/publications.js | 19 |
1 files changed, 18 insertions, 1 deletions
diff --git a/ui/imports/api/messages/server/publications.js b/ui/imports/api/messages/server/publications.js index 13c7c50..6b147f0 100644 --- a/ui/imports/api/messages/server/publications.js +++ b/ui/imports/api/messages/server/publications.js @@ -88,11 +88,28 @@ Meteor.publish('messages/count?level', function (level) { return new Counter(counterName, Messages.find({ level: level })); }); +Meteor.publish('messages/count?backDelta&level', function (backDelta, level) { + const counterName = `messages/count?backDelta=${backDelta}&level=${level}`; + console.log(`subscribe - counter: ${counterName}`); + + let begining = moment().subtract(backDelta); + let query = { + level: level, + 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}`); let query = { level: level }; query = R.ifElse(R.isNil, R.always(query), R.assoc('environment', R.__, query))(env); + console.log(`query: ${R.toString(query)}`); - return new Counter(counterName, Messages.find(query)); }); + return new Counter(counterName, Messages.find(query)); +}); |