summaryrefslogtreecommitdiffstats
path: root/ui/imports/api/messages
diff options
context:
space:
mode:
Diffstat (limited to 'ui/imports/api/messages')
-rw-r--r--ui/imports/api/messages/messages.js125
-rw-r--r--ui/imports/api/messages/methods.js8
-rw-r--r--ui/imports/api/messages/server/methods.js49
-rw-r--r--ui/imports/api/messages/server/publications.js131
4 files changed, 0 insertions, 313 deletions
diff --git a/ui/imports/api/messages/messages.js b/ui/imports/api/messages/messages.js
deleted file mode 100644
index 5a028b0..0000000
--- a/ui/imports/api/messages/messages.js
+++ /dev/null
@@ -1,125 +0,0 @@
-/////////////////////////////////////////////////////////////////////////////////////////
-// 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 { Mongo } from 'meteor/mongo';
-import { SimpleSchema } from 'meteor/aldeed:simple-schema';
-import * as R from 'ramda';
-import { Environments } from '/imports/api/environments/environments';
-import { Constants } from '/imports/api/constants/constants';
-
-export const Messages = new Mongo.Collection('messages', { idGeneration: 'MONGO' });
-
-let schema = {
- _id: { type: { _str: { type: String, regEx: SimpleSchema.RegEx.Id } } },
-
- environment: {
- type: String,
- custom: function () {
- let that = this;
- let env = Environments.findOne({ name: that.value });
-
- if (R.isNil(env)) {
- return 'notAllowed';
- }
- }
- },
-
- id: {
- type: String
- },
-
- viewed: {
- type: Boolean,
- defaultValue: false
- },
-
- display_context: {
- type: String
- },
-
- message: {
- type: Object,
- blackbox: true
- },
-
- source_system: {
- type: String,
- custom: function () {
- let that = this;
- let values = Constants.findOne({ name: 'message_source_systems' }).data;
-
- if (R.isNil(R.find(R.propEq('value', that.value), values))) {
- return 'notAllowed';
- }
- }
- },
-
- level: {
- type: String
- },
-
- timestamp: {
- type: Date
- },
-
- related_object_type: {
- type: String
- },
-
- related_object: {
- type: String
- },
-
- scan_id: {
- type: Date
- }
-};
-
-let simpleSchema = new SimpleSchema(schema);
-
-Messages.schema = simpleSchema;
-Messages.attachSchema(Messages.schema);
-
-export function calcIconForMessageLevel(level) {
- switch (level) {
- case 'info':
- return 'notifications';
- case 'warning':
- return 'warning';
- case 'error':
- return 'error';
- default:
- return 'notifications';
- }
-}
-
-export function lastMessageTimestamp (level, envName) {
- let query = { level: level };
- query = R.ifElse(R.isNil, R.always(query), R.assoc('environment', R.__, query))(envName);
-
- let message = Messages.findOne(query, {
- sort: { timestamp: -1 }
- });
-
- let res = R.path(['timestamp'], message);
- if (R.isNil(res)) { return null; }
- return (res instanceof String) ? res : res.toString();
-}
-
-export function calcColorClassForMessagesInfoBox(level) {
- switch (level) {
- case 'info':
- return 'green-text';
- case 'warning':
- return 'orange-text';
- case 'error':
- return 'red-text';
- default:
- return 'green-text';
- }
-}
diff --git a/ui/imports/api/messages/methods.js b/ui/imports/api/messages/methods.js
deleted file mode 100644
index 1eda375..0000000
--- a/ui/imports/api/messages/methods.js
+++ /dev/null
@@ -1,8 +0,0 @@
-/////////////////////////////////////////////////////////////////////////////////////////
-// 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 /
-/////////////////////////////////////////////////////////////////////////////////////////
diff --git a/ui/imports/api/messages/server/methods.js b/ui/imports/api/messages/server/methods.js
deleted file mode 100644
index 540c0a1..0000000
--- a/ui/imports/api/messages/server/methods.js
+++ /dev/null
@@ -1,49 +0,0 @@
-/////////////////////////////////////////////////////////////////////////////////////////
-// 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 * as R from 'ramda';
-import { Messages } from '/imports/api/messages/messages';
-
-Meteor.methods({
- 'messages/get?level&env&page&amountPerPage&sortField&sortDirection': function (
- level, env, page, amountPerPage, sortField, sortDirection) {
-
- logMethodCall('messages/get?level&env&page&amountPerPage&sortField&sortDirection',
- {level, env, page, amountPerPage});
-
- this.unblock();
-
- let skip = (page - 1) * amountPerPage;
-
- let query = {};
- let sortParams = {};
-
- query = R.ifElse(R.isNil, R.always(query),R.assoc('environment', R.__, query))(env);
- query = R.ifElse(R.isNil, R.always(query),R.assoc('level', R.__, query))(level);
-
- sortParams = R.ifElse(R.isNil, R.always(sortParams),
- R.assoc(R.__, sortDirection, sortParams))(sortField);
-
- console.log('sort params:', sortParams);
-
- let qParams = {
- limit: amountPerPage,
- skip: skip,
- sort: sortParams,
- };
-
- return Messages.find(query, qParams).fetch();
- }
-});
-
-function logMethodCall(name, args) {
- console.log(`method call: ${name}`);
- R.forEachObjIndexed((value, key) => {
- console.log(`${key}: ${R.toString(value)}`);
- }, args);
-}
diff --git a/ui/imports/api/messages/server/publications.js b/ui/imports/api/messages/server/publications.js
deleted file mode 100644
index 8c5b59d..0000000
--- a/ui/imports/api/messages/server/publications.js
+++ /dev/null
@@ -1,131 +0,0 @@
-/////////////////////////////////////////////////////////////////////////////////////////
-// 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 { Counter } from 'meteor/natestrauser:publish-performant-counts';
-import { Messages } from '../messages.js';
-import * as R from 'ramda';
-
-Meteor.publish('messages', function () {
- console.log('server subscribtion to: messages');
- //return Inventory.find({$where: 'this.id_path.match('^/WebEX-Mirantis@Cisco/')'});
- //return Inventory.find({ 'show_in_tree': true });
- return Messages.find({});
-});
-
-Meteor.publish('messages?_id', function (_id) {
- console.log('server subscribtion to: messages?_id');
- console.log('_id', _id);
-
- let query = { _id: _id };
- return Messages.find(query);
-});
-
-Meteor.publish('messages?level', function (level) {
- var query = {
- level: level
- };
-
- /*
- var counterName = 'messages?level!counter?' +
- 'level=' + level;
-
- console.log('server subscription to: ' + counterName);
- Counts.publish(this, counterName, Messages.find(query));
- */
-
- console.log('server subscribtion to: messages?level');
- console.log('- level: ' + level);
- return Messages.find(query);
-});
-
-Meteor.publish('messages?env+level', function (env, level) {
- var query = {
- environment: env,
- level: level
- };
- /*
- var counterName = 'messages?env+level!counter?env=' +
- env + '&level=' + level;
-
- console.log('server subscription to: messages - counter');
- console.log(' - name: ' + counterName);
- Counts.publish(this, counterName, Messages.find(query));
- */
-
- console.log('server subscribtion to: messages');
- console.log('- env: ' + env);
- console.log('- level: ' + level);
- return Messages.find(query);
-});
-
-Meteor.publish('messages/count', function () {
- const counterName = `messages/count`;
- console.log(`subscribe - counter: ${counterName}`);
-
- return new Counter(counterName, Messages.find({ }));
-});
-
-Meteor.publish('messages/count?env', function (env) {
- const counterName = `messages/count?env`;
- console.log(`subscribe - counter: ${counterName}`);
-
- let query = {};
- query = R.ifElse(R.isNil, R.always(query), R.assoc('environment', R.__, query))(env);
- return new Counter(counterName, Messages.find(query));
-});
-
-Meteor.publish('messages/count?level', function (level) {
- const counterName = `messages/count?level=${level}`;
- console.log(`subscribe - counter: ${counterName}`);
-
- 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?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}`);
-
- 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));
-});