return thresholds for expressions with less/greater than or equal

dist/datasource-zabbix/datasource.js

@@ -112,7 +112,7 @@ System.register(['lodash', 'app/core/utils/datemath', './utils', './migrations',
   }
 
   function getTriggerThreshold(expression) {
-    var thresholdPattern = /.*[<>]([\d\.]+)/;
+    var thresholdPattern = /.*[<>=]{1,2}([\d\.]+)/;
     var finded_thresholds = expression.match(thresholdPattern);
     if (finded_thresholds && finded_thresholds.length >= 2) {
       var threshold = finded_thresholds[1];

dist/datasource-zabbix/specs/datasource_specs.js

@@ -11,6 +11,7 @@ describe('ZabbixDatasource', () => {
   beforeEach(() => {
     ctx.instanceSettings = {
       jsonData: {
+        alerting: true,
         username: 'zabbix',
         password: 'zabbix',
         trends: true,
@@ -28,12 +29,12 @@ describe('ZabbixDatasource', () => {
     ctx.zabbix = () => {};
 
     ctx.ds = new Datasource(ctx.instanceSettings, ctx.templateSrv, ctx.alertSrv, ctx.dashboardSrv, ctx.zabbixAlertingSrv, ctx.zabbix);
-    ctx.ds.alertQuery = () => Q.when([]);
   });
 
   describe('When querying data', () => {
     beforeEach(() => {
       ctx.ds.replaceTemplateVars = (str) => str;
+      ctx.ds.alertQuery = () => Q.when([]);
     });
 
     ctx.options = {
@@ -234,4 +235,106 @@ describe('ZabbixDatasource', () => {
     });
   });
 
+  describe('When quering alerts', () => {
+    let options = {};
+
+    beforeEach(() => {
+      ctx.ds.replaceTemplateVars = (str) => str;
+
+      let targetItems = [{
+        "itemid": "1",
+        "name": "test item",
+        "key_": "test.key",
+        "value_type": "3",
+        "hostid": "10631",
+        "status": "0",
+        "state": "0",
+        "hosts": [{"hostid": "10631", "name": "Test host"}],
+        "item": "Test item"
+      }];
+      ctx.ds.zabbix.getItemsFromTarget = () => Promise.resolve(targetItems);
+
+      options = {
+        "panelId": 10,
+        "targets": [{
+          "application": {"filter": ""},
+          "group": {"filter": "Test group"},
+          "host": {"filter": "Test host"},
+          "item": {"filter": "Test item"},
+        }]
+      };
+    });
+
+    it('should return threshold when comparative symbol is `less than`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}<100",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(100);
+          return resp;
+        });
+    });
+
+    it('should return threshold when comparative symbol is `less than or equal`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}<=100",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(100);
+          return resp;
+        });
+    });
+
+    it('should return threshold when comparative symbol is `greater than or equal`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}>=30",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(30);
+          return resp;
+        });
+    });
+
+    it('should return threshold when comparative symbol is `equal`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}=50",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(50);
+          return resp;
+        });
+    });
+  });
 });

dist/test/datasource-zabbix/datasource.js

@@ -809,7 +809,7 @@ function filterEnabledTargets(targets) {
 }
 
 function getTriggerThreshold(expression) {
-  var thresholdPattern = /.*[<>]([\d\.]+)/;
+  var thresholdPattern = /.*[<>=]{1,2}([\d\.]+)/;
   var finded_thresholds = expression.match(thresholdPattern);
   if (finded_thresholds && finded_thresholds.length >= 2) {
     var threshold = finded_thresholds[1];

dist/test/datasource-zabbix/specs/datasource_specs.js

@@ -25,6 +25,7 @@ describe('ZabbixDatasource', function () {
   beforeEach(function () {
     ctx.instanceSettings = {
       jsonData: {
+        alerting: true,
         username: 'zabbix',
         password: 'zabbix',
         trends: true,
@@ -42,9 +43,6 @@ describe('ZabbixDatasource', function () {
     ctx.zabbix = function () {};
 
     ctx.ds = new _module.Datasource(ctx.instanceSettings, ctx.templateSrv, ctx.alertSrv, ctx.dashboardSrv, ctx.zabbixAlertingSrv, ctx.zabbix);
-    ctx.ds.alertQuery = function () {
-      return _q2.default.when([]);
-    };
   });
 
   describe('When querying data', function () {
@@ -52,6 +50,9 @@ describe('ZabbixDatasource', function () {
       ctx.ds.replaceTemplateVars = function (str) {
         return str;
       };
+      ctx.ds.alertQuery = function () {
+        return _q2.default.when([]);
+      };
     });
 
     ctx.options = {
@@ -323,4 +324,115 @@ describe('ZabbixDatasource', function () {
       done();
     });
   });
+
+  describe('When quering alerts', function () {
+    var options = {};
+
+    beforeEach(function () {
+      ctx.ds.replaceTemplateVars = function (str) {
+        return str;
+      };
+
+      var targetItems = [{
+        "itemid": "1",
+        "name": "test item",
+        "key_": "test.key",
+        "value_type": "3",
+        "hostid": "10631",
+        "status": "0",
+        "state": "0",
+        "hosts": [{ "hostid": "10631", "name": "Test host" }],
+        "item": "Test item"
+      }];
+      ctx.ds.zabbix.getItemsFromTarget = function () {
+        return Promise.resolve(targetItems);
+      };
+
+      options = {
+        "panelId": 10,
+        "targets": [{
+          "application": { "filter": "" },
+          "group": { "filter": "Test group" },
+          "host": { "filter": "Test host" },
+          "item": { "filter": "Test item" }
+        }]
+      };
+    });
+
+    it('should return threshold when comparative symbol is `less than`', function () {
+
+      var itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}<100"
+      }];
+
+      ctx.ds.zabbix.getAlerts = function () {
+        return Promise.resolve(itemTriggers);
+      };
+
+      return ctx.ds.alertQuery(options).then(function (resp) {
+        expect(resp.thresholds.length).to.equal(1);
+        expect(resp.thresholds[0]).to.equal(100);
+        return resp;
+      });
+    });
+
+    it('should return threshold when comparative symbol is `less than or equal`', function () {
+
+      var itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}<=100"
+      }];
+
+      ctx.ds.zabbix.getAlerts = function () {
+        return Promise.resolve(itemTriggers);
+      };
+
+      return ctx.ds.alertQuery(options).then(function (resp) {
+        expect(resp.thresholds.length).to.equal(1);
+        expect(resp.thresholds[0]).to.equal(100);
+        return resp;
+      });
+    });
+
+    it('should return threshold when comparative symbol is `greater than or equal`', function () {
+
+      var itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}>=30"
+      }];
+
+      ctx.ds.zabbix.getAlerts = function () {
+        return Promise.resolve(itemTriggers);
+      };
+
+      return ctx.ds.alertQuery(options).then(function (resp) {
+        expect(resp.thresholds.length).to.equal(1);
+        expect(resp.thresholds[0]).to.equal(30);
+        return resp;
+      });
+    });
+
+    it('should return threshold when comparative symbol is `equal`', function () {
+
+      var itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}=50"
+      }];
+
+      ctx.ds.zabbix.getAlerts = function () {
+        return Promise.resolve(itemTriggers);
+      };
+
+      return ctx.ds.alertQuery(options).then(function (resp) {
+        expect(resp.thresholds.length).to.equal(1);
+        expect(resp.thresholds[0]).to.equal(50);
+        return resp;
+      });
+    });
+  });
 });

