From 5de016dd808ca2e065c80ba05baf7602924d8c17 Mon Sep 17 00:00:00 2001 From: Alexander Zobnin Date: Thu, 8 Jun 2017 14:17:49 +0300 Subject: [PATCH] refactor: move macros expanding to utils --- dist/datasource-zabbix/utils.js | 45 ++++++++++++++++++++++++++- dist/datasource-zabbix/utils.js.map | 2 +- dist/datasource-zabbix/zabbix.js | 41 +++--------------------- dist/datasource-zabbix/zabbix.js.map | 2 +- dist/test/datasource-zabbix/utils.js | 41 ++++++++++++++++++++++++ dist/test/datasource-zabbix/zabbix.js | 39 ++--------------------- src/datasource-zabbix/utils.js | 41 +++++++++++++++++++++++- src/datasource-zabbix/zabbix.js | 39 ++--------------------- 8 files changed, 135 insertions(+), 115 deletions(-) diff --git a/dist/datasource-zabbix/utils.js b/dist/datasource-zabbix/utils.js index 4a3acc0..0f2c26f 100644 --- a/dist/datasource-zabbix/utils.js +++ b/dist/datasource-zabbix/utils.js @@ -3,7 +3,7 @@ System.register(['lodash', 'moment'], function (_export, _context) { "use strict"; - var _, moment, regexPattern; + var _, moment, MACRO_PATTERN, regexPattern; /** * Expand Zabbix item name @@ -58,6 +58,47 @@ System.register(['lodash', 'moment'], function (_export, _context) { return params; } + /////////// + // MACRO // + /////////// + + function containsMacro(itemName) { + return MACRO_PATTERN.test(itemName); + } + + _export('containsMacro', containsMacro); + + function replaceMacro(item, macros) { + var itemName = item.name; + var item_macros = itemName.match(MACRO_PATTERN); + _.forEach(item_macros, function (macro) { + var host_macros = _.filter(macros, function (m) { + if (m.hostid) { + return m.hostid === item.hostid; + } else { + // Add global macros + return true; + } + }); + + var macro_def = _.find(host_macros, { macro: macro }); + if (macro_def && macro_def.value) { + var macro_value = macro_def.value; + var macro_regex = new RegExp(escapeMacro(macro)); + itemName = itemName.replace(macro_regex, macro_value); + } + }); + + return itemName; + } + + _export('replaceMacro', replaceMacro); + + function escapeMacro(macro) { + macro = macro.replace(/\$/, '\\\$'); + return macro; + } + // Pattern for testing regex function isRegex(str) { return regexPattern.test(str); @@ -186,6 +227,8 @@ System.register(['lodash', 'moment'], function (_export, _context) { moment = _moment.default; }], execute: function () { + MACRO_PATTERN = /{\$[A-Z0-9_\.]+}/g; + _export('regexPattern', regexPattern = /^\/(.*)\/([gmi]*)$/m); _export('regexPattern', regexPattern); diff --git a/dist/datasource-zabbix/utils.js.map b/dist/datasource-zabbix/utils.js.map index aa0fea2..355f553 100644 --- a/dist/datasource-zabbix/utils.js.map +++ b/dist/datasource-zabbix/utils.js.map @@ -1 +1 @@ -{"version":3,"sources":["../../src/datasource-zabbix/utils.js"],"names":["expandItemName","name","key","key_params_str","substring","indexOf","lastIndexOf","key_params","splitKeyParams","i","length","replace","paramStr","params","quoted","in_array","split_symbol","param","_","forEach","symbol","push","isRegex","str","regexPattern","test","isTemplateVariable","templateVariables","variablePattern","variables","map","variable","includes","buildRegex","matches","match","pattern","flags","undefined","RegExp","escapeRegex","value","parseInterval","interval","intervalPattern","momentInterval","exec","moment","duration","Number","valueOf","parseTimeShiftInterval","formatAcknowledges","acknowledges","formatted_acknowledges","each","ack","timestamp","unix","clock","format","alias","surname","message","concat","convertToZabbixAPIUrl","url","zabbixAPIUrlPattern","trimSlashPattern","callOnce","func","promiseKeeper","Promise","resolve","apply","arguments","then","result","contains"],"mappings":";;;;;;;AAGA;;;;;;;AAOO,WAASA,cAAT,CAAwBC,IAAxB,EAA8BC,GAA9B,EAAmC;;AAExC;AACA;AACA,QAAIC,iBAAiBD,IAAIE,SAAJ,CAAcF,IAAIG,OAAJ,CAAY,GAAZ,IAAmB,CAAjC,EAAoCH,IAAII,WAAJ,CAAgB,GAAhB,CAApC,CAArB;AACA,QAAIC,aAAaC,eAAeL,cAAf,CAAjB;;AAEA;AACA,SAAK,IAAIM,IAAIF,WAAWG,MAAxB,EAAgCD,KAAK,CAArC,EAAwCA,GAAxC,EAA6C;AAC3CR,aAAOA,KAAKU,OAAL,CAAa,MAAMF,CAAnB,EAAsBF,WAAWE,IAAI,CAAf,CAAtB,CAAP;AACD;AACD,WAAOR,IAAP;AACD;;4BAZeD,c;;AAchB,WAASQ,cAAT,CAAwBI,QAAxB,EAAkC;AAChC,QAAIC,SAAS,EAAb;AACA,QAAIC,SAAS,KAAb;AACA,QAAIC,WAAW,KAAf;AACA,QAAIC,eAAe,GAAnB;AACA,QAAIC,QAAQ,EAAZ;;AAEAC,MAAEC,OAAF,CAAUP,QAAV,EAAoB,kBAAU;AAC5B,UAAIQ,WAAW,GAAX,IAAkBL,QAAtB,EAAgC;AAC9BE,iBAASG,MAAT;AACD,OAFD,MAEO,IAAIA,WAAW,GAAX,IAAkBN,MAAtB,EAA8B;AACnCA,iBAAS,KAAT;AACD,OAFM,MAEA,IAAIM,WAAW,GAAX,IAAkB,CAACN,MAAvB,EAA+B;AACpCA,iBAAS,IAAT;AACD,OAFM,MAEA,IAAIM,WAAW,GAAX,IAAkB,CAACN,MAAvB,EAA+B;AACpCC,mBAAY,IAAZ;AACD,OAFM,MAEA,IAAIK,WAAW,GAAX,IAAkB,CAACN,MAAvB,EAA+B;AACpCC,mBAAW,KAAX;AACD,OAFM,MAEA,IAAIK,WAAWJ,YAAX,IAA2B,CAACF,MAA5B,IAAsC,CAACC,QAA3C,EAAqD;AAC1DF,eAAOQ,IAAP,CAAYJ,KAAZ;AACAA,gBAAQ,EAAR;AACD,OAHM,MAGA;AACLA,iBAASG,MAAT;AACD;AACF,KAjBD;;AAmBAP,WAAOQ,IAAP,CAAYJ,KAAZ;AACA,WAAOJ,MAAP;AACD;;AAED;AAGO,WAASS,OAAT,CAAiBC,GAAjB,EAAsB;AAC3B,WAAOC,aAAaC,IAAb,CAAkBF,GAAlB,CAAP;AACD;;qBAFeD,O;;AAIT,WAASI,kBAAT,CAA4BH,GAA5B,EAAiCI,iBAAjC,EAAoD;AACzD,QAAIC,kBAAkB,QAAtB;AACA,QAAIA,gBAAgBH,IAAhB,CAAqBF,GAArB,CAAJ,EAA+B;AAC7B,UAAIM,YAAYX,EAAEY,GAAF,CAAMH,iBAAN,EAAyB,oBAAY;AACnD,eAAO,MAAMI,SAAS9B,IAAtB;AACD,OAFe,CAAhB;AAGA,aAAOiB,EAAEc,QAAF,CAAWH,SAAX,EAAsBN,GAAtB,CAAP;AACD,KALD,MAKO;AACL,aAAO,KAAP;AACD;AACF;;gCAVeG,kB;;AAYT,WAASO,UAAT,CAAoBV,GAApB,EAAyB;AAC9B,QAAIW,UAAUX,IAAIY,KAAJ,CAAUX,YAAV,CAAd;AACA,QAAIY,UAAUF,QAAQ,CAAR,CAAd;AACA,QAAIG,QAAQH,QAAQ,CAAR,MAAe,EAAf,GAAoBA,QAAQ,CAAR,CAApB,GAAiCI,SAA7C;AACA,WAAO,IAAIC,MAAJ,CAAWH,OAAX,EAAoBC,KAApB,CAAP;AACD;;AAED;AACA;;wBARgBJ,U;;AAST,WAASO,WAAT,CAAqBC,KAArB,EAA4B;AACjC,WAAOA,MAAM9B,OAAN,CAAc,uBAAd,EAAuC,MAAvC,CAAP;AACD;;yBAFe6B,W;;AAIT,WAASE,aAAT,CAAuBC,QAAvB,EAAiC;AACtC,QAAIC,kBAAkB,0BAAtB;AACA,QAAIC,iBAAiBD,gBAAgBE,IAAhB,CAAqBH,QAArB,CAArB;AACA,WAAOI,OAAOC,QAAP,CAAgBC,OAAOJ,eAAe,CAAf,CAAP,CAAhB,EAA2CA,eAAe,CAAf,CAA3C,EAA8DK,OAA9D,EAAP;AACD;;2BAJeR,a;;AAMT,WAASS,sBAAT,CAAgCR,QAAhC,EAA0C;AAC/C,QAAIC,kBAAkB,mCAAtB;AACA,QAAIC,iBAAiBD,gBAAgBE,IAAhB,CAAqBH,QAArB,CAArB;AACA,QAAIK,WAAW,CAAf;;AAEA,QAAIH,eAAe,CAAf,MAAsB,GAA1B,EAA+B;AAC7BG,iBAAW,IAAID,OAAOC,QAAP,CAAgBC,OAAOJ,eAAe,CAAf,CAAP,CAAhB,EAA2CA,eAAe,CAAf,CAA3C,EAA8DK,OAA9D,EAAf;AACD,KAFD,MAEO;AACLF,iBAAWD,OAAOC,QAAP,CAAgBC,OAAOJ,eAAe,CAAf,CAAP,CAAhB,EAA2CA,eAAe,CAAf,CAA3C,EAA8DK,OAA9D,EAAX;AACD;;AAED,WAAOF,QAAP;AACD;;AAED;;;;;;;oCAdgBG,sB;;AAoBT,WAASC,kBAAT,CAA4BC,YAA5B,EAA0C;AAC/C,QAAIA,aAAa3C,MAAjB,EAAyB;AACvB,UAAI4C,yBAAyB,6DACzB,mDADJ;AAEApC,QAAEqC,IAAF,CAAOrC,EAAEY,GAAF,CAAMuB,YAAN,EAAoB,UAAUG,GAAV,EAAe;AACxC,YAAIC,YAAYV,OAAOW,IAAP,CAAYF,IAAIG,KAAhB,CAAhB;AACA,eAAO,gBAAgBF,UAAUG,MAAV,CAAiB,sBAAjB,CAAhB,GAA2D,eAA3D,GAA6EJ,IAAIK,KAAjF,GACH,IADG,GACIL,IAAIvD,IADR,GACe,GADf,GACqBuD,IAAIM,OADzB,GACmC,GADnC,GACyC,WADzC,GACuDN,IAAIO,OAD3D,GACqE,YAD5E;AAED,OAJM,CAAP,EAII,UAAUP,GAAV,EAAe;AACjBF,iCAAyBA,uBAAuBU,MAAvB,CAA8BR,GAA9B,CAAzB;AACD,OAND;AAOAF,+BAAyBA,uBAAuBU,MAAvB,CAA8B,UAA9B,CAAzB;AACA,aAAOV,sBAAP;AACD,KAZD,MAYO;AACL,aAAO,EAAP;AACD;AACF;;gCAhBeF,kB;;AAkBT,WAASa,qBAAT,CAA+BC,GAA/B,EAAoC;AACzC,QAAIC,sBAAsB,oBAA1B;AACA,QAAIC,mBAAmB,aAAvB;AACA,QAAIF,IAAI/B,KAAJ,CAAUgC,mBAAV,CAAJ,EAAoC;AAClC,aAAOD,GAAP;AACD,KAFD,MAEO;AACL,aAAOA,IAAIvD,OAAJ,CAAYyD,gBAAZ,EAA8B,IAA9B,CAAP;AACD;AACF;;AAED;;;;;mCAVgBH,qB;;AAcT,WAASI,QAAT,CAAkBC,IAAlB,EAAwBC,aAAxB,EAAuC;AAC5C,WAAO,YAAW;AAChB,UAAI,CAACA,aAAL,EAAoB;AAClBA,wBAAgBC,QAAQC,OAAR,CACdH,KAAKI,KAAL,CAAW,IAAX,EAAiBC,SAAjB,EACCC,IADD,CACM,kBAAU;AACdL,0BAAgB,IAAhB;AACA,iBAAOM,MAAP;AACD,SAJD,CADc,CAAhB;AAOD;AACD,aAAON,aAAP;AACD,KAXD;AAYD;;AAED;;sBAfgBF,Q;;;;AAhJTnD,O;;AACA6B,Y;;;8BAsDIvB,Y,GAAe,qB;;;;AAyG1B,UAAI,CAACN,EAAEc,QAAP,EAAiB;AACfd,UAAEc,QAAF,GAAad,EAAE4D,QAAf;AACD","file":"utils.js","sourcesContent":["import _ from 'lodash';\nimport moment from 'moment';\n\n/**\n * Expand Zabbix item name\n *\n * @param {string} name item name, ie \"CPU $2 time\"\n * @param {string} key item key, ie system.cpu.util[,system,avg1]\n * @return {string} expanded name, ie \"CPU system time\"\n */\nexport function expandItemName(name, key) {\n\n // extract params from key:\n // \"system.cpu.util[,system,avg1]\" --> [\"\", \"system\", \"avg1\"]\n let key_params_str = key.substring(key.indexOf('[') + 1, key.lastIndexOf(']'));\n let key_params = splitKeyParams(key_params_str);\n\n // replace item parameters\n for (let i = key_params.length; i >= 1; i--) {\n name = name.replace('$' + i, key_params[i - 1]);\n }\n return name;\n}\n\nfunction splitKeyParams(paramStr) {\n let params = [];\n let quoted = false;\n let in_array = false;\n let split_symbol = ',';\n let param = '';\n\n _.forEach(paramStr, symbol => {\n if (symbol === '\"' && in_array) {\n param += symbol;\n } else if (symbol === '\"' && quoted) {\n quoted = false;\n } else if (symbol === '\"' && !quoted) {\n quoted = true;\n } else if (symbol === '[' && !quoted) {\n in_array = true;\n } else if (symbol === ']' && !quoted) {\n in_array = false;\n } else if (symbol === split_symbol && !quoted && !in_array) {\n params.push(param);\n param = '';\n } else {\n param += symbol;\n }\n });\n\n params.push(param);\n return params;\n}\n\n// Pattern for testing regex\nexport var regexPattern = /^\\/(.*)\\/([gmi]*)$/m;\n\nexport function isRegex(str) {\n return regexPattern.test(str);\n}\n\nexport function isTemplateVariable(str, templateVariables) {\n var variablePattern = /^\\$\\w+/;\n if (variablePattern.test(str)) {\n var variables = _.map(templateVariables, variable => {\n return '$' + variable.name;\n });\n return _.includes(variables, str);\n } else {\n return false;\n }\n}\n\nexport function buildRegex(str) {\n var matches = str.match(regexPattern);\n var pattern = matches[1];\n var flags = matches[2] !== \"\" ? matches[2] : undefined;\n return new RegExp(pattern, flags);\n}\n\n// Need for template variables replace\n// From Grafana's templateSrv.js\nexport function escapeRegex(value) {\n return value.replace(/[\\\\^$*+?.()|[\\]{}\\/]/g, '\\\\$&');\n}\n\nexport function parseInterval(interval) {\n var intervalPattern = /(^[\\d]+)(y|M|w|d|h|m|s)/g;\n var momentInterval = intervalPattern.exec(interval);\n return moment.duration(Number(momentInterval[1]), momentInterval[2]).valueOf();\n}\n\nexport function parseTimeShiftInterval(interval) {\n let intervalPattern = /^([\\+\\-]*)([\\d]+)(y|M|w|d|h|m|s)/g;\n let momentInterval = intervalPattern.exec(interval);\n let duration = 0;\n\n if (momentInterval[1] === '+') {\n duration = 0 - moment.duration(Number(momentInterval[2]), momentInterval[3]).valueOf();\n } else {\n duration = moment.duration(Number(momentInterval[2]), momentInterval[3]).valueOf();\n }\n\n return duration;\n}\n\n/**\n * Format acknowledges.\n *\n * @param {array} acknowledges array of Zabbix acknowledge objects\n * @return {string} HTML-formatted table\n */\nexport function formatAcknowledges(acknowledges) {\n if (acknowledges.length) {\n var formatted_acknowledges = '

Acknowledges:
'\n + '';\n _.each(_.map(acknowledges, function (ack) {\n var timestamp = moment.unix(ack.clock);\n return '';\n }), function (ack) {\n formatted_acknowledges = formatted_acknowledges.concat(ack);\n });\n formatted_acknowledges = formatted_acknowledges.concat('
TimeUserComments
' + timestamp.format(\"DD MMM YYYY HH:mm:ss\") + '' + ack.alias\n + ' (' + ack.name + ' ' + ack.surname + ')' + '' + ack.message + '
');\n return formatted_acknowledges;\n } else {\n return '';\n }\n}\n\nexport function convertToZabbixAPIUrl(url) {\n var zabbixAPIUrlPattern = /.*api_jsonrpc.php$/;\n var trimSlashPattern = /(.*?)[\\/]*$/;\n if (url.match(zabbixAPIUrlPattern)) {\n return url;\n } else {\n return url.replace(trimSlashPattern, \"$1\");\n }\n}\n\n/**\n * Wrap function to prevent multiple calls\n * when waiting for result.\n */\nexport function callOnce(func, promiseKeeper) {\n return function() {\n if (!promiseKeeper) {\n promiseKeeper = Promise.resolve(\n func.apply(this, arguments)\n .then(result => {\n promiseKeeper = null;\n return result;\n })\n );\n }\n return promiseKeeper;\n };\n}\n\n// Fix for backward compatibility with lodash 2.4\nif (!_.includes) {\n _.includes = _.contains;\n}\n"]} \ No newline at end of file +{"version":3,"sources":["../../src/datasource-zabbix/utils.js"],"names":["expandItemName","name","key","key_params_str","substring","indexOf","lastIndexOf","key_params","splitKeyParams","i","length","replace","paramStr","params","quoted","in_array","split_symbol","param","_","forEach","symbol","push","containsMacro","itemName","MACRO_PATTERN","test","replaceMacro","item","macros","item_macros","match","host_macros","filter","m","hostid","macro_def","find","macro","value","macro_value","macro_regex","RegExp","escapeMacro","isRegex","str","regexPattern","isTemplateVariable","templateVariables","variablePattern","variables","map","variable","includes","buildRegex","matches","pattern","flags","undefined","escapeRegex","parseInterval","interval","intervalPattern","momentInterval","exec","moment","duration","Number","valueOf","parseTimeShiftInterval","formatAcknowledges","acknowledges","formatted_acknowledges","each","ack","timestamp","unix","clock","format","alias","surname","message","concat","convertToZabbixAPIUrl","url","zabbixAPIUrlPattern","trimSlashPattern","callOnce","func","promiseKeeper","Promise","resolve","apply","arguments","then","result","contains"],"mappings":";;;;;;;AAGA;;;;;;;AAOO,WAASA,cAAT,CAAwBC,IAAxB,EAA8BC,GAA9B,EAAmC;;AAExC;AACA;AACA,QAAIC,iBAAiBD,IAAIE,SAAJ,CAAcF,IAAIG,OAAJ,CAAY,GAAZ,IAAmB,CAAjC,EAAoCH,IAAII,WAAJ,CAAgB,GAAhB,CAApC,CAArB;AACA,QAAIC,aAAaC,eAAeL,cAAf,CAAjB;;AAEA;AACA,SAAK,IAAIM,IAAIF,WAAWG,MAAxB,EAAgCD,KAAK,CAArC,EAAwCA,GAAxC,EAA6C;AAC3CR,aAAOA,KAAKU,OAAL,CAAa,MAAMF,CAAnB,EAAsBF,WAAWE,IAAI,CAAf,CAAtB,CAAP;AACD;AACD,WAAOR,IAAP;AACD;;4BAZeD,c;;AAchB,WAASQ,cAAT,CAAwBI,QAAxB,EAAkC;AAChC,QAAIC,SAAS,EAAb;AACA,QAAIC,SAAS,KAAb;AACA,QAAIC,WAAW,KAAf;AACA,QAAIC,eAAe,GAAnB;AACA,QAAIC,QAAQ,EAAZ;;AAEAC,MAAEC,OAAF,CAAUP,QAAV,EAAoB,kBAAU;AAC5B,UAAIQ,WAAW,GAAX,IAAkBL,QAAtB,EAAgC;AAC9BE,iBAASG,MAAT;AACD,OAFD,MAEO,IAAIA,WAAW,GAAX,IAAkBN,MAAtB,EAA8B;AACnCA,iBAAS,KAAT;AACD,OAFM,MAEA,IAAIM,WAAW,GAAX,IAAkB,CAACN,MAAvB,EAA+B;AACpCA,iBAAS,IAAT;AACD,OAFM,MAEA,IAAIM,WAAW,GAAX,IAAkB,CAACN,MAAvB,EAA+B;AACpCC,mBAAY,IAAZ;AACD,OAFM,MAEA,IAAIK,WAAW,GAAX,IAAkB,CAACN,MAAvB,EAA+B;AACpCC,mBAAW,KAAX;AACD,OAFM,MAEA,IAAIK,WAAWJ,YAAX,IAA2B,CAACF,MAA5B,IAAsC,CAACC,QAA3C,EAAqD;AAC1DF,eAAOQ,IAAP,CAAYJ,KAAZ;AACAA,gBAAQ,EAAR;AACD,OAHM,MAGA;AACLA,iBAASG,MAAT;AACD;AACF,KAjBD;;AAmBAP,WAAOQ,IAAP,CAAYJ,KAAZ;AACA,WAAOJ,MAAP;AACD;;AAED;AACA;AACA;;AAIO,WAASS,aAAT,CAAuBC,QAAvB,EAAiC;AACtC,WAAOC,cAAcC,IAAd,CAAmBF,QAAnB,CAAP;AACD;;2BAFeD,a;;AAIT,WAASI,YAAT,CAAsBC,IAAtB,EAA4BC,MAA5B,EAAoC;AACzC,QAAIL,WAAWI,KAAK1B,IAApB;AACA,QAAI4B,cAAcN,SAASO,KAAT,CAAeN,aAAf,CAAlB;AACAN,MAAEC,OAAF,CAAUU,WAAV,EAAuB,iBAAS;AAC9B,UAAIE,cAAcb,EAAEc,MAAF,CAASJ,MAAT,EAAiB,aAAK;AACtC,YAAIK,EAAEC,MAAN,EAAc;AACZ,iBAAOD,EAAEC,MAAF,KAAaP,KAAKO,MAAzB;AACD,SAFD,MAEO;AACL;AACA,iBAAO,IAAP;AACD;AACF,OAPiB,CAAlB;;AASA,UAAIC,YAAYjB,EAAEkB,IAAF,CAAOL,WAAP,EAAoB,EAAEM,OAAOA,KAAT,EAApB,CAAhB;AACA,UAAIF,aAAaA,UAAUG,KAA3B,EAAkC;AAChC,YAAIC,cAAcJ,UAAUG,KAA5B;AACA,YAAIE,cAAc,IAAIC,MAAJ,CAAWC,YAAYL,KAAZ,CAAX,CAAlB;AACAd,mBAAWA,SAASZ,OAAT,CAAiB6B,WAAjB,EAA8BD,WAA9B,CAAX;AACD;AACF,KAhBD;;AAkBA,WAAOhB,QAAP;AACD;;0BAtBeG,Y;;AAwBhB,WAASgB,WAAT,CAAqBL,KAArB,EAA4B;AAC1BA,YAAQA,MAAM1B,OAAN,CAAc,IAAd,EAAoB,MAApB,CAAR;AACA,WAAO0B,KAAP;AACD;;AAED;AAGO,WAASM,OAAT,CAAiBC,GAAjB,EAAsB;AAC3B,WAAOC,aAAapB,IAAb,CAAkBmB,GAAlB,CAAP;AACD;;qBAFeD,O;;AAIT,WAASG,kBAAT,CAA4BF,GAA5B,EAAiCG,iBAAjC,EAAoD;AACzD,QAAIC,kBAAkB,QAAtB;AACA,QAAIA,gBAAgBvB,IAAhB,CAAqBmB,GAArB,CAAJ,EAA+B;AAC7B,UAAIK,YAAY/B,EAAEgC,GAAF,CAAMH,iBAAN,EAAyB,oBAAY;AACnD,eAAO,MAAMI,SAASlD,IAAtB;AACD,OAFe,CAAhB;AAGA,aAAOiB,EAAEkC,QAAF,CAAWH,SAAX,EAAsBL,GAAtB,CAAP;AACD,KALD,MAKO;AACL,aAAO,KAAP;AACD;AACF;;gCAVeE,kB;;AAYT,WAASO,UAAT,CAAoBT,GAApB,EAAyB;AAC9B,QAAIU,UAAUV,IAAId,KAAJ,CAAUe,YAAV,CAAd;AACA,QAAIU,UAAUD,QAAQ,CAAR,CAAd;AACA,QAAIE,QAAQF,QAAQ,CAAR,MAAe,EAAf,GAAoBA,QAAQ,CAAR,CAApB,GAAiCG,SAA7C;AACA,WAAO,IAAIhB,MAAJ,CAAWc,OAAX,EAAoBC,KAApB,CAAP;AACD;;AAED;AACA;;wBARgBH,U;;AAST,WAASK,WAAT,CAAqBpB,KAArB,EAA4B;AACjC,WAAOA,MAAM3B,OAAN,CAAc,uBAAd,EAAuC,MAAvC,CAAP;AACD;;yBAFe+C,W;;AAIT,WAASC,aAAT,CAAuBC,QAAvB,EAAiC;AACtC,QAAIC,kBAAkB,0BAAtB;AACA,QAAIC,iBAAiBD,gBAAgBE,IAAhB,CAAqBH,QAArB,CAArB;AACA,WAAOI,OAAOC,QAAP,CAAgBC,OAAOJ,eAAe,CAAf,CAAP,CAAhB,EAA2CA,eAAe,CAAf,CAA3C,EAA8DK,OAA9D,EAAP;AACD;;2BAJeR,a;;AAMT,WAASS,sBAAT,CAAgCR,QAAhC,EAA0C;AAC/C,QAAIC,kBAAkB,mCAAtB;AACA,QAAIC,iBAAiBD,gBAAgBE,IAAhB,CAAqBH,QAArB,CAArB;AACA,QAAIK,WAAW,CAAf;;AAEA,QAAIH,eAAe,CAAf,MAAsB,GAA1B,EAA+B;AAC7BG,iBAAW,IAAID,OAAOC,QAAP,CAAgBC,OAAOJ,eAAe,CAAf,CAAP,CAAhB,EAA2CA,eAAe,CAAf,CAA3C,EAA8DK,OAA9D,EAAf;AACD,KAFD,MAEO;AACLF,iBAAWD,OAAOC,QAAP,CAAgBC,OAAOJ,eAAe,CAAf,CAAP,CAAhB,EAA2CA,eAAe,CAAf,CAA3C,EAA8DK,OAA9D,EAAX;AACD;;AAED,WAAOF,QAAP;AACD;;AAED;;;;;;;oCAdgBG,sB;;AAoBT,WAASC,kBAAT,CAA4BC,YAA5B,EAA0C;AAC/C,QAAIA,aAAa5D,MAAjB,EAAyB;AACvB,UAAI6D,yBAAyB,6DACzB,mDADJ;AAEArD,QAAEsD,IAAF,CAAOtD,EAAEgC,GAAF,CAAMoB,YAAN,EAAoB,UAAUG,GAAV,EAAe;AACxC,YAAIC,YAAYV,OAAOW,IAAP,CAAYF,IAAIG,KAAhB,CAAhB;AACA,eAAO,gBAAgBF,UAAUG,MAAV,CAAiB,sBAAjB,CAAhB,GAA2D,eAA3D,GAA6EJ,IAAIK,KAAjF,GACH,IADG,GACIL,IAAIxE,IADR,GACe,GADf,GACqBwE,IAAIM,OADzB,GACmC,GADnC,GACyC,WADzC,GACuDN,IAAIO,OAD3D,GACqE,YAD5E;AAED,OAJM,CAAP,EAII,UAAUP,GAAV,EAAe;AACjBF,iCAAyBA,uBAAuBU,MAAvB,CAA8BR,GAA9B,CAAzB;AACD,OAND;AAOAF,+BAAyBA,uBAAuBU,MAAvB,CAA8B,UAA9B,CAAzB;AACA,aAAOV,sBAAP;AACD,KAZD,MAYO;AACL,aAAO,EAAP;AACD;AACF;;gCAhBeF,kB;;AAkBT,WAASa,qBAAT,CAA+BC,GAA/B,EAAoC;AACzC,QAAIC,sBAAsB,oBAA1B;AACA,QAAIC,mBAAmB,aAAvB;AACA,QAAIF,IAAIrD,KAAJ,CAAUsD,mBAAV,CAAJ,EAAoC;AAClC,aAAOD,GAAP;AACD,KAFD,MAEO;AACL,aAAOA,IAAIxE,OAAJ,CAAY0E,gBAAZ,EAA8B,IAA9B,CAAP;AACD;AACF;;AAED;;;;;mCAVgBH,qB;;AAcT,WAASI,QAAT,CAAkBC,IAAlB,EAAwBC,aAAxB,EAAuC;AAC5C,WAAO,YAAW;AAChB,UAAI,CAACA,aAAL,EAAoB;AAClBA,wBAAgBC,QAAQC,OAAR,CACdH,KAAKI,KAAL,CAAW,IAAX,EAAiBC,SAAjB,EACCC,IADD,CACM,kBAAU;AACdL,0BAAgB,IAAhB;AACA,iBAAOM,MAAP;AACD,SAJD,CADc,CAAhB;AAOD;AACD,aAAON,aAAP;AACD,KAXD;AAYD;;AAED;;sBAfgBF,Q;;;;AAvLTpE,O;;AACA8C,Y;;;AAyDDxC,mB,GAAgB,mB;;8BAoCTqB,Y,GAAe,qB;;;;AAyG5B,UAAI,CAAC3B,EAAEkC,QAAP,EAAiB;AACflC,UAAEkC,QAAF,GAAalC,EAAE6E,QAAf;AACD","file":"utils.js","sourcesContent":["import _ from 'lodash';\nimport moment from 'moment';\n\n/**\n * Expand Zabbix item name\n *\n * @param {string} name item name, ie \"CPU $2 time\"\n * @param {string} key item key, ie system.cpu.util[,system,avg1]\n * @return {string} expanded name, ie \"CPU system time\"\n */\nexport function expandItemName(name, key) {\n\n // extract params from key:\n // \"system.cpu.util[,system,avg1]\" --> [\"\", \"system\", \"avg1\"]\n let key_params_str = key.substring(key.indexOf('[') + 1, key.lastIndexOf(']'));\n let key_params = splitKeyParams(key_params_str);\n\n // replace item parameters\n for (let i = key_params.length; i >= 1; i--) {\n name = name.replace('$' + i, key_params[i - 1]);\n }\n return name;\n}\n\nfunction splitKeyParams(paramStr) {\n let params = [];\n let quoted = false;\n let in_array = false;\n let split_symbol = ',';\n let param = '';\n\n _.forEach(paramStr, symbol => {\n if (symbol === '\"' && in_array) {\n param += symbol;\n } else if (symbol === '\"' && quoted) {\n quoted = false;\n } else if (symbol === '\"' && !quoted) {\n quoted = true;\n } else if (symbol === '[' && !quoted) {\n in_array = true;\n } else if (symbol === ']' && !quoted) {\n in_array = false;\n } else if (symbol === split_symbol && !quoted && !in_array) {\n params.push(param);\n param = '';\n } else {\n param += symbol;\n }\n });\n\n params.push(param);\n return params;\n}\n\n///////////\n// MACRO //\n///////////\n\nconst MACRO_PATTERN = /{\\$[A-Z0-9_\\.]+}/g;\n\nexport function containsMacro(itemName) {\n return MACRO_PATTERN.test(itemName);\n}\n\nexport function replaceMacro(item, macros) {\n let itemName = item.name;\n let item_macros = itemName.match(MACRO_PATTERN);\n _.forEach(item_macros, macro => {\n let host_macros = _.filter(macros, m => {\n if (m.hostid) {\n return m.hostid === item.hostid;\n } else {\n // Add global macros\n return true;\n }\n });\n\n let macro_def = _.find(host_macros, { macro: macro });\n if (macro_def && macro_def.value) {\n let macro_value = macro_def.value;\n let macro_regex = new RegExp(escapeMacro(macro));\n itemName = itemName.replace(macro_regex, macro_value);\n }\n });\n\n return itemName;\n}\n\nfunction escapeMacro(macro) {\n macro = macro.replace(/\\$/, '\\\\\\$');\n return macro;\n}\n\n// Pattern for testing regex\nexport const regexPattern = /^\\/(.*)\\/([gmi]*)$/m;\n\nexport function isRegex(str) {\n return regexPattern.test(str);\n}\n\nexport function isTemplateVariable(str, templateVariables) {\n var variablePattern = /^\\$\\w+/;\n if (variablePattern.test(str)) {\n var variables = _.map(templateVariables, variable => {\n return '$' + variable.name;\n });\n return _.includes(variables, str);\n } else {\n return false;\n }\n}\n\nexport function buildRegex(str) {\n var matches = str.match(regexPattern);\n var pattern = matches[1];\n var flags = matches[2] !== \"\" ? matches[2] : undefined;\n return new RegExp(pattern, flags);\n}\n\n// Need for template variables replace\n// From Grafana's templateSrv.js\nexport function escapeRegex(value) {\n return value.replace(/[\\\\^$*+?.()|[\\]{}\\/]/g, '\\\\$&');\n}\n\nexport function parseInterval(interval) {\n var intervalPattern = /(^[\\d]+)(y|M|w|d|h|m|s)/g;\n var momentInterval = intervalPattern.exec(interval);\n return moment.duration(Number(momentInterval[1]), momentInterval[2]).valueOf();\n}\n\nexport function parseTimeShiftInterval(interval) {\n let intervalPattern = /^([\\+\\-]*)([\\d]+)(y|M|w|d|h|m|s)/g;\n let momentInterval = intervalPattern.exec(interval);\n let duration = 0;\n\n if (momentInterval[1] === '+') {\n duration = 0 - moment.duration(Number(momentInterval[2]), momentInterval[3]).valueOf();\n } else {\n duration = moment.duration(Number(momentInterval[2]), momentInterval[3]).valueOf();\n }\n\n return duration;\n}\n\n/**\n * Format acknowledges.\n *\n * @param {array} acknowledges array of Zabbix acknowledge objects\n * @return {string} HTML-formatted table\n */\nexport function formatAcknowledges(acknowledges) {\n if (acknowledges.length) {\n var formatted_acknowledges = '

Acknowledges:
'\n + '';\n _.each(_.map(acknowledges, function (ack) {\n var timestamp = moment.unix(ack.clock);\n return '';\n }), function (ack) {\n formatted_acknowledges = formatted_acknowledges.concat(ack);\n });\n formatted_acknowledges = formatted_acknowledges.concat('
TimeUserComments
' + timestamp.format(\"DD MMM YYYY HH:mm:ss\") + '' + ack.alias\n + ' (' + ack.name + ' ' + ack.surname + ')' + '' + ack.message + '
');\n return formatted_acknowledges;\n } else {\n return '';\n }\n}\n\nexport function convertToZabbixAPIUrl(url) {\n var zabbixAPIUrlPattern = /.*api_jsonrpc.php$/;\n var trimSlashPattern = /(.*?)[\\/]*$/;\n if (url.match(zabbixAPIUrlPattern)) {\n return url;\n } else {\n return url.replace(trimSlashPattern, \"$1\");\n }\n}\n\n/**\n * Wrap function to prevent multiple calls\n * when waiting for result.\n */\nexport function callOnce(func, promiseKeeper) {\n return function() {\n if (!promiseKeeper) {\n promiseKeeper = Promise.resolve(\n func.apply(this, arguments)\n .then(result => {\n promiseKeeper = null;\n return result;\n })\n );\n }\n return promiseKeeper;\n };\n}\n\n// Fix for backward compatibility with lodash 2.4\nif (!_.includes) {\n _.includes = _.contains;\n}\n"]} \ No newline at end of file diff --git a/dist/datasource-zabbix/zabbix.js b/dist/datasource-zabbix/zabbix.js index faa504b..e69ea82 100644 --- a/dist/datasource-zabbix/zabbix.js +++ b/dist/datasource-zabbix/zabbix.js @@ -3,7 +3,7 @@ System.register(['angular', 'lodash', './utils', './zabbixAPI.service.js', './zabbixCachingProxy.service.js'], function (_export, _context) { "use strict"; - var angular, _, utils, _createClass, MACRO_PATTERN; + var angular, _, utils, _createClass; function _toConsumableArray(arr) { if (Array.isArray(arr)) { @@ -152,8 +152,8 @@ System.register(['angular', 'lodash', './utils', './zabbixAPI.service.js', './za var hostids = getHostIds(items); return this.getMacros(hostids).then(function (macros) { _.forEach(items, function (item) { - if (containsMacro(item.name)) { - item.name = replaceMacro(item, macros); + if (utils.containsMacro(item.name)) { + item.name = utils.replaceMacro(item, macros); } }); return items; @@ -267,39 +267,6 @@ System.register(['angular', 'lodash', './utils', './zabbixAPI.service.js', './za }); return _.uniq(_.flatten(hostIds)); } - - function containsMacro(itemName) { - return MACRO_PATTERN.test(itemName); - } - - function replaceMacro(item, macros) { - var itemName = item.name; - var item_macros = itemName.match(MACRO_PATTERN); - _.forEach(item_macros, function (macro) { - var host_macros = _.filter(macros, function (m) { - if (m.hostid) { - return m.hostid === item.hostid; - } else { - // Add global macros - return true; - } - }); - - var macro_def = _.find(host_macros, { macro: macro }); - if (macro_def && macro_def.value) { - var macro_value = macro_def.value; - var macro_regex = new RegExp(escapeMacro(macro)); - itemName = itemName.replace(macro_regex, macro_value); - } - }); - - return itemName; - } - - function escapeMacro(macro) { - macro = macro.replace(/\$/, '\\\$'); - return macro; - } return { setters: [function (_angular) { angular = _angular.default; @@ -327,7 +294,7 @@ System.register(['angular', 'lodash', './utils', './zabbixAPI.service.js', './za }; }(); - angular.module('grafana.services').factory('Zabbix', ZabbixFactory);MACRO_PATTERN = /{\$[A-Z0-9_\.]+}/g; + angular.module('grafana.services').factory('Zabbix', ZabbixFactory); } }; }); diff --git a/dist/datasource-zabbix/zabbix.js.map b/dist/datasource-zabbix/zabbix.js.map index dd11319..d353c70 100644 --- a/dist/datasource-zabbix/zabbix.js.map +++ b/dist/datasource-zabbix/zabbix.js.map @@ -1 +1 @@ -{"version":3,"sources":["../../src/datasource-zabbix/zabbix.js"],"names":["ZabbixFactory","zabbixAPIService","ZabbixCachingProxy","Zabbix","url","username","password","basicAuth","withCredentials","cacheTTL","ZabbixAPI","zabbixAPI","cacheOptions","enabled","ttl","cachingProxy","getHistory","bind","getMacros","getTrend","getEvents","getAlerts","getAcknowledges","getITService","getSLA","getVersion","login","target","options","parts","filters","_","map","p","filter","getItems","getGroups","groupFilter","getAllGroups","then","findByFilter","groups","groupids","getHosts","hostFilter","getAllHosts","hosts","hostids","getApps","appFilter","filterByQuery","apps","appFilterEmpty","undefined","itemtype","appids","showDisabledItems","items","expandUserMacro","getHostIds","forEach","containsMacro","item","name","replaceMacro","macros","itemFilter","getAllItems","showTriggers","hideHostsInMaintenance","promises","Promise","all","filteredGroups","results","filteredHosts","filteredApps","query","applicationids","flatten","getTriggers","findByName","list","finded","find","filterByName","filterByRegex","regex","filterPattern","utils","buildRegex","zbx_obj","test","isRegex","hostIds","uniq","itemName","MACRO_PATTERN","item_macros","match","host_macros","m","hostid","macro_def","macro","value","macro_value","macro_regex","RegExp","escapeMacro","replace","angular","module","factory"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;AAMA;AACA;;AAEA;AACA,WAASA,aAAT,CAAuBC,gBAAvB,EAAyCC,kBAAzC,EAA6D;AAAA,QAErDC,MAFqD;AAGzD,sBAAYC,GAAZ,EAAiBC,QAAjB,EAA2BC,QAA3B,EAAqCC,SAArC,EAAgDC,eAAhD,EAAiEC,QAAjE,EAA2E;AAAA;;AAEzE;AACA,YAAIC,YAAYT,gBAAhB;AACA,aAAKU,SAAL,GAAiB,IAAID,SAAJ,CAAcN,GAAd,EAAmBC,QAAnB,EAA6BC,QAA7B,EAAuCC,SAAvC,EAAkDC,eAAlD,CAAjB;;AAEA;AACA,YAAII,eAAe;AACjBC,mBAAS,IADQ;AAEjBC,eAAKL;AAFY,SAAnB;AAIA,aAAKM,YAAL,GAAoB,IAAIb,kBAAJ,CAAuB,KAAKS,SAA5B,EAAuCC,YAAvC,CAApB;;AAEA;AACA,aAAKI,UAAL,GAAkB,KAAKD,YAAL,CAAkBC,UAAlB,CAA6BC,IAA7B,CAAkC,KAAKF,YAAvC,CAAlB;AACA,aAAKG,SAAL,GAAiB,KAAKH,YAAL,CAAkBG,SAAlB,CAA4BD,IAA5B,CAAiC,KAAKF,YAAtC,CAAjB;;AAEA,aAAKI,QAAL,GAAgB,KAAKR,SAAL,CAAeQ,QAAf,CAAwBF,IAAxB,CAA6B,KAAKN,SAAlC,CAAhB;AACA,aAAKS,SAAL,GAAiB,KAAKT,SAAL,CAAeS,SAAf,CAAyBH,IAAzB,CAA8B,KAAKN,SAAnC,CAAjB;AACA,aAAKU,SAAL,GAAiB,KAAKV,SAAL,CAAeU,SAAf,CAAyBJ,IAAzB,CAA8B,KAAKN,SAAnC,CAAjB;AACA,aAAKW,eAAL,GAAuB,KAAKX,SAAL,CAAeW,eAAf,CAA+BL,IAA/B,CAAoC,KAAKN,SAAzC,CAAvB;AACA,aAAKY,YAAL,GAAoB,KAAKZ,SAAL,CAAeY,YAAf,CAA4BN,IAA5B,CAAiC,KAAKN,SAAtC,CAApB;AACA,aAAKa,MAAL,GAAc,KAAKb,SAAL,CAAea,MAAf,CAAsBP,IAAtB,CAA2B,KAAKN,SAAhC,CAAd;AACA,aAAKc,UAAL,GAAkB,KAAKd,SAAL,CAAec,UAAf,CAA0BR,IAA1B,CAA+B,KAAKN,SAApC,CAAlB;AACA,aAAKe,KAAL,GAAa,KAAKf,SAAL,CAAee,KAAf,CAAqBT,IAArB,CAA0B,KAAKN,SAA/B,CAAb;AACD;;AA5BwD;AAAA;AAAA,2CA8BtCgB,MA9BsC,EA8B9BC,OA9B8B,EA8BrB;AAClC,cAAIC,QAAQ,CAAC,OAAD,EAAU,MAAV,EAAkB,aAAlB,EAAiC,MAAjC,CAAZ;AACA,cAAIC,UAAUC,EAAEC,GAAF,CAAMH,KAAN,EAAa;AAAA,mBAAKF,OAAOM,CAAP,EAAUC,MAAf;AAAA,WAAb,CAAd;AACA,iBAAO,KAAKC,QAAL,gCAAiBL,OAAjB,UAA0BF,OAA1B,GAAP;AACD;AAlCwD;AAAA;AAAA,uCAoC1C;AACb,iBAAO,KAAKb,YAAL,CAAkBqB,SAAlB,EAAP;AACD;AAtCwD;AAAA;AAAA,kCAwC/CC,WAxC+C,EAwClC;AACrB,iBAAO,KAAKC,YAAL,GACNC,IADM,CACD;AAAA,mBAAUC,aAAaC,MAAb,EAAqBJ,WAArB,CAAV;AAAA,WADC,CAAP;AAED;AA3CwD;AAAA;AAAA,oCAgD7CA,WAhD6C,EAgDhC;AAAA;;AACvB,iBAAO,KAAKD,SAAL,CAAeC,WAAf,EACNE,IADM,CACD,kBAAU;AACd,gBAAIG,WAAWX,EAAEC,GAAF,CAAMS,MAAN,EAAc,SAAd,CAAf;AACA,mBAAO,MAAK1B,YAAL,CAAkB4B,QAAlB,CAA2BD,QAA3B,CAAP;AACD,WAJM,CAAP;AAKD;AAtDwD;AAAA;AAAA,iCAwDhDL,WAxDgD,EAwDnCO,UAxDmC,EAwDvB;AAChC,iBAAO,KAAKC,WAAL,CAAiBR,WAAjB,EACNE,IADM,CACD;AAAA,mBAASC,aAAaM,KAAb,EAAoBF,UAApB,CAAT;AAAA,WADC,CAAP;AAED;AA3DwD;AAAA;AAAA,mCAgE9CP,WAhE8C,EAgEjCO,UAhEiC,EAgErB;AAAA;;AAClC,iBAAO,KAAKD,QAAL,CAAcN,WAAd,EAA2BO,UAA3B,EACNL,IADM,CACD,iBAAS;AACb,gBAAIQ,UAAUhB,EAAEC,GAAF,CAAMc,KAAN,EAAa,QAAb,CAAd;AACA,mBAAO,OAAK/B,YAAL,CAAkBiC,OAAlB,CAA0BD,OAA1B,CAAP;AACD,WAJM,CAAP;AAKD;AAtEwD;AAAA;AAAA,gCAwEjDV,WAxEiD,EAwEpCO,UAxEoC,EAwExBK,SAxEwB,EAwEb;AAAA;;AAC1C,iBAAO,KAAKN,QAAL,CAAcN,WAAd,EAA2BO,UAA3B,EACNL,IADM,CACD,iBAAS;AACb,gBAAIQ,UAAUhB,EAAEC,GAAF,CAAMc,KAAN,EAAa,QAAb,CAAd;AACA,gBAAIG,SAAJ,EAAe;AACb,qBAAO,OAAKlC,YAAL,CAAkBiC,OAAlB,CAA0BD,OAA1B,EACNR,IADM,CACD;AAAA,uBAAQW,cAAcC,IAAd,EAAoBF,SAApB,CAAR;AAAA,eADC,CAAP;AAED,aAHD,MAGO;AACL,qBAAO;AACLG,gCAAgB,IADX;AAELL,yBAASA;AAFJ,eAAP;AAID;AACF,WAZM,CAAP;AAaD;AAtFwD;AAAA;AAAA,oCAwF7CV,WAxF6C,EAwFhCO,UAxFgC,EAwFpBK,SAxFoB,EAwFK;AAAA;;AAAA,cAAdrB,OAAc,uEAAJ,EAAI;;AAC5D,iBAAO,KAAKoB,OAAL,CAAaX,WAAb,EAA0BO,UAA1B,EAAsCK,SAAtC,EACNV,IADM,CACD,gBAAQ;AACZ,gBAAIY,KAAKC,cAAT,EAAyB;AACvB,qBAAO,OAAKrC,YAAL,CAAkBoB,QAAlB,CAA2BgB,KAAKJ,OAAhC,EAAyCM,SAAzC,EAAoDzB,QAAQ0B,QAA5D,CAAP;AACD,aAFD,MAEO;AACL,kBAAIC,SAASxB,EAAEC,GAAF,CAAMmB,IAAN,EAAY,eAAZ,CAAb;AACA,qBAAO,OAAKpC,YAAL,CAAkBoB,QAAlB,CAA2BkB,SAA3B,EAAsCE,MAAtC,EAA8C3B,QAAQ0B,QAAtD,CAAP;AACD;AACF,WARM,EASNf,IATM,CASD,iBAAS;AACb,gBAAI,CAACX,QAAQ4B,iBAAb,EAAgC;AAC9BC,sBAAQ1B,EAAEG,MAAF,CAASuB,KAAT,EAAgB,EAAC,UAAU,GAAX,EAAhB,CAAR;AACD;;AAED,mBAAOA,KAAP;AACD,WAfM,EAgBNlB,IAhBM,CAgBD,KAAKmB,eAAL,CAAqBzC,IAArB,CAA0B,IAA1B,CAhBC,CAAP;AAiBD;AA1GwD;AAAA;AAAA,wCA4GzCwC,KA5GyC,EA4GlC;AACrB,cAAIV,UAAUY,WAAWF,KAAX,CAAd;AACA,iBAAO,KAAKvC,SAAL,CAAe6B,OAAf,EACNR,IADM,CACD,kBAAU;AACdR,cAAE6B,OAAF,CAAUH,KAAV,EAAiB,gBAAQ;AACvB,kBAAII,cAAcC,KAAKC,IAAnB,CAAJ,EAA8B;AAC5BD,qBAAKC,IAAL,GAAYC,aAAaF,IAAb,EAAmBG,MAAnB,CAAZ;AACD;AACF,aAJD;AAKA,mBAAOR,KAAP;AACD,WARM,CAAP;AASD;AAvHwD;AAAA;AAAA,iCAyHhDpB,WAzHgD,EAyHnCO,UAzHmC,EAyHvBK,SAzHuB,EAyHZiB,UAzHY,EAyHc;AAAA,cAAdtC,OAAc,uEAAJ,EAAI;;AACrE,iBAAO,KAAKuC,WAAL,CAAiB9B,WAAjB,EAA8BO,UAA9B,EAA0CK,SAA1C,EAAqDrB,OAArD,EACNW,IADM,CACD;AAAA,mBAASW,cAAcO,KAAd,EAAqBS,UAArB,CAAT;AAAA,WADC,CAAP;AAED;AA5HwD;AAAA;AAAA,oCAiI7C7B,WAjI6C,EAiIhCO,UAjIgC,EAiIpBK,SAjIoB,EAiITmB,YAjIS,EAiIKC,sBAjIL,EAiI6B;AAAA;;AACpF,cAAIC,WAAW,CACb,KAAKlC,SAAL,CAAeC,WAAf,CADa,EAEb,KAAKM,QAAL,CAAcN,WAAd,EAA2BO,UAA3B,CAFa,EAGb,KAAKI,OAAL,CAAaX,WAAb,EAA0BO,UAA1B,EAAsCK,SAAtC,CAHa,CAAf;;AAMA,iBAAOsB,QAAQC,GAAR,CAAYF,QAAZ,EACN/B,IADM,CACD,mBAAW;AACf,gBAAIkC,iBAAiBC,QAAQ,CAAR,CAArB;AACA,gBAAIC,gBAAgBD,QAAQ,CAAR,CAApB;AACA,gBAAIE,eAAeF,QAAQ,CAAR,CAAnB;AACA,gBAAIG,QAAQ,EAAZ;;AAEA,gBAAI5B,SAAJ,EAAe;AACb4B,oBAAMC,cAAN,GAAuB/C,EAAEgD,OAAF,CAAUhD,EAAEC,GAAF,CAAM4C,YAAN,EAAoB,eAApB,CAAV,CAAvB;AACD;AACD,gBAAIhC,UAAJ,EAAgB;AACdiC,oBAAM9B,OAAN,GAAgBhB,EAAEC,GAAF,CAAM2C,aAAN,EAAqB,QAArB,CAAhB;AACD;AACD,gBAAItC,WAAJ,EAAiB;AACfwC,oBAAMnC,QAAN,GAAiBX,EAAEC,GAAF,CAAMyC,cAAN,EAAsB,SAAtB,CAAjB;AACD;;AAED,mBAAOI,KAAP;AACD,WAlBM,EAkBJtC,IAlBI,CAkBC,iBAAS;AACf,mBAAO,OAAK5B,SAAL,CACNqE,WADM,CACMH,MAAMnC,QADZ,EACsBmC,MAAM9B,OAD5B,EACqC8B,MAAMC,cAD3C,EAC2DV,YAD3D,EACyEC,sBADzE,CAAP;AAED,WArBM,CAAP;AAsBD;AA9JwD;;AAAA;AAAA;;AAiK3D,WAAOlE,MAAP;AACD;;AAMD;;AAEA;;;;;;AAMA,WAAS8E,UAAT,CAAoBC,IAApB,EAA0BnB,IAA1B,EAAgC;AAC9B,QAAIoB,SAASpD,EAAEqD,IAAF,CAAOF,IAAP,EAAa,EAAC,QAAQnB,IAAT,EAAb,CAAb;AACA,QAAIoB,MAAJ,EAAY;AACV,aAAO,CAACA,MAAD,CAAP;AACD,KAFD,MAEO;AACL,aAAO,EAAP;AACD;AACF;;AAED;;;;;;;;AAQA,WAASE,YAAT,CAAsBH,IAAtB,EAA4BnB,IAA5B,EAAkC;AAChC,QAAIoB,SAASpD,EAAEG,MAAF,CAASgD,IAAT,EAAe,EAAC,QAAQnB,IAAT,EAAf,CAAb;AACA,QAAIoB,MAAJ,EAAY;AACV,aAAOA,MAAP;AACD,KAFD,MAEO;AACL,aAAO,EAAP;AACD;AACF;;AAED,WAASG,aAAT,CAAuBJ,IAAvB,EAA6BK,KAA7B,EAAoC;AAClC,QAAIC,gBAAgBC,MAAMC,UAAN,CAAiBH,KAAjB,CAApB;AACA,WAAOxD,EAAEG,MAAF,CAASgD,IAAT,EAAe,UAAUS,OAAV,EAAmB;AACvC,aAAOH,cAAcI,IAAd,CAAmBD,QAAQ5B,IAA3B,CAAP;AACD,KAFM,CAAP;AAGD;;AAED,WAASvB,YAAT,CAAsB0C,IAAtB,EAA4BhD,MAA5B,EAAoC;AAClC,QAAIuD,MAAMI,OAAN,CAAc3D,MAAd,CAAJ,EAA2B;AACzB,aAAOoD,cAAcJ,IAAd,EAAoBhD,MAApB,CAAP;AACD,KAFD,MAEO;AACL,aAAO+C,WAAWC,IAAX,EAAiBhD,MAAjB,CAAP;AACD;AACF;;AAED,WAASgB,aAAT,CAAuBgC,IAAvB,EAA6BhD,MAA7B,EAAqC;AACnC,QAAIuD,MAAMI,OAAN,CAAc3D,MAAd,CAAJ,EAA2B;AACzB,aAAOoD,cAAcJ,IAAd,EAAoBhD,MAApB,CAAP;AACD,KAFD,MAEO;AACL,aAAOmD,aAAaH,IAAb,EAAmBhD,MAAnB,CAAP;AACD;AACF;;AAED,WAASyB,UAAT,CAAoBF,KAApB,EAA2B;AACzB,QAAIqC,UAAU/D,EAAEC,GAAF,CAAMyB,KAAN,EAAa,gBAAQ;AACjC,aAAO1B,EAAEC,GAAF,CAAM8B,KAAKhB,KAAX,EAAkB,QAAlB,CAAP;AACD,KAFa,CAAd;AAGA,WAAOf,EAAEgE,IAAF,CAAOhE,EAAEgD,OAAF,CAAUe,OAAV,CAAP,CAAP;AACD;;AAID,WAASjC,aAAT,CAAuBmC,QAAvB,EAAiC;AAC/B,WAAOC,cAAcL,IAAd,CAAmBI,QAAnB,CAAP;AACD;;AAED,WAAShC,YAAT,CAAsBF,IAAtB,EAA4BG,MAA5B,EAAoC;AAClC,QAAI+B,WAAWlC,KAAKC,IAApB;AACA,QAAImC,cAAcF,SAASG,KAAT,CAAeF,aAAf,CAAlB;AACAlE,MAAE6B,OAAF,CAAUsC,WAAV,EAAuB,iBAAS;AAC9B,UAAIE,cAAcrE,EAAEG,MAAF,CAAS+B,MAAT,EAAiB,aAAK;AACtC,YAAIoC,EAAEC,MAAN,EAAc;AACZ,iBAAOD,EAAEC,MAAF,KAAaxC,KAAKwC,MAAzB;AACD,SAFD,MAEO;AACL;AACA,iBAAO,IAAP;AACD;AACF,OAPiB,CAAlB;;AASA,UAAIC,YAAYxE,EAAEqD,IAAF,CAAOgB,WAAP,EAAoB,EAACI,OAAOA,KAAR,EAApB,CAAhB;AACA,UAAID,aAAaA,UAAUE,KAA3B,EAAkC;AAChC,YAAIC,cAAcH,UAAUE,KAA5B;AACA,YAAIE,cAAc,IAAIC,MAAJ,CAAWC,YAAYL,KAAZ,CAAX,CAAlB;AACAR,mBAAWA,SAASc,OAAT,CAAiBH,WAAjB,EAA8BD,WAA9B,CAAX;AACD;AACF,KAhBD;;AAkBA,WAAOV,QAAP;AACD;;AAED,WAASa,WAAT,CAAqBL,KAArB,EAA6B;AAC3BA,YAAQA,MAAMM,OAAN,CAAc,IAAd,EAAoB,MAApB,CAAR;AACA,WAAON,KAAP;AACD;;;AAnRMO,a;;AACAhF,O;;AACK0D,W;;;;;;;;;;;;;;;;;;;;;AA4KZsB,cACGC,MADH,CACU,kBADV,EAEGC,OAFH,CAEW,QAFX,EAEqBjH,aAFrB,EAoEIiG,a,GAAgB,mB","file":"zabbix.js","sourcesContent":["import angular from 'angular';\nimport _ from 'lodash';\nimport * as utils from './utils';\nimport './zabbixAPI.service.js';\nimport './zabbixCachingProxy.service.js';\n\n// Use factory() instead service() for multiple data sources support.\n// Each Zabbix data source instance should initialize its own API instance.\n\n/** @ngInject */\nfunction ZabbixFactory(zabbixAPIService, ZabbixCachingProxy) {\n\n class Zabbix {\n constructor(url, username, password, basicAuth, withCredentials, cacheTTL) {\n\n // Initialize Zabbix API\n var ZabbixAPI = zabbixAPIService;\n this.zabbixAPI = new ZabbixAPI(url, username, password, basicAuth, withCredentials);\n\n // Initialize caching proxy for requests\n let cacheOptions = {\n enabled: true,\n ttl: cacheTTL\n };\n this.cachingProxy = new ZabbixCachingProxy(this.zabbixAPI, cacheOptions);\n\n // Proxy methods\n this.getHistory = this.cachingProxy.getHistory.bind(this.cachingProxy);\n this.getMacros = this.cachingProxy.getMacros.bind(this.cachingProxy);\n\n this.getTrend = this.zabbixAPI.getTrend.bind(this.zabbixAPI);\n this.getEvents = this.zabbixAPI.getEvents.bind(this.zabbixAPI);\n this.getAlerts = this.zabbixAPI.getAlerts.bind(this.zabbixAPI);\n this.getAcknowledges = this.zabbixAPI.getAcknowledges.bind(this.zabbixAPI);\n this.getITService = this.zabbixAPI.getITService.bind(this.zabbixAPI);\n this.getSLA = this.zabbixAPI.getSLA.bind(this.zabbixAPI);\n this.getVersion = this.zabbixAPI.getVersion.bind(this.zabbixAPI);\n this.login = this.zabbixAPI.login.bind(this.zabbixAPI);\n }\n\n getItemsFromTarget(target, options) {\n let parts = ['group', 'host', 'application', 'item'];\n let filters = _.map(parts, p => target[p].filter);\n return this.getItems(...filters, options);\n }\n\n getAllGroups() {\n return this.cachingProxy.getGroups();\n }\n\n getGroups(groupFilter) {\n return this.getAllGroups()\n .then(groups => findByFilter(groups, groupFilter));\n }\n\n /**\n * Get list of host belonging to given groups.\n */\n getAllHosts(groupFilter) {\n return this.getGroups(groupFilter)\n .then(groups => {\n let groupids = _.map(groups, 'groupid');\n return this.cachingProxy.getHosts(groupids);\n });\n }\n\n getHosts(groupFilter, hostFilter) {\n return this.getAllHosts(groupFilter)\n .then(hosts => findByFilter(hosts, hostFilter));\n }\n\n /**\n * Get list of applications belonging to given groups and hosts.\n */\n getAllApps(groupFilter, hostFilter) {\n return this.getHosts(groupFilter, hostFilter)\n .then(hosts => {\n let hostids = _.map(hosts, 'hostid');\n return this.cachingProxy.getApps(hostids);\n });\n }\n\n getApps(groupFilter, hostFilter, appFilter) {\n return this.getHosts(groupFilter, hostFilter)\n .then(hosts => {\n let hostids = _.map(hosts, 'hostid');\n if (appFilter) {\n return this.cachingProxy.getApps(hostids)\n .then(apps => filterByQuery(apps, appFilter));\n } else {\n return {\n appFilterEmpty: true,\n hostids: hostids\n };\n }\n });\n }\n\n getAllItems(groupFilter, hostFilter, appFilter, options = {}) {\n return this.getApps(groupFilter, hostFilter, appFilter)\n .then(apps => {\n if (apps.appFilterEmpty) {\n return this.cachingProxy.getItems(apps.hostids, undefined, options.itemtype);\n } else {\n let appids = _.map(apps, 'applicationid');\n return this.cachingProxy.getItems(undefined, appids, options.itemtype);\n }\n })\n .then(items => {\n if (!options.showDisabledItems) {\n items = _.filter(items, {'status': '0'});\n }\n\n return items;\n })\n .then(this.expandUserMacro.bind(this));\n }\n\n expandUserMacro(items) {\n let hostids = getHostIds(items);\n return this.getMacros(hostids)\n .then(macros => {\n _.forEach(items, item => {\n if (containsMacro(item.name)) {\n item.name = replaceMacro(item, macros);\n }\n });\n return items;\n });\n }\n\n getItems(groupFilter, hostFilter, appFilter, itemFilter, options = {}) {\n return this.getAllItems(groupFilter, hostFilter, appFilter, options)\n .then(items => filterByQuery(items, itemFilter));\n }\n\n /**\n * Build query - convert target filters to array of Zabbix items\n */\n getTriggers(groupFilter, hostFilter, appFilter, showTriggers, hideHostsInMaintenance) {\n let promises = [\n this.getGroups(groupFilter),\n this.getHosts(groupFilter, hostFilter),\n this.getApps(groupFilter, hostFilter, appFilter)\n ];\n\n return Promise.all(promises)\n .then(results => {\n let filteredGroups = results[0];\n let filteredHosts = results[1];\n let filteredApps = results[2];\n let query = {};\n\n if (appFilter) {\n query.applicationids = _.flatten(_.map(filteredApps, 'applicationid'));\n }\n if (hostFilter) {\n query.hostids = _.map(filteredHosts, 'hostid');\n }\n if (groupFilter) {\n query.groupids = _.map(filteredGroups, 'groupid');\n }\n\n return query;\n }).then(query => {\n return this.zabbixAPI\n .getTriggers(query.groupids, query.hostids, query.applicationids, showTriggers, hideHostsInMaintenance);\n });\n }\n }\n\n return Zabbix;\n}\n\nangular\n .module('grafana.services')\n .factory('Zabbix', ZabbixFactory);\n\n///////////////////////////////////////////////////////////////////////////////\n\n/**\n * Find group, host, app or item by given name.\n * @param list list of groups, apps or other\n * @param name visible name\n * @return array with finded element or empty array\n */\nfunction findByName(list, name) {\n var finded = _.find(list, {'name': name});\n if (finded) {\n return [finded];\n } else {\n return [];\n }\n}\n\n/**\n * Different hosts can contains applications and items with same name.\n * For this reason use _.filter, which return all elements instead _.find,\n * which return only first finded.\n * @param {[type]} list list of elements\n * @param {[type]} name app name\n * @return {[type]} array with finded element or empty array\n */\nfunction filterByName(list, name) {\n var finded = _.filter(list, {'name': name});\n if (finded) {\n return finded;\n } else {\n return [];\n }\n}\n\nfunction filterByRegex(list, regex) {\n var filterPattern = utils.buildRegex(regex);\n return _.filter(list, function (zbx_obj) {\n return filterPattern.test(zbx_obj.name);\n });\n}\n\nfunction findByFilter(list, filter) {\n if (utils.isRegex(filter)) {\n return filterByRegex(list, filter);\n } else {\n return findByName(list, filter);\n }\n}\n\nfunction filterByQuery(list, filter) {\n if (utils.isRegex(filter)) {\n return filterByRegex(list, filter);\n } else {\n return filterByName(list, filter);\n }\n}\n\nfunction getHostIds(items) {\n let hostIds = _.map(items, item => {\n return _.map(item.hosts, 'hostid');\n });\n return _.uniq(_.flatten(hostIds));\n}\n\nlet MACRO_PATTERN = /{\\$[A-Z0-9_\\.]+}/g;\n\nfunction containsMacro(itemName) {\n return MACRO_PATTERN.test(itemName);\n}\n\nfunction replaceMacro(item, macros) {\n let itemName = item.name;\n let item_macros = itemName.match(MACRO_PATTERN);\n _.forEach(item_macros, macro => {\n let host_macros = _.filter(macros, m => {\n if (m.hostid) {\n return m.hostid === item.hostid;\n } else {\n // Add global macros\n return true;\n }\n });\n\n let macro_def = _.find(host_macros, {macro: macro});\n if (macro_def && macro_def.value) {\n let macro_value = macro_def.value;\n let macro_regex = new RegExp(escapeMacro(macro));\n itemName = itemName.replace(macro_regex, macro_value);\n }\n });\n\n return itemName;\n}\n\nfunction escapeMacro(macro) {\n macro = macro.replace(/\\$/, '\\\\\\$');\n return macro;\n}\n"]} \ No newline at end of file +{"version":3,"sources":["../../src/datasource-zabbix/zabbix.js"],"names":["ZabbixFactory","zabbixAPIService","ZabbixCachingProxy","Zabbix","url","username","password","basicAuth","withCredentials","cacheTTL","ZabbixAPI","zabbixAPI","cacheOptions","enabled","ttl","cachingProxy","getHistory","bind","getMacros","getTrend","getEvents","getAlerts","getAcknowledges","getITService","getSLA","getVersion","login","target","options","parts","filters","_","map","p","filter","getItems","getGroups","groupFilter","getAllGroups","then","findByFilter","groups","groupids","getHosts","hostFilter","getAllHosts","hosts","hostids","getApps","appFilter","filterByQuery","apps","appFilterEmpty","undefined","itemtype","appids","showDisabledItems","items","expandUserMacro","getHostIds","forEach","utils","containsMacro","item","name","replaceMacro","macros","itemFilter","getAllItems","showTriggers","hideHostsInMaintenance","promises","Promise","all","filteredGroups","results","filteredHosts","filteredApps","query","applicationids","flatten","getTriggers","findByName","list","finded","find","filterByName","filterByRegex","regex","filterPattern","buildRegex","zbx_obj","test","isRegex","hostIds","uniq","angular","module","factory"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;AAMA;AACA;;AAEA;AACA,WAASA,aAAT,CAAuBC,gBAAvB,EAAyCC,kBAAzC,EAA6D;AAAA,QAErDC,MAFqD;AAGzD,sBAAYC,GAAZ,EAAiBC,QAAjB,EAA2BC,QAA3B,EAAqCC,SAArC,EAAgDC,eAAhD,EAAiEC,QAAjE,EAA2E;AAAA;;AAEzE;AACA,YAAIC,YAAYT,gBAAhB;AACA,aAAKU,SAAL,GAAiB,IAAID,SAAJ,CAAcN,GAAd,EAAmBC,QAAnB,EAA6BC,QAA7B,EAAuCC,SAAvC,EAAkDC,eAAlD,CAAjB;;AAEA;AACA,YAAII,eAAe;AACjBC,mBAAS,IADQ;AAEjBC,eAAKL;AAFY,SAAnB;AAIA,aAAKM,YAAL,GAAoB,IAAIb,kBAAJ,CAAuB,KAAKS,SAA5B,EAAuCC,YAAvC,CAApB;;AAEA;AACA,aAAKI,UAAL,GAAkB,KAAKD,YAAL,CAAkBC,UAAlB,CAA6BC,IAA7B,CAAkC,KAAKF,YAAvC,CAAlB;AACA,aAAKG,SAAL,GAAiB,KAAKH,YAAL,CAAkBG,SAAlB,CAA4BD,IAA5B,CAAiC,KAAKF,YAAtC,CAAjB;;AAEA,aAAKI,QAAL,GAAgB,KAAKR,SAAL,CAAeQ,QAAf,CAAwBF,IAAxB,CAA6B,KAAKN,SAAlC,CAAhB;AACA,aAAKS,SAAL,GAAiB,KAAKT,SAAL,CAAeS,SAAf,CAAyBH,IAAzB,CAA8B,KAAKN,SAAnC,CAAjB;AACA,aAAKU,SAAL,GAAiB,KAAKV,SAAL,CAAeU,SAAf,CAAyBJ,IAAzB,CAA8B,KAAKN,SAAnC,CAAjB;AACA,aAAKW,eAAL,GAAuB,KAAKX,SAAL,CAAeW,eAAf,CAA+BL,IAA/B,CAAoC,KAAKN,SAAzC,CAAvB;AACA,aAAKY,YAAL,GAAoB,KAAKZ,SAAL,CAAeY,YAAf,CAA4BN,IAA5B,CAAiC,KAAKN,SAAtC,CAApB;AACA,aAAKa,MAAL,GAAc,KAAKb,SAAL,CAAea,MAAf,CAAsBP,IAAtB,CAA2B,KAAKN,SAAhC,CAAd;AACA,aAAKc,UAAL,GAAkB,KAAKd,SAAL,CAAec,UAAf,CAA0BR,IAA1B,CAA+B,KAAKN,SAApC,CAAlB;AACA,aAAKe,KAAL,GAAa,KAAKf,SAAL,CAAee,KAAf,CAAqBT,IAArB,CAA0B,KAAKN,SAA/B,CAAb;AACD;;AA5BwD;AAAA;AAAA,2CA8BtCgB,MA9BsC,EA8B9BC,OA9B8B,EA8BrB;AAClC,cAAIC,QAAQ,CAAC,OAAD,EAAU,MAAV,EAAkB,aAAlB,EAAiC,MAAjC,CAAZ;AACA,cAAIC,UAAUC,EAAEC,GAAF,CAAMH,KAAN,EAAa;AAAA,mBAAKF,OAAOM,CAAP,EAAUC,MAAf;AAAA,WAAb,CAAd;AACA,iBAAO,KAAKC,QAAL,gCAAiBL,OAAjB,UAA0BF,OAA1B,GAAP;AACD;AAlCwD;AAAA;AAAA,uCAoC1C;AACb,iBAAO,KAAKb,YAAL,CAAkBqB,SAAlB,EAAP;AACD;AAtCwD;AAAA;AAAA,kCAwC/CC,WAxC+C,EAwClC;AACrB,iBAAO,KAAKC,YAAL,GACNC,IADM,CACD;AAAA,mBAAUC,aAAaC,MAAb,EAAqBJ,WAArB,CAAV;AAAA,WADC,CAAP;AAED;AA3CwD;AAAA;AAAA,oCAgD7CA,WAhD6C,EAgDhC;AAAA;;AACvB,iBAAO,KAAKD,SAAL,CAAeC,WAAf,EACNE,IADM,CACD,kBAAU;AACd,gBAAIG,WAAWX,EAAEC,GAAF,CAAMS,MAAN,EAAc,SAAd,CAAf;AACA,mBAAO,MAAK1B,YAAL,CAAkB4B,QAAlB,CAA2BD,QAA3B,CAAP;AACD,WAJM,CAAP;AAKD;AAtDwD;AAAA;AAAA,iCAwDhDL,WAxDgD,EAwDnCO,UAxDmC,EAwDvB;AAChC,iBAAO,KAAKC,WAAL,CAAiBR,WAAjB,EACNE,IADM,CACD;AAAA,mBAASC,aAAaM,KAAb,EAAoBF,UAApB,CAAT;AAAA,WADC,CAAP;AAED;AA3DwD;AAAA;AAAA,mCAgE9CP,WAhE8C,EAgEjCO,UAhEiC,EAgErB;AAAA;;AAClC,iBAAO,KAAKD,QAAL,CAAcN,WAAd,EAA2BO,UAA3B,EACNL,IADM,CACD,iBAAS;AACb,gBAAIQ,UAAUhB,EAAEC,GAAF,CAAMc,KAAN,EAAa,QAAb,CAAd;AACA,mBAAO,OAAK/B,YAAL,CAAkBiC,OAAlB,CAA0BD,OAA1B,CAAP;AACD,WAJM,CAAP;AAKD;AAtEwD;AAAA;AAAA,gCAwEjDV,WAxEiD,EAwEpCO,UAxEoC,EAwExBK,SAxEwB,EAwEb;AAAA;;AAC1C,iBAAO,KAAKN,QAAL,CAAcN,WAAd,EAA2BO,UAA3B,EACNL,IADM,CACD,iBAAS;AACb,gBAAIQ,UAAUhB,EAAEC,GAAF,CAAMc,KAAN,EAAa,QAAb,CAAd;AACA,gBAAIG,SAAJ,EAAe;AACb,qBAAO,OAAKlC,YAAL,CAAkBiC,OAAlB,CAA0BD,OAA1B,EACNR,IADM,CACD;AAAA,uBAAQW,cAAcC,IAAd,EAAoBF,SAApB,CAAR;AAAA,eADC,CAAP;AAED,aAHD,MAGO;AACL,qBAAO;AACLG,gCAAgB,IADX;AAELL,yBAASA;AAFJ,eAAP;AAID;AACF,WAZM,CAAP;AAaD;AAtFwD;AAAA;AAAA,oCAwF7CV,WAxF6C,EAwFhCO,UAxFgC,EAwFpBK,SAxFoB,EAwFK;AAAA;;AAAA,cAAdrB,OAAc,uEAAJ,EAAI;;AAC5D,iBAAO,KAAKoB,OAAL,CAAaX,WAAb,EAA0BO,UAA1B,EAAsCK,SAAtC,EACNV,IADM,CACD,gBAAQ;AACZ,gBAAIY,KAAKC,cAAT,EAAyB;AACvB,qBAAO,OAAKrC,YAAL,CAAkBoB,QAAlB,CAA2BgB,KAAKJ,OAAhC,EAAyCM,SAAzC,EAAoDzB,QAAQ0B,QAA5D,CAAP;AACD,aAFD,MAEO;AACL,kBAAIC,SAASxB,EAAEC,GAAF,CAAMmB,IAAN,EAAY,eAAZ,CAAb;AACA,qBAAO,OAAKpC,YAAL,CAAkBoB,QAAlB,CAA2BkB,SAA3B,EAAsCE,MAAtC,EAA8C3B,QAAQ0B,QAAtD,CAAP;AACD;AACF,WARM,EASNf,IATM,CASD,iBAAS;AACb,gBAAI,CAACX,QAAQ4B,iBAAb,EAAgC;AAC9BC,sBAAQ1B,EAAEG,MAAF,CAASuB,KAAT,EAAgB,EAAC,UAAU,GAAX,EAAhB,CAAR;AACD;;AAED,mBAAOA,KAAP;AACD,WAfM,EAgBNlB,IAhBM,CAgBD,KAAKmB,eAAL,CAAqBzC,IAArB,CAA0B,IAA1B,CAhBC,CAAP;AAiBD;AA1GwD;AAAA;AAAA,wCA4GzCwC,KA5GyC,EA4GlC;AACrB,cAAIV,UAAUY,WAAWF,KAAX,CAAd;AACA,iBAAO,KAAKvC,SAAL,CAAe6B,OAAf,EACNR,IADM,CACD,kBAAU;AACdR,cAAE6B,OAAF,CAAUH,KAAV,EAAiB,gBAAQ;AACvB,kBAAII,MAAMC,aAAN,CAAoBC,KAAKC,IAAzB,CAAJ,EAAoC;AAClCD,qBAAKC,IAAL,GAAYH,MAAMI,YAAN,CAAmBF,IAAnB,EAAyBG,MAAzB,CAAZ;AACD;AACF,aAJD;AAKA,mBAAOT,KAAP;AACD,WARM,CAAP;AASD;AAvHwD;AAAA;AAAA,iCAyHhDpB,WAzHgD,EAyHnCO,UAzHmC,EAyHvBK,SAzHuB,EAyHZkB,UAzHY,EAyHc;AAAA,cAAdvC,OAAc,uEAAJ,EAAI;;AACrE,iBAAO,KAAKwC,WAAL,CAAiB/B,WAAjB,EAA8BO,UAA9B,EAA0CK,SAA1C,EAAqDrB,OAArD,EACNW,IADM,CACD;AAAA,mBAASW,cAAcO,KAAd,EAAqBU,UAArB,CAAT;AAAA,WADC,CAAP;AAED;AA5HwD;AAAA;AAAA,oCAiI7C9B,WAjI6C,EAiIhCO,UAjIgC,EAiIpBK,SAjIoB,EAiIToB,YAjIS,EAiIKC,sBAjIL,EAiI6B;AAAA;;AACpF,cAAIC,WAAW,CACb,KAAKnC,SAAL,CAAeC,WAAf,CADa,EAEb,KAAKM,QAAL,CAAcN,WAAd,EAA2BO,UAA3B,CAFa,EAGb,KAAKI,OAAL,CAAaX,WAAb,EAA0BO,UAA1B,EAAsCK,SAAtC,CAHa,CAAf;;AAMA,iBAAOuB,QAAQC,GAAR,CAAYF,QAAZ,EACNhC,IADM,CACD,mBAAW;AACf,gBAAImC,iBAAiBC,QAAQ,CAAR,CAArB;AACA,gBAAIC,gBAAgBD,QAAQ,CAAR,CAApB;AACA,gBAAIE,eAAeF,QAAQ,CAAR,CAAnB;AACA,gBAAIG,QAAQ,EAAZ;;AAEA,gBAAI7B,SAAJ,EAAe;AACb6B,oBAAMC,cAAN,GAAuBhD,EAAEiD,OAAF,CAAUjD,EAAEC,GAAF,CAAM6C,YAAN,EAAoB,eAApB,CAAV,CAAvB;AACD;AACD,gBAAIjC,UAAJ,EAAgB;AACdkC,oBAAM/B,OAAN,GAAgBhB,EAAEC,GAAF,CAAM4C,aAAN,EAAqB,QAArB,CAAhB;AACD;AACD,gBAAIvC,WAAJ,EAAiB;AACfyC,oBAAMpC,QAAN,GAAiBX,EAAEC,GAAF,CAAM0C,cAAN,EAAsB,SAAtB,CAAjB;AACD;;AAED,mBAAOI,KAAP;AACD,WAlBM,EAkBJvC,IAlBI,CAkBC,iBAAS;AACf,mBAAO,OAAK5B,SAAL,CACNsE,WADM,CACMH,MAAMpC,QADZ,EACsBoC,MAAM/B,OAD5B,EACqC+B,MAAMC,cAD3C,EAC2DV,YAD3D,EACyEC,sBADzE,CAAP;AAED,WArBM,CAAP;AAsBD;AA9JwD;;AAAA;AAAA;;AAiK3D,WAAOnE,MAAP;AACD;;AAMD;;AAEA;;;;;;AAMA,WAAS+E,UAAT,CAAoBC,IAApB,EAA0BnB,IAA1B,EAAgC;AAC9B,QAAIoB,SAASrD,EAAEsD,IAAF,CAAOF,IAAP,EAAa,EAAC,QAAQnB,IAAT,EAAb,CAAb;AACA,QAAIoB,MAAJ,EAAY;AACV,aAAO,CAACA,MAAD,CAAP;AACD,KAFD,MAEO;AACL,aAAO,EAAP;AACD;AACF;;AAED;;;;;;;;AAQA,WAASE,YAAT,CAAsBH,IAAtB,EAA4BnB,IAA5B,EAAkC;AAChC,QAAIoB,SAASrD,EAAEG,MAAF,CAASiD,IAAT,EAAe,EAAC,QAAQnB,IAAT,EAAf,CAAb;AACA,QAAIoB,MAAJ,EAAY;AACV,aAAOA,MAAP;AACD,KAFD,MAEO;AACL,aAAO,EAAP;AACD;AACF;;AAED,WAASG,aAAT,CAAuBJ,IAAvB,EAA6BK,KAA7B,EAAoC;AAClC,QAAIC,gBAAgB5B,MAAM6B,UAAN,CAAiBF,KAAjB,CAApB;AACA,WAAOzD,EAAEG,MAAF,CAASiD,IAAT,EAAe,UAAUQ,OAAV,EAAmB;AACvC,aAAOF,cAAcG,IAAd,CAAmBD,QAAQ3B,IAA3B,CAAP;AACD,KAFM,CAAP;AAGD;;AAED,WAASxB,YAAT,CAAsB2C,IAAtB,EAA4BjD,MAA5B,EAAoC;AAClC,QAAI2B,MAAMgC,OAAN,CAAc3D,MAAd,CAAJ,EAA2B;AACzB,aAAOqD,cAAcJ,IAAd,EAAoBjD,MAApB,CAAP;AACD,KAFD,MAEO;AACL,aAAOgD,WAAWC,IAAX,EAAiBjD,MAAjB,CAAP;AACD;AACF;;AAED,WAASgB,aAAT,CAAuBiC,IAAvB,EAA6BjD,MAA7B,EAAqC;AACnC,QAAI2B,MAAMgC,OAAN,CAAc3D,MAAd,CAAJ,EAA2B;AACzB,aAAOqD,cAAcJ,IAAd,EAAoBjD,MAApB,CAAP;AACD,KAFD,MAEO;AACL,aAAOoD,aAAaH,IAAb,EAAmBjD,MAAnB,CAAP;AACD;AACF;;AAED,WAASyB,UAAT,CAAoBF,KAApB,EAA2B;AACzB,QAAIqC,UAAU/D,EAAEC,GAAF,CAAMyB,KAAN,EAAa,gBAAQ;AACjC,aAAO1B,EAAEC,GAAF,CAAM+B,KAAKjB,KAAX,EAAkB,QAAlB,CAAP;AACD,KAFa,CAAd;AAGA,WAAOf,EAAEgE,IAAF,CAAOhE,EAAEiD,OAAF,CAAUc,OAAV,CAAP,CAAP;AACD;;;AAhPME,a;;AACAjE,O;;AACK8B,W;;;;;;;;;;;;;;;;;;;;;AA4KZmC,cACGC,MADH,CACU,kBADV,EAEGC,OAFH,CAEW,QAFX,EAEqBlG,aAFrB","file":"zabbix.js","sourcesContent":["import angular from 'angular';\nimport _ from 'lodash';\nimport * as utils from './utils';\nimport './zabbixAPI.service.js';\nimport './zabbixCachingProxy.service.js';\n\n// Use factory() instead service() for multiple data sources support.\n// Each Zabbix data source instance should initialize its own API instance.\n\n/** @ngInject */\nfunction ZabbixFactory(zabbixAPIService, ZabbixCachingProxy) {\n\n class Zabbix {\n constructor(url, username, password, basicAuth, withCredentials, cacheTTL) {\n\n // Initialize Zabbix API\n var ZabbixAPI = zabbixAPIService;\n this.zabbixAPI = new ZabbixAPI(url, username, password, basicAuth, withCredentials);\n\n // Initialize caching proxy for requests\n let cacheOptions = {\n enabled: true,\n ttl: cacheTTL\n };\n this.cachingProxy = new ZabbixCachingProxy(this.zabbixAPI, cacheOptions);\n\n // Proxy methods\n this.getHistory = this.cachingProxy.getHistory.bind(this.cachingProxy);\n this.getMacros = this.cachingProxy.getMacros.bind(this.cachingProxy);\n\n this.getTrend = this.zabbixAPI.getTrend.bind(this.zabbixAPI);\n this.getEvents = this.zabbixAPI.getEvents.bind(this.zabbixAPI);\n this.getAlerts = this.zabbixAPI.getAlerts.bind(this.zabbixAPI);\n this.getAcknowledges = this.zabbixAPI.getAcknowledges.bind(this.zabbixAPI);\n this.getITService = this.zabbixAPI.getITService.bind(this.zabbixAPI);\n this.getSLA = this.zabbixAPI.getSLA.bind(this.zabbixAPI);\n this.getVersion = this.zabbixAPI.getVersion.bind(this.zabbixAPI);\n this.login = this.zabbixAPI.login.bind(this.zabbixAPI);\n }\n\n getItemsFromTarget(target, options) {\n let parts = ['group', 'host', 'application', 'item'];\n let filters = _.map(parts, p => target[p].filter);\n return this.getItems(...filters, options);\n }\n\n getAllGroups() {\n return this.cachingProxy.getGroups();\n }\n\n getGroups(groupFilter) {\n return this.getAllGroups()\n .then(groups => findByFilter(groups, groupFilter));\n }\n\n /**\n * Get list of host belonging to given groups.\n */\n getAllHosts(groupFilter) {\n return this.getGroups(groupFilter)\n .then(groups => {\n let groupids = _.map(groups, 'groupid');\n return this.cachingProxy.getHosts(groupids);\n });\n }\n\n getHosts(groupFilter, hostFilter) {\n return this.getAllHosts(groupFilter)\n .then(hosts => findByFilter(hosts, hostFilter));\n }\n\n /**\n * Get list of applications belonging to given groups and hosts.\n */\n getAllApps(groupFilter, hostFilter) {\n return this.getHosts(groupFilter, hostFilter)\n .then(hosts => {\n let hostids = _.map(hosts, 'hostid');\n return this.cachingProxy.getApps(hostids);\n });\n }\n\n getApps(groupFilter, hostFilter, appFilter) {\n return this.getHosts(groupFilter, hostFilter)\n .then(hosts => {\n let hostids = _.map(hosts, 'hostid');\n if (appFilter) {\n return this.cachingProxy.getApps(hostids)\n .then(apps => filterByQuery(apps, appFilter));\n } else {\n return {\n appFilterEmpty: true,\n hostids: hostids\n };\n }\n });\n }\n\n getAllItems(groupFilter, hostFilter, appFilter, options = {}) {\n return this.getApps(groupFilter, hostFilter, appFilter)\n .then(apps => {\n if (apps.appFilterEmpty) {\n return this.cachingProxy.getItems(apps.hostids, undefined, options.itemtype);\n } else {\n let appids = _.map(apps, 'applicationid');\n return this.cachingProxy.getItems(undefined, appids, options.itemtype);\n }\n })\n .then(items => {\n if (!options.showDisabledItems) {\n items = _.filter(items, {'status': '0'});\n }\n\n return items;\n })\n .then(this.expandUserMacro.bind(this));\n }\n\n expandUserMacro(items) {\n let hostids = getHostIds(items);\n return this.getMacros(hostids)\n .then(macros => {\n _.forEach(items, item => {\n if (utils.containsMacro(item.name)) {\n item.name = utils.replaceMacro(item, macros);\n }\n });\n return items;\n });\n }\n\n getItems(groupFilter, hostFilter, appFilter, itemFilter, options = {}) {\n return this.getAllItems(groupFilter, hostFilter, appFilter, options)\n .then(items => filterByQuery(items, itemFilter));\n }\n\n /**\n * Build query - convert target filters to array of Zabbix items\n */\n getTriggers(groupFilter, hostFilter, appFilter, showTriggers, hideHostsInMaintenance) {\n let promises = [\n this.getGroups(groupFilter),\n this.getHosts(groupFilter, hostFilter),\n this.getApps(groupFilter, hostFilter, appFilter)\n ];\n\n return Promise.all(promises)\n .then(results => {\n let filteredGroups = results[0];\n let filteredHosts = results[1];\n let filteredApps = results[2];\n let query = {};\n\n if (appFilter) {\n query.applicationids = _.flatten(_.map(filteredApps, 'applicationid'));\n }\n if (hostFilter) {\n query.hostids = _.map(filteredHosts, 'hostid');\n }\n if (groupFilter) {\n query.groupids = _.map(filteredGroups, 'groupid');\n }\n\n return query;\n }).then(query => {\n return this.zabbixAPI\n .getTriggers(query.groupids, query.hostids, query.applicationids, showTriggers, hideHostsInMaintenance);\n });\n }\n }\n\n return Zabbix;\n}\n\nangular\n .module('grafana.services')\n .factory('Zabbix', ZabbixFactory);\n\n///////////////////////////////////////////////////////////////////////////////\n\n/**\n * Find group, host, app or item by given name.\n * @param list list of groups, apps or other\n * @param name visible name\n * @return array with finded element or empty array\n */\nfunction findByName(list, name) {\n var finded = _.find(list, {'name': name});\n if (finded) {\n return [finded];\n } else {\n return [];\n }\n}\n\n/**\n * Different hosts can contains applications and items with same name.\n * For this reason use _.filter, which return all elements instead _.find,\n * which return only first finded.\n * @param {[type]} list list of elements\n * @param {[type]} name app name\n * @return {[type]} array with finded element or empty array\n */\nfunction filterByName(list, name) {\n var finded = _.filter(list, {'name': name});\n if (finded) {\n return finded;\n } else {\n return [];\n }\n}\n\nfunction filterByRegex(list, regex) {\n var filterPattern = utils.buildRegex(regex);\n return _.filter(list, function (zbx_obj) {\n return filterPattern.test(zbx_obj.name);\n });\n}\n\nfunction findByFilter(list, filter) {\n if (utils.isRegex(filter)) {\n return filterByRegex(list, filter);\n } else {\n return findByName(list, filter);\n }\n}\n\nfunction filterByQuery(list, filter) {\n if (utils.isRegex(filter)) {\n return filterByRegex(list, filter);\n } else {\n return filterByName(list, filter);\n }\n}\n\nfunction getHostIds(items) {\n let hostIds = _.map(items, item => {\n return _.map(item.hosts, 'hostid');\n });\n return _.uniq(_.flatten(hostIds));\n}\n"]} \ No newline at end of file diff --git a/dist/test/datasource-zabbix/utils.js b/dist/test/datasource-zabbix/utils.js index 74340a8..9bd47a1 100644 --- a/dist/test/datasource-zabbix/utils.js +++ b/dist/test/datasource-zabbix/utils.js @@ -5,6 +5,8 @@ Object.defineProperty(exports, "__esModule", { }); exports.regexPattern = undefined; exports.expandItemName = expandItemName; +exports.containsMacro = containsMacro; +exports.replaceMacro = replaceMacro; exports.isRegex = isRegex; exports.isTemplateVariable = isTemplateVariable; exports.buildRegex = buildRegex; @@ -76,6 +78,45 @@ function splitKeyParams(paramStr) { return params; } +/////////// +// MACRO // +/////////// + +var MACRO_PATTERN = /{\$[A-Z0-9_\.]+}/g; + +function containsMacro(itemName) { + return MACRO_PATTERN.test(itemName); +} + +function replaceMacro(item, macros) { + var itemName = item.name; + var item_macros = itemName.match(MACRO_PATTERN); + _lodash2.default.forEach(item_macros, function (macro) { + var host_macros = _lodash2.default.filter(macros, function (m) { + if (m.hostid) { + return m.hostid === item.hostid; + } else { + // Add global macros + return true; + } + }); + + var macro_def = _lodash2.default.find(host_macros, { macro: macro }); + if (macro_def && macro_def.value) { + var macro_value = macro_def.value; + var macro_regex = new RegExp(escapeMacro(macro)); + itemName = itemName.replace(macro_regex, macro_value); + } + }); + + return itemName; +} + +function escapeMacro(macro) { + macro = macro.replace(/\$/, '\\\$'); + return macro; +} + // Pattern for testing regex var regexPattern = exports.regexPattern = /^\/(.*)\/([gmi]*)$/m; diff --git a/dist/test/datasource-zabbix/zabbix.js b/dist/test/datasource-zabbix/zabbix.js index 94d5519..999c90b 100644 --- a/dist/test/datasource-zabbix/zabbix.js +++ b/dist/test/datasource-zabbix/zabbix.js @@ -165,8 +165,8 @@ function ZabbixFactory(zabbixAPIService, ZabbixCachingProxy) { var hostids = getHostIds(items); return this.getMacros(hostids).then(function (macros) { _lodash2.default.forEach(items, function (item) { - if (containsMacro(item.name)) { - item.name = replaceMacro(item, macros); + if (utils.containsMacro(item.name)) { + item.name = utils.replaceMacro(item, macros); } }); return items; @@ -287,38 +287,3 @@ function getHostIds(items) { }); return _lodash2.default.uniq(_lodash2.default.flatten(hostIds)); } - -var MACRO_PATTERN = /{\$[A-Z0-9_\.]+}/g; - -function containsMacro(itemName) { - return MACRO_PATTERN.test(itemName); -} - -function replaceMacro(item, macros) { - var itemName = item.name; - var item_macros = itemName.match(MACRO_PATTERN); - _lodash2.default.forEach(item_macros, function (macro) { - var host_macros = _lodash2.default.filter(macros, function (m) { - if (m.hostid) { - return m.hostid === item.hostid; - } else { - // Add global macros - return true; - } - }); - - var macro_def = _lodash2.default.find(host_macros, { macro: macro }); - if (macro_def && macro_def.value) { - var macro_value = macro_def.value; - var macro_regex = new RegExp(escapeMacro(macro)); - itemName = itemName.replace(macro_regex, macro_value); - } - }); - - return itemName; -} - -function escapeMacro(macro) { - macro = macro.replace(/\$/, '\\\$'); - return macro; -} diff --git a/src/datasource-zabbix/utils.js b/src/datasource-zabbix/utils.js index e9615d9..17953f4 100644 --- a/src/datasource-zabbix/utils.js +++ b/src/datasource-zabbix/utils.js @@ -52,8 +52,47 @@ function splitKeyParams(paramStr) { return params; } +/////////// +// MACRO // +/////////// + +const MACRO_PATTERN = /{\$[A-Z0-9_\.]+}/g; + +export function containsMacro(itemName) { + return MACRO_PATTERN.test(itemName); +} + +export function replaceMacro(item, macros) { + let itemName = item.name; + let item_macros = itemName.match(MACRO_PATTERN); + _.forEach(item_macros, macro => { + let host_macros = _.filter(macros, m => { + if (m.hostid) { + return m.hostid === item.hostid; + } else { + // Add global macros + return true; + } + }); + + let macro_def = _.find(host_macros, { macro: macro }); + if (macro_def && macro_def.value) { + let macro_value = macro_def.value; + let macro_regex = new RegExp(escapeMacro(macro)); + itemName = itemName.replace(macro_regex, macro_value); + } + }); + + return itemName; +} + +function escapeMacro(macro) { + macro = macro.replace(/\$/, '\\\$'); + return macro; +} + // Pattern for testing regex -export var regexPattern = /^\/(.*)\/([gmi]*)$/m; +export const regexPattern = /^\/(.*)\/([gmi]*)$/m; export function isRegex(str) { return regexPattern.test(str); diff --git a/src/datasource-zabbix/zabbix.js b/src/datasource-zabbix/zabbix.js index 6d89d8b..a50fe15 100644 --- a/src/datasource-zabbix/zabbix.js +++ b/src/datasource-zabbix/zabbix.js @@ -121,8 +121,8 @@ function ZabbixFactory(zabbixAPIService, ZabbixCachingProxy) { return this.getMacros(hostids) .then(macros => { _.forEach(items, item => { - if (containsMacro(item.name)) { - item.name = replaceMacro(item, macros); + if (utils.containsMacro(item.name)) { + item.name = utils.replaceMacro(item, macros); } }); return items; @@ -239,38 +239,3 @@ function getHostIds(items) { }); return _.uniq(_.flatten(hostIds)); } - -let MACRO_PATTERN = /{\$[A-Z0-9_\.]+}/g; - -function containsMacro(itemName) { - return MACRO_PATTERN.test(itemName); -} - -function replaceMacro(item, macros) { - let itemName = item.name; - let item_macros = itemName.match(MACRO_PATTERN); - _.forEach(item_macros, macro => { - let host_macros = _.filter(macros, m => { - if (m.hostid) { - return m.hostid === item.hostid; - } else { - // Add global macros - return true; - } - }); - - let macro_def = _.find(host_macros, {macro: macro}); - if (macro_def && macro_def.value) { - let macro_value = macro_def.value; - let macro_regex = new RegExp(escapeMacro(macro)); - itemName = itemName.replace(macro_regex, macro_value); - } - }); - - return itemName; -} - -function escapeMacro(macro) { - macro = macro.replace(/\$/, '\\\$'); - return macro; -}