425 lines
14 KiB
JavaScript
425 lines
14 KiB
JavaScript
define([
|
|
'angular',
|
|
'lodash',
|
|
'./helperFunctions',
|
|
'./utils'
|
|
],
|
|
function (angular, _) {
|
|
'use strict';
|
|
|
|
var module = angular.module('grafana.controllers');
|
|
var targetLetters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';
|
|
|
|
module.controller('ZabbixAPIQueryCtrl', function ($scope, $sce, templateSrv, zabbixHelperSrv, Utils) {
|
|
|
|
var zabbixCache = $scope.datasource.zabbixCache;
|
|
|
|
$scope.init = function () {
|
|
$scope.targetLetters = targetLetters;
|
|
$scope.metric = {};
|
|
|
|
if (!$scope.target.mode || $scope.target.mode !== 1) {
|
|
$scope.downsampleFunctionList = [
|
|
{name: "avg", value: "avg"},
|
|
{name: "min", value: "min"},
|
|
{name: "max", value: "max"}
|
|
];
|
|
|
|
// Set avg by default
|
|
if (!$scope.target.downsampleFunction) {
|
|
$scope.target.downsampleFunction = $scope.downsampleFunctionList[0];
|
|
}
|
|
|
|
// Load metrics from cache
|
|
if (zabbixCache._initialized) {
|
|
$scope.getMetricsFromCache();
|
|
$scope.initFilters();
|
|
console.log("Cached", $scope.metric);
|
|
} else {
|
|
zabbixCache.refresh().then(function () {
|
|
$scope.getMetricsFromCache();
|
|
$scope.initFilters();
|
|
console.log("From server", $scope.metric);
|
|
});
|
|
}
|
|
|
|
setItemAlias();
|
|
}
|
|
else if ($scope.target.mode === 1) {
|
|
$scope.slaPropertyList = [
|
|
{name: "Status", property: "status"},
|
|
{name: "SLA", property: "sla"},
|
|
{name: "OK time", property: "okTime"},
|
|
{name: "Problem time", property: "problemTime"},
|
|
{name: "Down time", property: "downtimeTime"}
|
|
];
|
|
$scope.itserviceList = [{name: "test"}];
|
|
$scope.updateITServiceList();
|
|
}
|
|
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
};
|
|
|
|
$scope.initFilters = function () {
|
|
$scope.onGroupBlur();
|
|
$scope.onHostBlur();
|
|
$scope.onApplicationBlur();
|
|
};
|
|
|
|
$scope.getMetricsFromCache = function () {
|
|
$scope.metric = {
|
|
groupList: zabbixCache.getGroups(),
|
|
hostList: zabbixCache.getHosts(),
|
|
applicationList: zabbixCache.getApplications(),
|
|
itemList: zabbixCache.getItems()
|
|
};
|
|
};
|
|
|
|
// Get list of metric names for bs-typeahead directive
|
|
function getMetricNames(scope, metricList) {
|
|
return _.uniq(_.map(scope.metric[metricList], 'name'));
|
|
}
|
|
|
|
// Map functions for bs-typeahead
|
|
$scope.getGroupNames = _.partial(getMetricNames, $scope, 'groupList');
|
|
$scope.getHostNames = _.partial(getMetricNames, $scope, 'filteredHosts');
|
|
$scope.getApplicationNames = _.partial(getMetricNames, $scope, 'filteredApplications');
|
|
$scope.getItemNames = _.partial(getMetricNames, $scope, 'filteredItems');
|
|
|
|
$scope.filterHosts = function () {
|
|
var group = $scope.target.group;
|
|
var groups = [];
|
|
var hosts = [];
|
|
|
|
// Filter groups by regex
|
|
if (group.isRegex) {
|
|
var filterPattern = Utils.buildRegex(group.filter);
|
|
groups = _.filter($scope.metric.groupList, function (groupObj) {
|
|
return filterPattern.test(groupObj.name);
|
|
});
|
|
}
|
|
// Find hosts in selected group
|
|
else {
|
|
var finded = _.find($scope.metric.groupList, {'name': group.filter});
|
|
if (finded) {
|
|
groups.push(finded);
|
|
} else {
|
|
groups = undefined;
|
|
}
|
|
}
|
|
|
|
if (groups) {
|
|
var groupids = _.map(groups, 'groupid');
|
|
hosts = _.filter($scope.metric.hostList, function (hostObj) {
|
|
return _.intersection(groupids, hostObj.groups).length;
|
|
});
|
|
}
|
|
return hosts;
|
|
};
|
|
|
|
$scope.filterApplications = function () {
|
|
var host = $scope.target.host;
|
|
var hosts = [];
|
|
var apps = [];
|
|
|
|
// Filter hosts by regex
|
|
if (host.isRegex) {
|
|
var filterPattern = Utils.buildRegex(host.filter);
|
|
hosts = _.filter($scope.metric.hostList, function (hostObj) {
|
|
return filterPattern.test(hostObj.name);
|
|
});
|
|
}
|
|
// Find applications in selected host
|
|
else {
|
|
var finded = _.find($scope.metric.hostList, {'name': host.filter});
|
|
if (finded) {
|
|
hosts.push(finded);
|
|
} else {
|
|
hosts = undefined;
|
|
}
|
|
}
|
|
|
|
if (hosts) {
|
|
var hostsids = _.map(hosts, 'hostid');
|
|
apps = _.filter($scope.metric.applicationList, function (appObj) {
|
|
return _.intersection(hostsids, appObj.hosts).length;
|
|
});
|
|
}
|
|
|
|
return apps;
|
|
};
|
|
|
|
$scope.filterItems = function () {
|
|
var app = $scope.target.application;
|
|
var apps = [];
|
|
var items = [];
|
|
|
|
// Filter applications by regex
|
|
if (app.isRegex) {
|
|
var filterPattern = Utils.buildRegex(app.filter);
|
|
apps = _.filter($scope.metric.applicationList, function (appObj) {
|
|
return filterPattern.test(appObj.name);
|
|
});
|
|
}
|
|
// Find items in selected application
|
|
else {
|
|
var finded = _.find($scope.metric.applicationList, {'name': app.filter});
|
|
if (finded) {
|
|
apps.push(finded);
|
|
} else {
|
|
apps = undefined;
|
|
}
|
|
}
|
|
|
|
if (apps) {
|
|
var appids = _.flatten(_.map(apps, 'applicationids'));
|
|
items = _.filter($scope.metric.itemList, function (itemObj) {
|
|
return _.intersection(appids, itemObj.applications).length;
|
|
});
|
|
}
|
|
|
|
return items;
|
|
};
|
|
|
|
$scope.onTargetPartChange = function (targetPart) {
|
|
var regexStyle = {'color': '#CCA300'};
|
|
targetPart.isRegex = Utils.isRegex(targetPart.filter);
|
|
targetPart.style = targetPart.isRegex ? regexStyle : {};
|
|
};
|
|
|
|
// Handle group blur and filter hosts
|
|
$scope.onGroupBlur = function() {
|
|
$scope.metric.filteredHosts = $scope.filterHosts();
|
|
};
|
|
|
|
// Handle host blur and filter applications
|
|
$scope.onHostBlur = function() {
|
|
$scope.metric.filteredApplications = $scope.filterApplications();
|
|
};
|
|
|
|
// Handle application blur and filter items
|
|
$scope.onApplicationBlur = function() {
|
|
$scope.metric.filteredItems = $scope.filterItems();
|
|
};
|
|
|
|
$scope.parseTarget = function() {
|
|
// Parse target
|
|
};
|
|
|
|
/**
|
|
* Switch query editor to specified mode.
|
|
* Modes:
|
|
* 0 - items
|
|
* 1 - IT services
|
|
* 2 - Text metrics
|
|
*/
|
|
$scope.switchEditorMode = function (mode) {
|
|
$scope.target.mode = mode;
|
|
$scope.init();
|
|
};
|
|
|
|
/**
|
|
* Take alias from item name by default
|
|
*/
|
|
function setItemAlias() {
|
|
if (!$scope.target.alias && $scope.target.item) {
|
|
$scope.target.alias = $scope.target.item.name;
|
|
}
|
|
}
|
|
|
|
$scope.targetBlur = function () {
|
|
setItemAlias();
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
|
$scope.oldTarget = angular.copy($scope.target);
|
|
$scope.get_data();
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Call when IT service is selected.
|
|
*/
|
|
$scope.selectITService = function () {
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
|
$scope.oldTarget = angular.copy($scope.target);
|
|
$scope.get_data();
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Call when host group selected
|
|
*/
|
|
$scope.selectHostGroup = function () {
|
|
$scope.updateHostList();
|
|
$scope.updateAppList();
|
|
$scope.updateItemList();
|
|
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
|
$scope.oldTarget = angular.copy($scope.target);
|
|
$scope.get_data();
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Call when host selected
|
|
*/
|
|
$scope.selectHost = function () {
|
|
$scope.updateAppList();
|
|
$scope.updateItemList();
|
|
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
|
$scope.oldTarget = angular.copy($scope.target);
|
|
$scope.get_data();
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Call when application selected
|
|
*/
|
|
$scope.selectApplication = function () {
|
|
$scope.updateItemList();
|
|
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
|
$scope.oldTarget = angular.copy($scope.target);
|
|
$scope.get_data();
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Call when item selected
|
|
*/
|
|
$scope.selectItem = function () {
|
|
setItemAlias();
|
|
$scope.target.errors = validateTarget($scope.target);
|
|
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
|
$scope.oldTarget = angular.copy($scope.target);
|
|
$scope.get_data();
|
|
}
|
|
};
|
|
|
|
$scope.duplicate = function () {
|
|
var clone = angular.copy($scope.target);
|
|
$scope.panel.targets.push(clone);
|
|
};
|
|
|
|
$scope.moveMetricQuery = function (fromIndex, toIndex) {
|
|
_.move($scope.panel.targets, fromIndex, toIndex);
|
|
};
|
|
|
|
//////////////////////////////
|
|
// SUGGESTION QUERIES
|
|
//////////////////////////////
|
|
|
|
/**
|
|
* Update list of IT services
|
|
*/
|
|
$scope.updateITServiceList = function () {
|
|
$scope.datasource.zabbixAPI.getITService().then(function (iteservices) {
|
|
$scope.itserviceList = [];
|
|
$scope.itserviceList = $scope.itserviceList.concat(iteservices);
|
|
});
|
|
};
|
|
|
|
/**
|
|
* Update list of host groups
|
|
*/
|
|
$scope.updateGroupList = function () {
|
|
$scope.datasource.zabbixAPI.performHostGroupSuggestQuery().then(function (groups) {
|
|
$scope.metric.groupList = [{name: '*', visible_name: 'All'}];
|
|
addTemplatedVariables($scope.metric.groupList);
|
|
$scope.metric.groupList = $scope.metric.groupList.concat(groups);
|
|
});
|
|
};
|
|
|
|
/**
|
|
* Update list of hosts
|
|
*/
|
|
$scope.updateHostList = function () {
|
|
var groups = $scope.target.group ? zabbixHelperSrv.splitMetrics(templateSrv.replace($scope.target.group.name)) : undefined;
|
|
if (groups) {
|
|
$scope.datasource.zabbixAPI.hostFindQuery(groups).then(function (hosts) {
|
|
$scope.metric.hostList = [{name: '*', visible_name: 'All'}];
|
|
addTemplatedVariables($scope.metric.hostList);
|
|
$scope.metric.hostList = $scope.metric.hostList.concat(hosts);
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Update list of host applications
|
|
*/
|
|
$scope.updateAppList = function () {
|
|
var groups = $scope.target.group ? zabbixHelperSrv.splitMetrics(templateSrv.replace($scope.target.group.name)) : undefined;
|
|
var hosts = $scope.target.host ? zabbixHelperSrv.splitMetrics(templateSrv.replace($scope.target.host.name)) : undefined;
|
|
if (groups && hosts) {
|
|
$scope.datasource.zabbixAPI.appFindQuery(hosts, groups).then(function (apps) {
|
|
apps = _.map(_.uniq(_.map(apps, 'name')), function (appname) {
|
|
return {name: appname};
|
|
});
|
|
$scope.metric.applicationList = [{name: '*', visible_name: 'All'}];
|
|
addTemplatedVariables($scope.metric.applicationList);
|
|
$scope.metric.applicationList = $scope.metric.applicationList.concat(apps);
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Update list of items
|
|
*/
|
|
$scope.updateItemList = function () {
|
|
var groups = $scope.target.group ? zabbixHelperSrv.splitMetrics(templateSrv.replace($scope.target.group.name)) : undefined;
|
|
var hosts = $scope.target.host ? zabbixHelperSrv.splitMetrics(templateSrv.replace($scope.target.host.name)) : undefined;
|
|
var apps = $scope.target.application ?
|
|
zabbixHelperSrv.splitMetrics(templateSrv.replace($scope.target.application.name)) : undefined;
|
|
var itemtype = $scope.target.mode === 2 ? "text" : "numeric";
|
|
if (groups && hosts && apps) {
|
|
$scope.datasource.zabbixAPI.itemFindQuery(groups, hosts, apps, itemtype).then(function (items) {
|
|
// Show only unique item names
|
|
var uniq_items = _.map(_.uniq(items, function (item) {
|
|
return zabbixHelperSrv.expandItemName(item);
|
|
}), function (item) {
|
|
return {name: zabbixHelperSrv.expandItemName(item)};
|
|
});
|
|
$scope.metric.itemList = [{name: 'All'}];
|
|
addTemplatedVariables($scope.metric.itemList);
|
|
$scope.metric.itemList = $scope.metric.itemList.concat(uniq_items);
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Add templated variables to list of available metrics
|
|
*
|
|
* @param {Array} metricList List of metrics which variables add to
|
|
*/
|
|
function addTemplatedVariables(metricList) {
|
|
_.each(templateSrv.variables, function (variable) {
|
|
metricList.push({
|
|
name: '$' + variable.name,
|
|
templated: true
|
|
});
|
|
});
|
|
}
|
|
|
|
//////////////////////////////
|
|
// VALIDATION
|
|
//////////////////////////////
|
|
|
|
function validateTarget(target) {
|
|
var errs = {};
|
|
if (!target) {
|
|
errs = 'Not defined';
|
|
}
|
|
return errs;
|
|
}
|
|
|
|
$scope.init();
|
|
|
|
});
|
|
|
|
});
|