src/datasource-zabbix/datasource.js

@@ -706,7 +706,7 @@ function filterEnabledTargets(targets) {
 }
 
 function getTriggerThreshold(expression) {
-  let thresholdPattern = /.*[<>]([\d\.]+)/;
+  let thresholdPattern = /.*[<>=]{1,2}([\d\.]+)/;
   let finded_thresholds = expression.match(thresholdPattern);
   if (finded_thresholds && finded_thresholds.length >= 2) {
     let threshold = finded_thresholds[1];

src/datasource-zabbix/specs/datasource_specs.js

@@ -11,6 +11,7 @@ describe('ZabbixDatasource', () => {
   beforeEach(() => {
     ctx.instanceSettings = {
       jsonData: {
+        alerting: true,
         username: 'zabbix',
         password: 'zabbix',
         trends: true,
@@ -28,12 +29,12 @@ describe('ZabbixDatasource', () => {
     ctx.zabbix = () => {};
 
     ctx.ds = new Datasource(ctx.instanceSettings, ctx.templateSrv, ctx.alertSrv, ctx.dashboardSrv, ctx.zabbixAlertingSrv, ctx.zabbix);
-    ctx.ds.alertQuery = () => Q.when([]);
   });
 
   describe('When querying data', () => {
     beforeEach(() => {
       ctx.ds.replaceTemplateVars = (str) => str;
+      ctx.ds.alertQuery = () => Q.when([]);
     });
 
     ctx.options = {
@@ -234,4 +235,106 @@ describe('ZabbixDatasource', () => {
     });
   });
 
+  describe('When querying alerts', () => {
+    let options = {};
+
+    beforeEach(() => {
+      ctx.ds.replaceTemplateVars = (str) => str;
+
+      let targetItems = [{
+        "itemid": "1",
+        "name": "test item",
+        "key_": "test.key",
+        "value_type": "3",
+        "hostid": "10631",
+        "status": "0",
+        "state": "0",
+        "hosts": [{"hostid": "10631", "name": "Test host"}],
+        "item": "Test item"
+      }];
+      ctx.ds.zabbix.getItemsFromTarget = () => Promise.resolve(targetItems);
+
+      options = {
+        "panelId": 10,
+        "targets": [{
+          "application": {"filter": ""},
+          "group": {"filter": "Test group"},
+          "host": {"filter": "Test host"},
+          "item": {"filter": "Test item"},
+        }]
+      };
+    });
+
+    it('should return threshold when comparative symbol is `less than`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}<100",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(100);
+          return resp;
+        });
+    });
+
+    it('should return threshold when comparative symbol is `less than or equal`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}<=100",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(100);
+          return resp;
+        });
+    });
+
+    it('should return threshold when comparative symbol is `greater than or equal`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}>=30",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(30);
+          return resp;
+        });
+    });
+
+    it('should return threshold when comparative symbol is `equal`', () => {
+
+      let itemTriggers = [{
+        "triggerid": "15383",
+        "priority": "4",
+        "expression": "{15915}=50",
+      }];
+
+      ctx.ds.zabbix.getAlerts = () => Promise.resolve(itemTriggers);
+
+      return ctx.ds.alertQuery(options)
+        .then(resp => {
+          expect(resp.thresholds.length).to.equal(1);
+          expect(resp.thresholds[0]).to.equal(50);
+          return resp;
+        });
+    });
+  });
 });