aboutsummaryrefslogtreecommitdiffstats
path: root/ui/imports/api/statistics/server/publications.js
blob: f69be56f4e69f1d4eb05275c8bbaf8e8b4608b4a (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
/////////////////////////////////////////////////////////////////////////////////////////
// Copyright (c) 2017 Koren Lev (Cisco Systems), Yaron Yogev (Cisco Systems) and others /
//                                                                                      /
// All rights reserved. This program and the accompanying materials                     /
// are made available under the terms of the Apache License, Version 2.0                /
// which accompanies this distribution, and is available at                             /
// http://www.apache.org/licenses/LICENSE-2.0                                           /
/////////////////////////////////////////////////////////////////////////////////////////
import { Meteor } from 'meteor/meteor';
//import { Counts } from 'meteor/tmeasday:publish-counts';
import { Statistics } from '../statistics.js';
import { createGraphQuerySchema } from '../helpers';

Meteor.publish('statistics!graph-frames', function ({
  env, 
  object_id, 
  type,
  flowType, 
  timeStart,
  sourceMacAddress,
  destinationMacAddress,
  sourceIPv4Address,
  destinationIPv4Address
}) {
  console.log('server subscribe: statistics?graph-frames');

  let schema = createGraphQuerySchema(
    env, 
    object_id,
    type,
    flowType, 
    timeStart,
    null,
    sourceMacAddress,
    destinationMacAddress,
    sourceIPv4Address,
    destinationIPv4Address);

  console.log('statistics!graph-frames');
  console.log(`- env: ${env}`);
  console.log(`- object_id: ${object_id}`);
  console.log(`- type: ${type}`);
  console.log(`- flowType: ${flowType}`);
  console.log(`- timeStart: ${timeStart}`);
  console.log(`- sourceMacAddress: ${sourceMacAddress}`);
  console.log(`- destinationMacAddress: ${destinationMacAddress}`);
  console.log(`- sourceIPv4Address: ${sourceIPv4Address}`);
  console.log(`- destinationIPv4Address: ${destinationIPv4Address}`);

  return Statistics.find(schema);
});