* problems: update panel schema

* update packages (build with node 12)

* problems: use datasource from target

* problems: fix query editor after schema update

* problems: fix list layout

* update circleci node image to 12

* fix tests
This commit is contained in:
Alexander Zobnin
2019-12-25 14:24:15 +03:00
committed by GitHub
parent c1db914376
commit ff4ad1997f
11 changed files with 189 additions and 119 deletions

View File

@@ -56,6 +56,7 @@ export default class AlertCard extends PureComponent<AlertCardProps, AlertCardSt
render() { render() {
const { problem, panelOptions } = this.props; const { problem, panelOptions } = this.props;
const showDatasourceName = panelOptions.targets && panelOptions.targets.length > 1;
const cardClass = classNames('alert-rule-item', 'zbx-trigger-card', { 'zbx-trigger-highlighted': panelOptions.highlightBackground }); const cardClass = classNames('alert-rule-item', 'zbx-trigger-card', { 'zbx-trigger-highlighted': panelOptions.highlightBackground });
const descriptionClass = classNames('alert-rule-item__text', { 'zbx-description--newline': panelOptions.descriptionAtNewLine }); const descriptionClass = classNames('alert-rule-item__text', { 'zbx-description--newline': panelOptions.descriptionAtNewLine });
const severityDesc = _.find(panelOptions.triggerSeverity, s => s.priority === Number(problem.priority)); const severityDesc = _.find(panelOptions.triggerSeverity, s => s.priority === Number(problem.priority));
@@ -134,7 +135,7 @@ export default class AlertCard extends PureComponent<AlertCardProps, AlertCardSt
</div> </div>
</div> </div>
{panelOptions.datasources.length > 1 && ( {showDatasourceName && (
<div className="alert-rule-item__time zabbix-trigger-source"> <div className="alert-rule-item__time zabbix-trigger-source">
<span> <span>
<i className="fa fa-database"></i> <i className="fa fa-database"></i>

View File

@@ -68,7 +68,7 @@ export default class AlertList extends PureComponent<AlertListProps, AlertListSt
<ol className={alertListClass}> <ol className={alertListClass}>
{currentProblems.map(problem => {currentProblems.map(problem =>
<AlertCard <AlertCard
key={problem.triggerid} key={`${problem.triggerid}-${problem.datasource}`}
problem={problem} problem={problem}
panelOptions={panelOptions} panelOptions={panelOptions}
onTagClick={this.handleTagClick} onTagClick={this.handleTagClick}

View File

@@ -1,8 +1,9 @@
import _ from 'lodash'; import _ from 'lodash';
import { getNextRefIdChar } from './utils';
import { getDefaultTarget } from './triggers_panel_ctrl'; import { getDefaultTarget } from './triggers_panel_ctrl';
// Actual schema version // Actual schema version
export const CURRENT_SCHEMA_VERSION = 6; export const CURRENT_SCHEMA_VERSION = 7;
export function migratePanelSchema(panel) { export function migratePanelSchema(panel) {
if (isEmptyPanel(panel)) { if (isEmptyPanel(panel)) {
@@ -45,6 +46,26 @@ export function migratePanelSchema(panel) {
} }
} }
if (schemaVersion < 7) {
const updatedTargets = [];
for (const targetKey in panel.targets) {
const target = panel.targets[targetKey];
if (!isEmptyTarget(target) && !isInvalidTarget(target, targetKey)) {
updatedTargets.push({
...target,
datasource: targetKey,
});
}
}
for (const target of updatedTargets) {
if (!target.refId) {
target.refId = getNextRefIdChar(updatedTargets);
}
}
panel.targets = updatedTargets;
delete panel.datasources;
}
return panel; return panel;
} }
@@ -59,3 +80,11 @@ function isEmptyPanel(panel) {
function isEmptyTargets(targets) { function isEmptyTargets(targets) {
return !targets || (_.isArray(targets) && (targets.length === 0 || targets.length === 1 && _.isEmpty(targets[0]))); return !targets || (_.isArray(targets) && (targets.length === 0 || targets.length === 1 && _.isEmpty(targets[0])));
} }
function isEmptyTarget(target) {
return !target || !(target.group && target.host && target.application && target.trigger);
}
function isInvalidTarget(target, targetKey) {
return target && target.refId === 'A' && targetKey === '0';
}

View File

@@ -6,7 +6,7 @@
</div> </div>
<div class="gf-form"> <div class="gf-form">
<datasource-selector <datasource-selector
datasources="ctrl.panel.datasources" datasources="editor.selectedDatasources"
options="editor.panelCtrl.available_datasources" options="editor.panelCtrl.available_datasources"
on-change="editor.datasourcesChanged()"> on-change="editor.datasourcesChanged()">
</datasource-selector> </datasource-selector>
@@ -15,50 +15,50 @@
</div> </div>
</div> </div>
<div class="editor-row" ng-repeat="ds in ctrl.panel.datasources"> <div class="editor-row" ng-repeat="target in ctrl.panel.targets">
<div class="section gf-form-group"> <div class="section gf-form-group">
<h5 class="section-heading">{{ ds }}</h5> <h5 class="section-heading">{{ target.datasource }}</h5>
<div class="gf-form-inline"> <div class="gf-form-inline">
<div class="gf-form"> <div class="gf-form">
<label class="gf-form-label query-keyword width-7">Group</label> <label class="gf-form-label query-keyword width-7">Group</label>
<input type="text" <input type="text"
ng-model="ctrl.panel.targets[ds].group.filter" ng-model="target.group.filter"
bs-typeahead="editor.getGroupNames[ds]" bs-typeahead="editor.getGroupNames[target.datasource]"
ng-blur="editor.parseTarget()" ng-blur="editor.parseTarget()"
data-min-length=0 data-min-length=0
data-items=100 data-items=100
class="gf-form-input width-14" class="gf-form-input width-14"
ng-class="{ ng-class="{
'zbx-variable': editor.isVariable(ctrl.panel.targets[ds].group.filter), 'zbx-variable': editor.isVariable(target.group.filter),
'zbx-regex': editor.isRegex(ctrl.panel.targets[ds].group.filter) 'zbx-regex': editor.isRegex(target.group.filter)
}"> }">
</div> </div>
<div class="gf-form"> <div class="gf-form">
<label class="gf-form-label query-keyword width-7">Host</label> <label class="gf-form-label query-keyword width-7">Host</label>
<input type="text" <input type="text"
ng-model="ctrl.panel.targets[ds].host.filter" ng-model="target.host.filter"
bs-typeahead="editor.getHostNames[ds]" bs-typeahead="editor.getHostNames[target.datasource]"
ng-blur="editor.parseTarget()" ng-blur="editor.parseTarget()"
data-min-length=0 data-min-length=0
data-items=100 data-items=100
class="gf-form-input width-14" class="gf-form-input width-14"
ng-class="{ ng-class="{
'zbx-variable': editor.isVariable(ctrl.panel.targets[ds].host.filter), 'zbx-variable': editor.isVariable(target.host.filter),
'zbx-regex': editor.isRegex(ctrl.panel.targets[ds].host.filter) 'zbx-regex': editor.isRegex(target.host.filter)
}"> }">
</div> </div>
<div class="gf-form"> <div class="gf-form">
<label class="gf-form-label query-keyword width-7">Proxy</label> <label class="gf-form-label query-keyword width-7">Proxy</label>
<input type="text" <input type="text"
ng-model="ctrl.panel.targets[ds].proxy.filter" ng-model="target.proxy.filter"
bs-typeahead="editor.getProxyNames[ds]" bs-typeahead="editor.getProxyNames[target.datasource]"
ng-blur="editor.parseTarget()" ng-blur="editor.parseTarget()"
data-min-length=0 data-min-length=0
data-items=100 data-items=100
class="gf-form-input width-14" class="gf-form-input width-14"
ng-class="{ ng-class="{
'zbx-variable': editor.isVariable(ctrl.panel.targets[ds].proxy.filter), 'zbx-variable': editor.isVariable(target.proxy.filter),
'zbx-regex': editor.isRegex(ctrl.panel.targets[ds].proxy.filter) 'zbx-regex': editor.isRegex(target.proxy.filter)
}"> }">
</div> </div>
</div> </div>
@@ -67,35 +67,35 @@
<div class="gf-form"> <div class="gf-form">
<label class="gf-form-label query-keyword width-7">Application</label> <label class="gf-form-label query-keyword width-7">Application</label>
<input type="text" <input type="text"
ng-model="ctrl.panel.targets[ds].application.filter" ng-model="target.application.filter"
bs-typeahead="editor.getApplicationNames[ds]" bs-typeahead="editor.getApplicationNames[target.datasource]"
ng-blur="editor.parseTarget()" ng-blur="editor.parseTarget()"
data-min-length=0 data-min-length=0
data-items=100 data-items=100
class="gf-form-input width-14" class="gf-form-input width-14"
ng-class="{ ng-class="{
'zbx-variable': editor.isVariable(ctrl.panel.targets[ds].application.filter), 'zbx-variable': editor.isVariable(target.application.filter),
'zbx-regex': editor.isRegex(ctrl.panel.targets[ds].application.filter) 'zbx-regex': editor.isRegex(target.application.filter)
}"> }">
</div> </div>
<div class="gf-form"> <div class="gf-form">
<label class="gf-form-label query-keyword width-7">Trigger</label> <label class="gf-form-label query-keyword width-7">Trigger</label>
<input type="text" <input type="text"
ng-model="ctrl.panel.targets[ds].trigger.filter" ng-model="target.trigger.filter"
ng-blur="editor.parseTarget()" ng-blur="editor.parseTarget()"
placeholder="trigger name" placeholder="trigger name"
class="gf-form-input width-14" class="gf-form-input width-14"
ng-style="ctrl.panel.targets[ds].trigger.style" ng-style="target.trigger.style"
ng-class="{ ng-class="{
'zbx-variable': editor.isVariable(ctrl.panel.targets[ds].trigger.filter), 'zbx-variable': editor.isVariable(target.trigger.filter),
'zbx-regex': editor.isRegex(ctrl.panel.targets[ds].trigger.filter) 'zbx-regex': editor.isRegex(target.trigger.filter)
}" }"
empty-to-null> empty-to-null>
</div> </div>
<div class="gf-form"> <div class="gf-form">
<label class="gf-form-label query-keyword width-7">Tags</label> <label class="gf-form-label query-keyword width-7">Tags</label>
<input type="text" class="gf-form-input width-14" <input type="text" class="gf-form-input width-14"
ng-model="ctrl.panel.targets[ds].tags.filter" ng-model="target.tags.filter"
ng-blur="editor.parseTarget()" ng-blur="editor.parseTarget()"
placeholder="tag1:value1, tag2:value2"> placeholder="tag1:value1, tag2:value2">
</div> </div>

View File

@@ -5,16 +5,16 @@ import {DEFAULT_TARGET, DEFAULT_SEVERITY, PANEL_DEFAULTS} from '../triggers_pane
import {CURRENT_SCHEMA_VERSION} from '../migrations'; import {CURRENT_SCHEMA_VERSION} from '../migrations';
describe('Triggers Panel schema migration', () => { describe('Triggers Panel schema migration', () => {
let ctx = {}; let ctx: any = {};
let updatePanelCtrl; let updatePanelCtrl;
let datasourceSrvMock = { const datasourceSrvMock = {
getMetricSources: () => { getMetricSources: () => {
return [{ meta: {id: 'alexanderzobnin-zabbix-datasource'}, value: {}, name: 'zabbix_default' }]; return [{ meta: {id: 'alexanderzobnin-zabbix-datasource'}, value: {}, name: 'zabbix_default' }];
}, },
get: () => Promise.resolve({}) get: () => Promise.resolve({})
}; };
let timeoutMock = () => {}; const timeoutMock = () => {};
beforeEach(() => { beforeEach(() => {
ctx = { ctx = {
@@ -47,14 +47,16 @@ describe('Triggers Panel schema migration', () => {
}); });
it('should update old panel schema', () => { it('should update old panel schema', () => {
let updatedPanelCtrl = updatePanelCtrl(ctx.scope); const updatedPanelCtrl = updatePanelCtrl(ctx.scope);
let expected = _.defaultsDeep({ const expected = _.defaultsDeep({
schemaVersion: CURRENT_SCHEMA_VERSION, schemaVersion: CURRENT_SCHEMA_VERSION,
datasources: ['zabbix'], targets: [
targets: { {
'zabbix': DEFAULT_TARGET ...DEFAULT_TARGET,
}, datasource: 'zabbix',
}
],
ageField: true, ageField: true,
statusField: false, statusField: false,
severityField: false, severityField: false,
@@ -68,29 +70,29 @@ describe('Triggers Panel schema migration', () => {
it('should create new panel with default schema', () => { it('should create new panel with default schema', () => {
ctx.scope.panel = {}; ctx.scope.panel = {};
let updatedPanelCtrl = updatePanelCtrl(ctx.scope); const updatedPanelCtrl = updatePanelCtrl(ctx.scope);
let expected = _.defaultsDeep({ const expected = _.defaultsDeep({
schemaVersion: CURRENT_SCHEMA_VERSION, schemaVersion: CURRENT_SCHEMA_VERSION,
datasources: ['zabbix_default'], targets: [{
targets: { ...DEFAULT_TARGET,
'zabbix_default': DEFAULT_TARGET datasource: 'zabbix_default'
} }]
}, PANEL_DEFAULTS); }, PANEL_DEFAULTS);
expect(updatedPanelCtrl.panel).toEqual(expected); expect(updatedPanelCtrl.panel).toEqual(expected);
}); });
it('should set default targets for new panel with empty targets', () => { it('should set default targets for new panel with empty targets', () => {
ctx.scope.panel = { ctx.scope.panel = {
targets: [{}] targets: []
}; };
let updatedPanelCtrl = updatePanelCtrl(ctx.scope); const updatedPanelCtrl = updatePanelCtrl(ctx.scope);
let expected = _.defaultsDeep({ const expected = _.defaultsDeep({
datasources: ['zabbix_default'], targets: [{
targets: { ...DEFAULT_TARGET,
'zabbix_default': DEFAULT_TARGET datasource: 'zabbix_default'
}, }]
}, PANEL_DEFAULTS); }, PANEL_DEFAULTS);
expect(updatedPanelCtrl.panel).toEqual(expected); expect(updatedPanelCtrl.panel).toEqual(expected);

View File

@@ -5,9 +5,9 @@ import {PANEL_DEFAULTS, DEFAULT_TARGET} from '../triggers_panel_ctrl';
// import { create } from 'domain'; // import { create } from 'domain';
describe('TriggerPanelCtrl', () => { describe('TriggerPanelCtrl', () => {
let ctx = {}; let ctx: any = {};
let datasourceSrvMock, zabbixDSMock; let datasourceSrvMock, zabbixDSMock;
let timeoutMock = () => {}; const timeoutMock = () => {};
let createPanelCtrl; let createPanelCtrl;
beforeEach(() => { beforeEach(() => {
@@ -61,7 +61,7 @@ describe('TriggerPanelCtrl', () => {
describe('When adding new panel', () => { describe('When adding new panel', () => {
it('should suggest all zabbix data sources', () => { it('should suggest all zabbix data sources', () => {
ctx.scope.panel = {}; ctx.scope.panel = {};
let panelCtrl = createPanelCtrl(); const panelCtrl = createPanelCtrl();
expect(panelCtrl.available_datasources).toEqual([ expect(panelCtrl.available_datasources).toEqual([
'zabbix_default', 'zabbix' 'zabbix_default', 'zabbix'
]); ]);
@@ -69,10 +69,8 @@ describe('TriggerPanelCtrl', () => {
it('should load first zabbix data source as default', () => { it('should load first zabbix data source as default', () => {
ctx.scope.panel = {}; ctx.scope.panel = {};
let panelCtrl = createPanelCtrl(); const panelCtrl = createPanelCtrl();
expect(panelCtrl.panel.datasources).toEqual([ expect(panelCtrl.panel.targets[0].datasource).toEqual('zabbix_default');
'zabbix_default'
]);
}); });
it('should rewrite default empty target', () => { it('should rewrite default empty target', () => {
@@ -82,7 +80,7 @@ describe('TriggerPanelCtrl', () => {
"refId": "A" "refId": "A"
}], }],
}; };
let panelCtrl = createPanelCtrl(); const panelCtrl = createPanelCtrl();
expect(panelCtrl.available_datasources).toEqual([ expect(panelCtrl.available_datasources).toEqual([
'zabbix_default', 'zabbix' 'zabbix_default', 'zabbix'
]); ]);
@@ -92,16 +90,22 @@ describe('TriggerPanelCtrl', () => {
describe('When refreshing panel', () => { describe('When refreshing panel', () => {
beforeEach(() => { beforeEach(() => {
ctx.scope.panel.datasources = ['zabbix_default', 'zabbix']; ctx.scope.panel.datasources = ['zabbix_default', 'zabbix'];
ctx.scope.panel.targets = { ctx.scope.panel.targets = [
'zabbix_default': DEFAULT_TARGET, {
'zabbix': DEFAULT_TARGET ...DEFAULT_TARGET,
}; datasource: 'zabbix_default'
},
{
...DEFAULT_TARGET,
datasource: 'zabbix'
},
];
ctx.panelCtrl = createPanelCtrl(); ctx.panelCtrl = createPanelCtrl();
}); });
it('should format triggers', (done) => { it('should format triggers', (done) => {
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let formattedTrigger = _.find(ctx.panelCtrl.triggerList, {triggerid: "1"}); const formattedTrigger: any = _.find(ctx.panelCtrl.triggerList, {triggerid: "1"});
expect(formattedTrigger.host).toBe('backend01'); expect(formattedTrigger.host).toBe('backend01');
expect(formattedTrigger.hostTechName).toBe('backend01_tech'); expect(formattedTrigger.hostTechName).toBe('backend01_tech');
expect(formattedTrigger.datasource).toBe('zabbix_default'); expect(formattedTrigger.datasource).toBe('zabbix_default');
@@ -113,7 +117,7 @@ describe('TriggerPanelCtrl', () => {
it('should sort triggers by time by default', (done) => { it('should sort triggers by time by default', (done) => {
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger_ids = _.map(ctx.panelCtrl.triggerList, 'triggerid'); const trigger_ids = _.map(ctx.panelCtrl.triggerList, 'triggerid');
expect(trigger_ids).toEqual([ expect(trigger_ids).toEqual([
'2', '4', '3', '1' '2', '4', '3', '1'
]); ]);
@@ -124,7 +128,7 @@ describe('TriggerPanelCtrl', () => {
it('should sort triggers by severity', (done) => { it('should sort triggers by severity', (done) => {
ctx.panelCtrl.panel.sortTriggersBy = { text: 'severity', value: 'priority' }; ctx.panelCtrl.panel.sortTriggersBy = { text: 'severity', value: 'priority' };
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger_ids = _.map(ctx.panelCtrl.triggerList, 'triggerid'); const trigger_ids = _.map(ctx.panelCtrl.triggerList, 'triggerid');
expect(trigger_ids).toEqual([ expect(trigger_ids).toEqual([
'1', '3', '2', '4' '1', '3', '2', '4'
]); ]);
@@ -134,7 +138,7 @@ describe('TriggerPanelCtrl', () => {
it('should add acknowledges to trigger', (done) => { it('should add acknowledges to trigger', (done) => {
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger = getTriggerById(1, ctx); const trigger = getTriggerById(1, ctx);
expect(trigger.acknowledges).toHaveLength(1); expect(trigger.acknowledges).toHaveLength(1);
expect(trigger.acknowledges[0].message).toBe("event ack"); expect(trigger.acknowledges[0].message).toBe("event ack");
@@ -153,15 +157,15 @@ describe('TriggerPanelCtrl', () => {
it('should handle new lines in trigger description', () => { it('should handle new lines in trigger description', () => {
ctx.panelCtrl.setTriggerSeverity = jest.fn((trigger) => trigger); ctx.panelCtrl.setTriggerSeverity = jest.fn((trigger) => trigger);
let trigger = {comments: "this is\ndescription"}; const trigger = {comments: "this is\ndescription"};
const formattedTrigger = ctx.panelCtrl.formatTrigger(trigger); const formattedTrigger = ctx.panelCtrl.formatTrigger(trigger);
expect(formattedTrigger.comments).toBe("this is<br>description"); expect(formattedTrigger.comments).toBe("this is<br>description");
}); });
it('should format host name to display (default)', (done) => { it('should format host name to display (default)', (done) => {
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger = getTriggerById(1, ctx); const trigger = getTriggerById(1, ctx);
let hostname = ctx.panelCtrl.formatHostName(trigger); const hostname = ctx.panelCtrl.formatHostName(trigger);
expect(hostname).toBe('backend01'); expect(hostname).toBe('backend01');
done(); done();
}); });
@@ -171,8 +175,8 @@ describe('TriggerPanelCtrl', () => {
ctx.panelCtrl.panel.hostField = false; ctx.panelCtrl.panel.hostField = false;
ctx.panelCtrl.panel.hostTechNameField = true; ctx.panelCtrl.panel.hostTechNameField = true;
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger = getTriggerById(1, ctx); const trigger = getTriggerById(1, ctx);
let hostname = ctx.panelCtrl.formatHostName(trigger); const hostname = ctx.panelCtrl.formatHostName(trigger);
expect(hostname).toBe('backend01_tech'); expect(hostname).toBe('backend01_tech');
done(); done();
}); });
@@ -182,8 +186,8 @@ describe('TriggerPanelCtrl', () => {
ctx.panelCtrl.panel.hostField = true; ctx.panelCtrl.panel.hostField = true;
ctx.panelCtrl.panel.hostTechNameField = true; ctx.panelCtrl.panel.hostTechNameField = true;
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger = getTriggerById(1, ctx); const trigger = getTriggerById(1, ctx);
let hostname = ctx.panelCtrl.formatHostName(trigger); const hostname = ctx.panelCtrl.formatHostName(trigger);
expect(hostname).toBe('backend01 (backend01_tech)'); expect(hostname).toBe('backend01 (backend01_tech)');
done(); done();
}); });
@@ -193,8 +197,8 @@ describe('TriggerPanelCtrl', () => {
ctx.panelCtrl.panel.hostField = false; ctx.panelCtrl.panel.hostField = false;
ctx.panelCtrl.panel.hostTechNameField = false; ctx.panelCtrl.panel.hostTechNameField = false;
ctx.panelCtrl.onRefresh().then(() => { ctx.panelCtrl.onRefresh().then(() => {
let trigger = getTriggerById(1, ctx); const trigger = getTriggerById(1, ctx);
let hostname = ctx.panelCtrl.formatHostName(trigger); const hostname = ctx.panelCtrl.formatHostName(trigger);
expect(hostname).toBe(""); expect(hostname).toBe("");
done(); done();
}); });
@@ -222,7 +226,7 @@ describe('TriggerPanelCtrl', () => {
}); });
}); });
const defaultTrigger = { const defaultTrigger: any = {
"triggerid": "13565", "triggerid": "13565",
"value": "1", "value": "1",
"groups": [{"groupid": "1", "name": "Backend"}] , "groups": [{"groupid": "1", "name": "Backend"}] ,
@@ -248,7 +252,7 @@ const defaultTrigger = {
"flags": "0", "type": "0", "items": [] , "error": "" "flags": "0", "type": "0", "items": [] , "error": ""
}; };
const defaultEvent = { const defaultEvent: any = {
"eventid": "11", "eventid": "11",
"acknowledges": [ "acknowledges": [
{ {
@@ -272,8 +276,8 @@ const defaultEvent = {
"objectid": "1", "objectid": "1",
}; };
function generateTrigger(id, timestamp, severity) { function generateTrigger(id, timestamp?, severity?): any {
let trigger = _.cloneDeep(defaultTrigger); const trigger = _.cloneDeep(defaultTrigger);
trigger.triggerid = id.toString(); trigger.triggerid = id.toString();
if (severity) { if (severity) {
trigger.priority = severity.toString(); trigger.priority = severity.toString();
@@ -284,13 +288,13 @@ function generateTrigger(id, timestamp, severity) {
return trigger; return trigger;
} }
function createTrigger(props) { function createTrigger(props): any {
let trigger = _.cloneDeep(defaultTrigger); let trigger = _.cloneDeep(defaultTrigger);
trigger = _.merge(trigger, props); trigger = _.merge(trigger, props);
trigger.lastEvent.objectid = trigger.triggerid; trigger.lastEvent.objectid = trigger.triggerid;
return trigger; return trigger;
} }
function getTriggerById(id, ctx) { function getTriggerById(id, ctx): any {
return _.find(ctx.panelCtrl.triggerList, {triggerid: id.toString()}); return _.find(ctx.panelCtrl.triggerList, {triggerid: id.toString()});
} }

View File

@@ -10,6 +10,7 @@ import { triggerPanelTriggersTab } from './triggers_tab';
import { migratePanelSchema, CURRENT_SCHEMA_VERSION } from './migrations'; import { migratePanelSchema, CURRENT_SCHEMA_VERSION } from './migrations';
import ProblemList from './components/Problems/Problems'; import ProblemList from './components/Problems/Problems';
import AlertList from './components/AlertList/AlertList'; import AlertList from './components/AlertList/AlertList';
import { getNextRefIdChar } from './utils';
const ZABBIX_DS_ID = 'alexanderzobnin-zabbix-datasource'; const ZABBIX_DS_ID = 'alexanderzobnin-zabbix-datasource';
const PROBLEM_EVENTS_LIMIT = 100; const PROBLEM_EVENTS_LIMIT = 100;
@@ -23,7 +24,17 @@ export const DEFAULT_TARGET = {
proxy: {filter: ""}, proxy: {filter: ""},
}; };
export const getDefaultTarget = () => DEFAULT_TARGET; export const getDefaultTarget = (targets) => {
return {
group: {filter: ""},
host: {filter: ""},
application: {filter: ""},
trigger: {filter: ""},
tags: {filter: ""},
proxy: {filter: ""},
refId: getNextRefIdChar(targets),
};
};
export const DEFAULT_SEVERITY = [ export const DEFAULT_SEVERITY = [
{ priority: 0, severity: 'Not classified', color: 'rgb(108, 108, 108)', show: true}, { priority: 0, severity: 'Not classified', color: 'rgb(108, 108, 108)', show: true},
@@ -40,8 +51,7 @@ const DEFAULT_TIME_FORMAT = "DD MMM YYYY HH:mm:ss";
export const PANEL_DEFAULTS = { export const PANEL_DEFAULTS = {
schemaVersion: CURRENT_SCHEMA_VERSION, schemaVersion: CURRENT_SCHEMA_VERSION,
datasources: [], targets: [getDefaultTarget([])],
targets: {},
// Fields // Fields
hostField: true, hostField: true,
hostTechNameField: false, hostTechNameField: false,
@@ -108,11 +118,8 @@ export class TriggerPanelCtrl extends PanelCtrl {
_.defaultsDeep(this.panel, _.cloneDeep(PANEL_DEFAULTS)); _.defaultsDeep(this.panel, _.cloneDeep(PANEL_DEFAULTS));
this.available_datasources = _.map(this.getZabbixDataSources(), 'name'); this.available_datasources = _.map(this.getZabbixDataSources(), 'name');
if (this.panel.datasources.length === 0) { if (this.panel.targets && !this.panel.targets[0].datasource) {
this.panel.datasources.push(this.available_datasources[0]); this.panel.targets[0].datasource = this.available_datasources[0];
}
if (this.isEmptyTargets()) {
this.panel.targets[this.panel.datasources[0]] = getDefaultTarget();
} }
this.initDatasources(); this.initDatasources();
@@ -138,7 +145,11 @@ export class TriggerPanelCtrl extends PanelCtrl {
} }
initDatasources() { initDatasources() {
let promises = _.map(this.panel.datasources, (ds) => { if (!this.panel.targets) {
return;
}
const targetDatasources = _.compact(this.panel.targets.map(target => target.datasource));
let promises = targetDatasources.map(ds => {
// Load datasource // Load datasource
return this.datasourceSrv.get(ds) return this.datasourceSrv.get(ds)
.then(datasource => { .then(datasource => {
@@ -236,14 +247,15 @@ export class TriggerPanelCtrl extends PanelCtrl {
const timeTo = Math.ceil(dateMath.parse(this.range.to) / 1000); const timeTo = Math.ceil(dateMath.parse(this.range.to) / 1000);
const userIsEditor = this.contextSrv.isEditor || this.contextSrv.isGrafanaAdmin; const userIsEditor = this.contextSrv.isEditor || this.contextSrv.isGrafanaAdmin;
let promises = _.map(this.panel.datasources, (ds) => { let promises = _.map(this.panel.targets, (target) => {
const ds = target.datasource;
let proxies; let proxies;
let showAckButton = true; let showAckButton = true;
return this.datasourceSrv.get(ds) return this.datasourceSrv.get(ds)
.then(datasource => { .then(datasource => {
const zabbix = datasource.zabbix; const zabbix = datasource.zabbix;
const showEvents = this.panel.showEvents.value; const showEvents = this.panel.showEvents.value;
const triggerFilter = this.panel.targets[ds]; const triggerFilter = target;
const showProxy = this.panel.hostProxy; const showProxy = this.panel.hostProxy;
const getProxiesPromise = showProxy ? zabbix.getProxies() : () => []; const getProxiesPromise = showProxy ? zabbix.getProxies() : () => [];
showAckButton = !datasource.disableReadOnlyUsersAck || userIsEditor; showAckButton = !datasource.disableReadOnlyUsersAck || userIsEditor;
@@ -284,8 +296,8 @@ export class TriggerPanelCtrl extends PanelCtrl {
}) })
.then(triggers => this.setMaintenanceStatus(triggers)) .then(triggers => this.setMaintenanceStatus(triggers))
.then(triggers => this.setAckButtonStatus(triggers, showAckButton)) .then(triggers => this.setAckButtonStatus(triggers, showAckButton))
.then(triggers => this.filterTriggersPre(triggers, ds)) .then(triggers => this.filterTriggersPre(triggers, target))
.then(triggers => this.addTriggerDataSource(triggers, ds)) .then(triggers => this.addTriggerDataSource(triggers, target))
.then(triggers => this.addTriggerHostProxy(triggers, proxies)); .then(triggers => this.addTriggerHostProxy(triggers, proxies));
}); });
@@ -339,16 +351,17 @@ export class TriggerPanelCtrl extends PanelCtrl {
return triggers; return triggers;
} }
filterTriggersPre(triggerList, ds) { filterTriggersPre(triggerList, target) {
// Filter triggers by description // Filter triggers by description
let triggerFilter = this.panel.targets[ds].trigger.filter; const ds = target.datasource;
let triggerFilter = target.trigger.filter;
triggerFilter = this.datasources[ds].replaceTemplateVars(triggerFilter); triggerFilter = this.datasources[ds].replaceTemplateVars(triggerFilter);
if (triggerFilter) { if (triggerFilter) {
triggerList = filterTriggers(triggerList, triggerFilter); triggerList = filterTriggers(triggerList, triggerFilter);
} }
// Filter by tags // Filter by tags
const target = this.panel.targets[ds]; // const target = this.panel.targets[ds];
if (target.tags.filter) { if (target.tags.filter) {
let tagsFilter = this.datasources[ds].replaceTemplateVars(target.tags.filter); let tagsFilter = this.datasources[ds].replaceTemplateVars(target.tags.filter);
// replaceTemplateVars() builds regex-like string, so we should trim it. // replaceTemplateVars() builds regex-like string, so we should trim it.
@@ -406,9 +419,9 @@ export class TriggerPanelCtrl extends PanelCtrl {
return triggers; return triggers;
} }
addTriggerDataSource(triggers, ds) { addTriggerDataSource(triggers, target) {
_.each(triggers, (trigger) => { _.each(triggers, (trigger) => {
trigger.datasource = ds; trigger.datasource = target.datasource;
}); });
return triggers; return triggers;
} }
@@ -479,24 +492,24 @@ export class TriggerPanelCtrl extends PanelCtrl {
return _.map(tags, (tag) => `${tag.tag}:${tag.value}`).join(', '); return _.map(tags, (tag) => `${tag.tag}:${tag.value}`).join(', ');
} }
addTagFilter(tag, ds) { addTagFilter(tag, target) {
let tagFilter = this.panel.targets[ds].tags.filter; let tagFilter = target.tags.filter;
let targetTags = this.parseTags(tagFilter); let targetTags = this.parseTags(tagFilter);
let newTag = {tag: tag.tag, value: tag.value}; let newTag = {tag: tag.tag, value: tag.value};
targetTags.push(newTag); targetTags.push(newTag);
targetTags = _.uniqWith(targetTags, _.isEqual); targetTags = _.uniqWith(targetTags, _.isEqual);
let newFilter = this.tagsToString(targetTags); let newFilter = this.tagsToString(targetTags);
this.panel.targets[ds].tags.filter = newFilter; target.tags.filter = newFilter;
this.refresh(); this.refresh();
} }
removeTagFilter(tag, ds) { removeTagFilter(tag, target) {
let tagFilter = this.panel.targets[ds].tags.filter; let tagFilter = target.tags.filter;
let targetTags = this.parseTags(tagFilter); let targetTags = this.parseTags(tagFilter);
_.remove(targetTags, t => t.tag === tag.tag && t.value === tag.value); _.remove(targetTags, t => t.tag === tag.tag && t.value === tag.value);
targetTags = _.uniqWith(targetTags, _.isEqual); targetTags = _.uniqWith(targetTags, _.isEqual);
let newFilter = this.tagsToString(targetTags); let newFilter = this.tagsToString(targetTags);
this.panel.targets[ds].tags.filter = newFilter; target.tags.filter = newFilter;
this.refresh(); this.refresh();
} }

View File

@@ -10,7 +10,7 @@ class TriggersTabCtrl {
this.panelCtrl = $scope.ctrl; this.panelCtrl = $scope.ctrl;
this.panel = this.panelCtrl.panel; this.panel = this.panelCtrl.panel;
this.templateSrv = templateSrv; this.templateSrv = templateSrv;
this.datasources = this.panelCtrl.datasources; this.datasources = {};
// Load scope defaults // Load scope defaults
var scopeDefaults = { var scopeDefaults = {
@@ -21,6 +21,7 @@ class TriggersTabCtrl {
oldTarget: _.cloneDeep(this.panel.targets) oldTarget: _.cloneDeep(this.panel.targets)
}; };
_.defaultsDeep(this, scopeDefaults); _.defaultsDeep(this, scopeDefaults);
this.selectedDatasources = this.getSelectedDatasources();
this.initDatasources(); this.initDatasources();
this.panelCtrl.refresh(); this.panelCtrl.refresh();
@@ -30,6 +31,7 @@ class TriggersTabCtrl {
return this.panelCtrl.initDatasources() return this.panelCtrl.initDatasources()
.then((datasources) => { .then((datasources) => {
_.each(datasources, (datasource) => { _.each(datasources, (datasource) => {
this.datasources[datasource.name] = datasource;
this.bindSuggestionFunctions(datasource); this.bindSuggestionFunctions(datasource);
}); });
}); });
@@ -44,6 +46,10 @@ class TriggersTabCtrl {
this.getProxyNames[ds] = _.bind(this.suggestProxies, this, datasource); this.getProxyNames[ds] = _.bind(this.suggestProxies, this, datasource);
} }
getSelectedDatasources() {
return _.compact(this.panel.targets.map(target => target.datasource));
}
suggestGroups(datasource, query, callback) { suggestGroups(datasource, query, callback) {
return datasource.zabbix.getAllGroups() return datasource.zabbix.getAllGroups()
.then(groups => { .then(groups => {
@@ -53,7 +59,8 @@ class TriggersTabCtrl {
} }
suggestHosts(datasource, query, callback) { suggestHosts(datasource, query, callback) {
let groupFilter = datasource.replaceTemplateVars(this.panel.targets[datasource.name].group.filter); const target = this.panel.targets.find(t => t.datasource === datasource.name);
let groupFilter = datasource.replaceTemplateVars(target.group.filter);
return datasource.zabbix.getAllHosts(groupFilter) return datasource.zabbix.getAllHosts(groupFilter)
.then(hosts => { .then(hosts => {
return _.map(hosts, 'name'); return _.map(hosts, 'name');
@@ -62,8 +69,9 @@ class TriggersTabCtrl {
} }
suggestApps(datasource, query, callback) { suggestApps(datasource, query, callback) {
let groupFilter = datasource.replaceTemplateVars(this.panel.targets[datasource.name].group.filter); const target = this.panel.targets.find(t => t.datasource === datasource.name);
let hostFilter = datasource.replaceTemplateVars(this.panel.targets[datasource.name].host.filter); let groupFilter = datasource.replaceTemplateVars(target.group.filter);
let hostFilter = datasource.replaceTemplateVars(target.host.filter);
return datasource.zabbix.getAllApps(groupFilter, hostFilter) return datasource.zabbix.getAllApps(groupFilter, hostFilter)
.then(apps => { .then(apps => {
return _.map(apps, 'name'); return _.map(apps, 'name');
@@ -78,16 +86,17 @@ class TriggersTabCtrl {
} }
datasourcesChanged() { datasourcesChanged() {
_.each(this.panel.datasources, (ds) => { const newTargets = [];
if (!this.panel.targets[ds]) { _.each(this.selectedDatasources, (ds) => {
this.panel.targets[ds] = getDefaultTarget(); const dsTarget = this.panel.targets.find((target => target.datasource === ds));
} if (dsTarget) {
}); newTargets.push(dsTarget);
// Remove unchecked targets } else {
_.each(this.panel.targets, (target, ds) => { const newTarget = getDefaultTarget(this.panel.targets);
if (!_.includes(this.panel.datasources, ds)) { newTarget.datasource = ds;
delete this.panel.targets[ds]; newTargets.push(newTarget);
} }
this.panel.targets = newTargets;
}); });
this.parseTarget(); this.parseTarget();
} }

View File

@@ -1,7 +1,7 @@
export interface ProblemsPanelOptions { export interface ProblemsPanelOptions {
schemaVersion: number; schemaVersion: number;
datasources: any[]; datasources: any[];
targets: Map<string, ProblemsPanelTarget>; targets: ProblemsPanelTarget[];
// Fields // Fields
hostField?: boolean; hostField?: boolean;
hostTechNameField?: boolean; hostTechNameField?: boolean;
@@ -62,6 +62,7 @@ export interface ProblemsPanelTarget {
proxy: { proxy: {
filter: string filter: string
}; };
datasource: string;
} }
export interface TriggerSeverity { export interface TriggerSeverity {

View File

@@ -1,4 +1,6 @@
import _ from 'lodash';
import moment from 'moment'; import moment from 'moment';
import { DataQuery } from '@grafana/ui/';
import * as utils from '../datasource-zabbix/utils'; import * as utils from '../datasource-zabbix/utils';
import { ZBXTrigger } from './types'; import { ZBXTrigger } from './types';
@@ -20,3 +22,13 @@ export function formatLastChange(lastchangeUnix: number, customFormat?: string)
const lastchange = timestamp.format(format); const lastchange = timestamp.format(format);
return lastchange; return lastchange;
} }
export const getNextRefIdChar = (queries: DataQuery[]): string => {
const letters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';
return _.find(letters, refId => {
return _.every(queries, other => {
return other.refId !== refId;
});
});
};

View File

@@ -64,7 +64,6 @@
], ],
"variable-name": [ "variable-name": [
true, true,
"check-format",
"ban-keywords", "ban-keywords",
"allow-leading-underscore", "allow-leading-underscore",
"allow-trailing-underscore", "allow-trailing-underscore",