417 lines
20 KiB
JavaScript
417 lines
20 KiB
JavaScript
'use strict';
|
|
|
|
Object.defineProperty(exports, "__esModule", {
|
|
value: true
|
|
});
|
|
exports.PanelCtrl = exports.TriggerPanelCtrl = undefined;
|
|
|
|
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
|
|
|
|
var _lodash = require('lodash');
|
|
|
|
var _lodash2 = _interopRequireDefault(_lodash);
|
|
|
|
var _jquery = require('jquery');
|
|
|
|
var _jquery2 = _interopRequireDefault(_jquery);
|
|
|
|
var _moment = require('moment');
|
|
|
|
var _moment2 = _interopRequireDefault(_moment);
|
|
|
|
var _utils = require('../datasource-zabbix/utils');
|
|
|
|
var utils = _interopRequireWildcard(_utils);
|
|
|
|
var _sdk = require('app/plugins/sdk');
|
|
|
|
var _editor = require('./editor');
|
|
|
|
require('./ack-tooltip.directive');
|
|
|
|
require('./css/panel_triggers.css!');
|
|
|
|
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
|
|
|
|
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
|
|
|
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
|
|
|
|
function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
|
|
|
|
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; } /**
|
|
* Grafana-Zabbix
|
|
* Zabbix plugin for Grafana.
|
|
* http://github.com/alexanderzobnin/grafana-zabbix
|
|
*
|
|
* Trigger panel.
|
|
* This feature sponsored by CORE IT
|
|
* http://www.coreit.fr
|
|
*
|
|
* Copyright 2015 Alexander Zobnin alexanderzobnin@gmail.com
|
|
* Licensed under the Apache License, Version 2.0
|
|
*/
|
|
|
|
var defaultSeverity = [{ priority: 0, severity: 'Not classified', color: '#B7DBAB', show: true }, { priority: 1, severity: 'Information', color: '#82B5D8', show: true }, { priority: 2, severity: 'Warning', color: '#E5AC0E', show: true }, { priority: 3, severity: 'Average', color: '#C15C17', show: true }, { priority: 4, severity: 'High', color: '#BF1B00', show: true }, { priority: 5, severity: 'Disaster', color: '#890F02', show: true }];
|
|
|
|
var panelDefaults = {
|
|
datasource: null,
|
|
triggers: {
|
|
group: { filter: "" },
|
|
host: { filter: "" },
|
|
application: { filter: "" },
|
|
trigger: { filter: "" }
|
|
},
|
|
hostField: true,
|
|
statusField: false,
|
|
severityField: false,
|
|
lastChangeField: true,
|
|
ageField: true,
|
|
infoField: true,
|
|
limit: 10,
|
|
showTriggers: 'all triggers',
|
|
hideHostsInMaintenance: false,
|
|
sortTriggersBy: { text: 'last change', value: 'lastchange' },
|
|
showEvents: { text: 'Problems', value: '1' },
|
|
triggerSeverity: defaultSeverity,
|
|
okEventColor: 'rgba(0, 245, 153, 0.45)',
|
|
ackEventColor: 'rgba(0, 0, 0, 0)',
|
|
scroll: true,
|
|
pageSize: 10,
|
|
fontSize: '100%'
|
|
};
|
|
|
|
var triggerStatusMap = {
|
|
'0': 'OK',
|
|
'1': 'Problem'
|
|
};
|
|
|
|
var defaultTimeFormat = "DD MMM YYYY HH:mm:ss";
|
|
|
|
var TriggerPanelCtrl = function (_PanelCtrl) {
|
|
_inherits(TriggerPanelCtrl, _PanelCtrl);
|
|
|
|
/** @ngInject */
|
|
function TriggerPanelCtrl($scope, $injector, $element, datasourceSrv, templateSrv, contextSrv, dashboardSrv) {
|
|
_classCallCheck(this, TriggerPanelCtrl);
|
|
|
|
var _this = _possibleConstructorReturn(this, (TriggerPanelCtrl.__proto__ || Object.getPrototypeOf(TriggerPanelCtrl)).call(this, $scope, $injector));
|
|
|
|
_this.datasourceSrv = datasourceSrv;
|
|
_this.templateSrv = templateSrv;
|
|
_this.contextSrv = contextSrv;
|
|
_this.dashboardSrv = dashboardSrv;
|
|
|
|
_this.triggerStatusMap = triggerStatusMap;
|
|
_this.defaultTimeFormat = defaultTimeFormat;
|
|
_this.pageIndex = 0;
|
|
_this.triggerList = [];
|
|
_this.currentTriggersPage = [];
|
|
|
|
// Load panel defaults
|
|
// _.cloneDeep() need for prevent changing shared defaultSeverity.
|
|
// Load object "by value" istead "by reference".
|
|
_lodash2.default.defaults(_this.panel, _lodash2.default.cloneDeep(panelDefaults));
|
|
|
|
_this.events.on('init-edit-mode', _this.onInitEditMode.bind(_this));
|
|
_this.events.on('refresh', _this.onRefresh.bind(_this));
|
|
return _this;
|
|
}
|
|
|
|
_createClass(TriggerPanelCtrl, [{
|
|
key: 'onInitEditMode',
|
|
value: function onInitEditMode() {
|
|
this.addEditorTab('Options', _editor.triggerPanelEditor, 2);
|
|
}
|
|
}, {
|
|
key: 'onRefresh',
|
|
value: function onRefresh() {
|
|
var _this2 = this;
|
|
|
|
// ignore fetching data if another panel is in fullscreen
|
|
if (this.otherPanelInFullscreenMode()) {
|
|
return;
|
|
}
|
|
|
|
// clear loading/error state
|
|
delete this.error;
|
|
this.loading = true;
|
|
|
|
return this.refreshData().then(function (triggerList) {
|
|
// Limit triggers number
|
|
_this2.triggerList = triggerList.slice(0, _this2.panel.limit);
|
|
|
|
_this2.getCurrentTriggersPage();
|
|
|
|
// Notify panel that request is finished
|
|
_this2.loading = false;
|
|
|
|
_this2.render(_this2.triggerList);
|
|
});
|
|
}
|
|
}, {
|
|
key: 'refreshData',
|
|
value: function refreshData() {
|
|
return this.getTriggers().then(this.getAcknowledges.bind(this)).then(this.filterTriggers.bind(this));
|
|
}
|
|
}, {
|
|
key: 'getTriggers',
|
|
value: function getTriggers() {
|
|
var _this3 = this;
|
|
|
|
return this.datasourceSrv.get(this.panel.datasource).then(function (datasource) {
|
|
var zabbix = datasource.zabbix;
|
|
_this3.zabbix = zabbix;
|
|
var showEvents = _this3.panel.showEvents.value;
|
|
var triggerFilter = _this3.panel.triggers;
|
|
var hideHostsInMaintenance = _this3.panel.hideHostsInMaintenance;
|
|
|
|
// Replace template variables
|
|
var groupFilter = datasource.replaceTemplateVars(triggerFilter.group.filter);
|
|
var hostFilter = datasource.replaceTemplateVars(triggerFilter.host.filter);
|
|
var appFilter = datasource.replaceTemplateVars(triggerFilter.application.filter);
|
|
|
|
var getTriggers = zabbix.getTriggers(groupFilter, hostFilter, appFilter, showEvents, hideHostsInMaintenance);
|
|
return getTriggers.then(function (triggers) {
|
|
return _lodash2.default.map(triggers, _this3.formatTrigger.bind(_this3));
|
|
});
|
|
});
|
|
}
|
|
}, {
|
|
key: 'getAcknowledges',
|
|
value: function getAcknowledges(triggerList) {
|
|
var _this4 = this;
|
|
|
|
// Request acknowledges for trigger
|
|
var eventids = _lodash2.default.map(triggerList, function (trigger) {
|
|
return trigger.lastEvent.eventid;
|
|
});
|
|
|
|
return this.zabbix.getAcknowledges(eventids).then(function (events) {
|
|
|
|
// Map events to triggers
|
|
_lodash2.default.each(triggerList, function (trigger) {
|
|
var event = _lodash2.default.find(events, function (event) {
|
|
return event.eventid === trigger.lastEvent.eventid;
|
|
});
|
|
|
|
if (event) {
|
|
trigger.acknowledges = _lodash2.default.map(event.acknowledges, function (ack) {
|
|
var timestamp = _moment2.default.unix(ack.clock);
|
|
if (_this4.panel.customLastChangeFormat) {
|
|
ack.time = timestamp.format(_this4.panel.lastChangeFormat);
|
|
} else {
|
|
ack.time = timestamp.format(_this4.defaultTimeFormat);
|
|
}
|
|
ack.user = ack.alias + ' (' + ack.name + ' ' + ack.surname + ')';
|
|
return ack;
|
|
});
|
|
|
|
// Mark acknowledged triggers with different color
|
|
if (_this4.panel.markAckEvents && trigger.acknowledges.length) {
|
|
trigger.color = _this4.panel.ackEventColor;
|
|
}
|
|
}
|
|
});
|
|
|
|
return triggerList;
|
|
});
|
|
}
|
|
}, {
|
|
key: 'filterTriggers',
|
|
value: function filterTriggers(triggerList) {
|
|
var _this5 = this;
|
|
|
|
// Filter triggers by description
|
|
var triggerFilter = this.panel.triggers.trigger.filter;
|
|
if (triggerFilter) {
|
|
triggerList = _filterTriggers(triggerList, triggerFilter);
|
|
}
|
|
|
|
// Filter acknowledged triggers
|
|
if (this.panel.showTriggers === 'unacknowledged') {
|
|
triggerList = _lodash2.default.filter(triggerList, function (trigger) {
|
|
return !trigger.acknowledges;
|
|
});
|
|
} else if (this.panel.showTriggers === 'acknowledged') {
|
|
triggerList = _lodash2.default.filter(triggerList, 'acknowledges');
|
|
} else {
|
|
triggerList = triggerList;
|
|
}
|
|
|
|
// Filter triggers by severity
|
|
triggerList = _lodash2.default.filter(triggerList, function (trigger) {
|
|
return _this5.panel.triggerSeverity[trigger.priority].show;
|
|
});
|
|
|
|
// Sort triggers
|
|
if (this.panel.sortTriggersBy.value === 'priority') {
|
|
triggerList = _lodash2.default.sortBy(triggerList, 'priority').reverse();
|
|
} else {
|
|
triggerList = _lodash2.default.sortBy(triggerList, 'lastchangeUnix').reverse();
|
|
}
|
|
|
|
return triggerList;
|
|
}
|
|
}, {
|
|
key: 'formatTrigger',
|
|
value: function formatTrigger(trigger) {
|
|
var triggerObj = trigger;
|
|
|
|
// Format last change and age
|
|
trigger.lastchangeUnix = Number(trigger.lastchange);
|
|
var timestamp = _moment2.default.unix(trigger.lastchangeUnix);
|
|
if (this.panel.customLastChangeFormat) {
|
|
// User defined format
|
|
triggerObj.lastchange = timestamp.format(this.panel.lastChangeFormat);
|
|
} else {
|
|
triggerObj.lastchange = timestamp.format(this.defaultTimeFormat);
|
|
}
|
|
triggerObj.age = timestamp.fromNow(true);
|
|
|
|
// Set host that the trigger belongs
|
|
if (trigger.hosts.length) {
|
|
triggerObj.host = trigger.hosts[0].name;
|
|
triggerObj.hostTechName = trigger.hosts[0].host;
|
|
}
|
|
|
|
// Set color
|
|
if (trigger.value === '1') {
|
|
// Problem state
|
|
triggerObj.color = this.panel.triggerSeverity[trigger.priority].color;
|
|
} else {
|
|
// OK state
|
|
triggerObj.color = this.panel.okEventColor;
|
|
}
|
|
|
|
triggerObj.severity = this.panel.triggerSeverity[trigger.priority].severity;
|
|
return triggerObj;
|
|
}
|
|
}, {
|
|
key: 'switchComment',
|
|
value: function switchComment(trigger) {
|
|
trigger.showComment = !trigger.showComment;
|
|
}
|
|
}, {
|
|
key: 'acknowledgeTrigger',
|
|
value: function acknowledgeTrigger(trigger, message) {
|
|
var eventid = trigger.lastEvent.eventid;
|
|
var grafana_user = this.contextSrv.user.name;
|
|
var ack_message = grafana_user + ' (Grafana): ' + message;
|
|
return this.datasourceSrv.get(this.panel.datasource).then(function (datasource) {
|
|
var zabbixAPI = datasource.zabbix.zabbixAPI;
|
|
return zabbixAPI.acknowledgeEvent(eventid, ack_message);
|
|
}).then(this.onRefresh.bind(this));
|
|
}
|
|
}, {
|
|
key: 'getCurrentTriggersPage',
|
|
value: function getCurrentTriggersPage() {
|
|
var pageSize = this.panel.pageSize || 10;
|
|
var startPos = this.pageIndex * pageSize;
|
|
var endPos = Math.min(startPos + pageSize, this.triggerList.length);
|
|
this.currentTriggersPage = this.triggerList.slice(startPos, endPos);
|
|
return this.currentTriggersPage;
|
|
}
|
|
}, {
|
|
key: 'link',
|
|
value: function link(scope, elem, attrs, ctrl) {
|
|
var data;
|
|
var panel = ctrl.panel;
|
|
var pageCount = 0;
|
|
data = ctrl.triggerList;
|
|
|
|
function getTableHeight() {
|
|
var panelHeight = ctrl.height;
|
|
|
|
if (pageCount > 1) {
|
|
panelHeight -= 26;
|
|
}
|
|
|
|
return panelHeight - 31 + 'px';
|
|
}
|
|
|
|
function switchPage(e) {
|
|
var el = (0, _jquery2.default)(e.currentTarget);
|
|
ctrl.pageIndex = parseInt(el.text(), 10) - 1;
|
|
|
|
var pageSize = ctrl.panel.pageSize || 10;
|
|
var startPos = ctrl.pageIndex * pageSize;
|
|
var endPos = Math.min(startPos + pageSize, ctrl.triggerList.length);
|
|
ctrl.currentTriggersPage = ctrl.triggerList.slice(startPos, endPos);
|
|
|
|
scope.$apply();
|
|
renderPanel();
|
|
}
|
|
|
|
function appendPaginationControls(footerElem) {
|
|
footerElem.empty();
|
|
|
|
var pageSize = ctrl.panel.pageSize || 5;
|
|
pageCount = Math.ceil(data.length / pageSize);
|
|
if (pageCount === 1) {
|
|
return;
|
|
}
|
|
|
|
var startPage = Math.max(ctrl.pageIndex - 3, 0);
|
|
var endPage = Math.min(pageCount, startPage + 9);
|
|
|
|
var paginationList = (0, _jquery2.default)('<ul></ul>');
|
|
|
|
for (var i = startPage; i < endPage; i++) {
|
|
var activeClass = i === ctrl.pageIndex ? 'active' : '';
|
|
var pageLinkElem = (0, _jquery2.default)('<li><a class="triggers-panel-page-link pointer ' + activeClass + '">' + (i + 1) + '</a></li>');
|
|
paginationList.append(pageLinkElem);
|
|
}
|
|
|
|
footerElem.append(paginationList);
|
|
}
|
|
|
|
function renderPanel() {
|
|
var panelElem = elem.parents('.panel');
|
|
var rootElem = elem.find('.triggers-panel-scroll');
|
|
var footerElem = elem.find('.triggers-panel-footer');
|
|
|
|
elem.css({ 'font-size': panel.fontSize });
|
|
panelElem.addClass('triggers-panel-wrapper');
|
|
appendPaginationControls(footerElem);
|
|
|
|
rootElem.css({ 'max-height': panel.scroll ? getTableHeight() : '' });
|
|
}
|
|
|
|
elem.on('click', '.triggers-panel-page-link', switchPage);
|
|
|
|
var unbindDestroy = scope.$on('$destroy', function () {
|
|
elem.off('click', '.triggers-panel-page-link');
|
|
unbindDestroy();
|
|
});
|
|
|
|
ctrl.events.on('render', function (renderData) {
|
|
data = renderData || data;
|
|
if (data) {
|
|
renderPanel();
|
|
}
|
|
ctrl.renderingCompleted();
|
|
});
|
|
}
|
|
}]);
|
|
|
|
return TriggerPanelCtrl;
|
|
}(_sdk.PanelCtrl);
|
|
|
|
TriggerPanelCtrl.templateUrl = 'panel-triggers/module.html';
|
|
|
|
function _filterTriggers(triggers, triggerFilter) {
|
|
if (utils.isRegex(triggerFilter)) {
|
|
return _lodash2.default.filter(triggers, function (trigger) {
|
|
return utils.buildRegex(triggerFilter).test(trigger.description);
|
|
});
|
|
} else {
|
|
return _lodash2.default.filter(triggers, function (trigger) {
|
|
return trigger.description === triggerFilter;
|
|
});
|
|
}
|
|
}
|
|
|
|
exports.TriggerPanelCtrl = TriggerPanelCtrl;
|
|
exports.PanelCtrl = TriggerPanelCtrl;
|