1 files changed, 52 insertions, 0 deletions
diff --git a/ui/imports/api/statistics/server/publications.js b/ui/imports/api/statistics/server/publications.js
new file mode 100644
index 0000000..f69be56
--- /dev/null
+++ b/ui/imports/api/statistics/server/publications.js
@@ -0,0 +1,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);
+});
+