'use strict'; Object.defineProperty(exports, "__esModule", { value: true }); exports.regexPattern = undefined; exports.expandItemName = expandItemName; exports.containsMacro = containsMacro; exports.replaceMacro = replaceMacro; exports.splitTemplateQuery = splitTemplateQuery; exports.isRegex = isRegex; exports.isTemplateVariable = isTemplateVariable; exports.buildRegex = buildRegex; exports.escapeRegex = escapeRegex; exports.parseInterval = parseInterval; exports.parseTimeShiftInterval = parseTimeShiftInterval; exports.formatAcknowledges = formatAcknowledges; exports.convertToZabbixAPIUrl = convertToZabbixAPIUrl; exports.callOnce = callOnce; var _lodash = require('lodash'); var _lodash2 = _interopRequireDefault(_lodash); var _moment = require('moment'); var _moment2 = _interopRequireDefault(_moment); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } /** * Expand Zabbix item name * * @param {string} name item name, ie "CPU $2 time" * @param {string} key item key, ie system.cpu.util[,system,avg1] * @return {string} expanded name, ie "CPU system time" */ function expandItemName(name, key) { // extract params from key: // "system.cpu.util[,system,avg1]" --> ["", "system", "avg1"] var key_params_str = key.substring(key.indexOf('[') + 1, key.lastIndexOf(']')); var key_params = splitKeyParams(key_params_str); // replace item parameters for (var i = key_params.length; i >= 1; i--) { name = name.replace('$' + i, key_params[i - 1]); } return name; } function splitKeyParams(paramStr) { var params = []; var quoted = false; var in_array = false; var split_symbol = ','; var param = ''; _lodash2.default.forEach(paramStr, function (symbol) { if (symbol === '"' && in_array) { param += symbol; } else if (symbol === '"' && quoted) { quoted = false; } else if (symbol === '"' && !quoted) { quoted = true; } else if (symbol === '[' && !quoted) { in_array = true; } else if (symbol === ']' && !quoted) { in_array = false; } else if (symbol === split_symbol && !quoted && !in_array) { params.push(param); param = ''; } else { param += symbol; } }); params.push(param); return params; } 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; } /** * Split template query to parts of zabbix entities * group.host.app.item -> [group, host, app, item] * {group}{host.com} -> [group, host.com] */ function splitTemplateQuery(query) { var splitPattern = /\{[^\{\}]*\}|\{\/.*\/\}/g; var split = void 0; if (isContainsBraces(query)) { var result = query.match(splitPattern); split = _lodash2.default.map(result, function (part) { return _lodash2.default.trim(part, '{}'); }); } else { split = query.split('.'); } return split; } function isContainsBraces(query) { var bracesPattern = /^\{.+\}$/; return bracesPattern.test(query); } // Pattern for testing regex var regexPattern = exports.regexPattern = /^\/(.*)\/([gmi]*)$/m; function isRegex(str) { return regexPattern.test(str); } function isTemplateVariable(str, templateVariables) { var variablePattern = /^\$\w+/; if (variablePattern.test(str)) { var variables = _lodash2.default.map(templateVariables, function (variable) { return '$' + variable.name; }); return _lodash2.default.includes(variables, str); } else { return false; } } function buildRegex(str) { var matches = str.match(regexPattern); var pattern = matches[1]; var flags = matches[2] !== "" ? matches[2] : undefined; return new RegExp(pattern, flags); } // Need for template variables replace // From Grafana's templateSrv.js function escapeRegex(value) { return value.replace(/[\\^$*+?.()|[\]{}\/]/g, '\\$&'); } function parseInterval(interval) { var intervalPattern = /(^[\d]+)(y|M|w|d|h|m|s)/g; var momentInterval = intervalPattern.exec(interval); return _moment2.default.duration(Number(momentInterval[1]), momentInterval[2]).valueOf(); } function parseTimeShiftInterval(interval) { var intervalPattern = /^([\+\-]*)([\d]+)(y|M|w|d|h|m|s)/g; var momentInterval = intervalPattern.exec(interval); var duration = 0; if (momentInterval[1] === '+') { duration = 0 - _moment2.default.duration(Number(momentInterval[2]), momentInterval[3]).valueOf(); } else { duration = _moment2.default.duration(Number(momentInterval[2]), momentInterval[3]).valueOf(); } return duration; } /** * Format acknowledges. * * @param {array} acknowledges array of Zabbix acknowledge objects * @return {string} HTML-formatted table */ function formatAcknowledges(acknowledges) { if (acknowledges.length) { var formatted_acknowledges = '

Acknowledges:
' + ''; _lodash2.default.each(_lodash2.default.map(acknowledges, function (ack) { var timestamp = _moment2.default.unix(ack.clock); return ''; }), function (ack) { formatted_acknowledges = formatted_acknowledges.concat(ack); }); formatted_acknowledges = formatted_acknowledges.concat('
TimeUserComments
' + timestamp.format("DD MMM YYYY HH:mm:ss") + '' + ack.alias + ' (' + ack.name + ' ' + ack.surname + ')' + '' + ack.message + '
'); return formatted_acknowledges; } else { return ''; } } function convertToZabbixAPIUrl(url) { var zabbixAPIUrlPattern = /.*api_jsonrpc.php$/; var trimSlashPattern = /(.*?)[\/]*$/; if (url.match(zabbixAPIUrlPattern)) { return url; } else { return url.replace(trimSlashPattern, "$1"); } } /** * Wrap function to prevent multiple calls * when waiting for result. */ function callOnce(func, promiseKeeper) { return function () { if (!promiseKeeper) { promiseKeeper = Promise.resolve(func.apply(this, arguments).then(function (result) { promiseKeeper = null; return result; })); } return promiseKeeper; }; } // Fix for backward compatibility with lodash 2.4 if (!_lodash2.default.includes) { _lodash2.default.includes = _lodash2.default.contains; }