'}),Ze=l({},Be.DefaultType,{content:"(string|element|function)"}),tn="fade",en="show",nn=".popover-header",on=".popover-body",rn={HIDE:"hide"+ze,HIDDEN:"hidden"+ze,SHOW:"show"+ze,SHOWN:"shown"+ze,INSERTED:"inserted"+ze,CLICK:"click"+ze,FOCUSIN:"focusin"+ze,FOCUSOUT:"focusout"+ze,MOUSEENTER:"mouseenter"+ze,MOUSELEAVE:"mouseleave"+ze},sn=function(t){var e,n;function i(){return t.apply(this,arguments)||this}n=t,(e=i).prototype=Object.create(n.prototype),(e.prototype.constructor=e).__proto__=n;var o=i.prototype;return o.isWithContent=function(){return this.getTitle()||this._getContent()},o.addAttachmentClass=function(t){g(this.getTipElement()).addClass($e+"-"+t)},o.getTipElement=function(){return this.tip=this.tip||g(this.config.template)[0],this.tip},o.setContent=function(){var t=g(this.getTipElement());this.setElementContent(t.find(nn),this.getTitle());var e=this._getContent();"function"==typeof e&&(e=e.call(this.element)),this.setElementContent(t.find(on),e),t.removeClass(tn+" "+en)},o._getContent=function(){return this.element.getAttribute("data-content")||this.config.content},o._cleanTipClass=function(){var t=g(this.getTipElement()),e=t.attr("class").match(Ge);null!==e&&0
',a='',f=function(a){var b;return b=document.createElement("div"),b.innerHTML=a,b.children[0]},g=e=null,d=function(a){return k(a),g.className+=" "+a},k=function(a){return g.className=g.className.replace(new RegExp("(^| )"+a.split(" ").join("|")+"( |$)","gi")," ")},i={},h=function(a,b){return d(a),null!=i[a]&&clearTimeout(i[a]),i[a]=setTimeout(function(){return k(a),delete i[a]},1e3*b)},m=function(a){var b,c,d,e;d={day:86400,hour:3600,minute:60,second:1};for(c in d)if(b=d[c],a>=b)return e=Math.floor(a/b),[e,c];return["now",""]},l=function(){var c,h;return g=f(b),document.body.appendChild(g),null!=Offline.reconnect&&Offline.getOption("reconnect")&&(g.appendChild(f(a)),c=g.querySelector(".offline-ui-retry"),h=function(a){return a.preventDefault(),Offline.reconnect.tryNow()},null!=c.addEventListener?c.addEventListener("click",h,!1):c.attachEvent("click",h)),d("offline-ui-"+Offline.state),e=g.querySelector(".offline-ui-content")},j=function(){return l(),Offline.on("up",function(){return k("offline-ui-down"),d("offline-ui-up"),h("offline-ui-up-2s",2),h("offline-ui-up-5s",5)}),Offline.on("down",function(){return k("offline-ui-up"),d("offline-ui-down"),h("offline-ui-down-2s",2),h("offline-ui-down-5s",5)}),Offline.on("reconnect:connecting",function(){return d("offline-ui-connecting"),k("offline-ui-waiting")}),Offline.on("reconnect:tick",function(){var a,b,c;return d("offline-ui-waiting"),k("offline-ui-connecting"),a=m(Offline.reconnect.remaining),b=a[0],c=a[1],e.setAttribute("data-retry-in-value",b),e.setAttribute("data-retry-in-unit",c)}),Offline.on("reconnect:stopped",function(){return k("offline-ui-connecting offline-ui-waiting"),e.setAttribute("data-retry-in-value",null),e.setAttribute("data-retry-in-unit",null)}),Offline.on("reconnect:failure",function(){return h("offline-ui-reconnect-failed-2s",2),h("offline-ui-reconnect-failed-5s",5)}),Offline.on("reconnect:success",function(){return h("offline-ui-reconnect-succeeded-2s",2),h("offline-ui-reconnect-succeeded-5s",5)})},"complete"===document.readyState?j():null!=document.addEventListener?document.addEventListener("DOMContentLoaded",j,!1):(c=document.onreadystatechange,document.onreadystatechange=function(){return"complete"===document.readyState&&j(),"function"==typeof c?c.apply(null,arguments):void 0})}.call(this);
diff --git a/js/popper.min.js b/js/popper.min.js
new file mode 100644
index 0000000..94a5c26
--- /dev/null
+++ b/js/popper.min.js
@@ -0,0 +1,5 @@
+/*
+ Copyright (C) Federico Zivolo 2019
+ Distributed under the MIT License (license terms are at http://opensource.org/licenses/MIT).
+ */(function(e,t){'object'==typeof exports&&'undefined'!=typeof module?module.exports=t():'function'==typeof define&&define.amd?define(t):e.Popper=t()})(this,function(){'use strict';function e(e){return e&&'[object Function]'==={}.toString.call(e)}function t(e,t){if(1!==e.nodeType)return[];var o=e.ownerDocument.defaultView,n=o.getComputedStyle(e,null);return t?n[t]:n}function o(e){return'HTML'===e.nodeName?e:e.parentNode||e.host}function n(e){if(!e)return document.body;switch(e.nodeName){case'HTML':case'BODY':return e.ownerDocument.body;case'#document':return e.body;}var i=t(e),r=i.overflow,p=i.overflowX,s=i.overflowY;return /(auto|scroll|overlay)/.test(r+s+p)?e:n(o(e))}function r(e){return 11===e?pe:10===e?se:pe||se}function p(e){if(!e)return document.documentElement;for(var o=r(10)?document.body:null,n=e.offsetParent||null;n===o&&e.nextElementSibling;)n=(e=e.nextElementSibling).offsetParent;var i=n&&n.nodeName;return i&&'BODY'!==i&&'HTML'!==i?-1!==['TH','TD','TABLE'].indexOf(n.nodeName)&&'static'===t(n,'position')?p(n):n:e?e.ownerDocument.documentElement:document.documentElement}function s(e){var t=e.nodeName;return'BODY'!==t&&('HTML'===t||p(e.firstElementChild)===e)}function d(e){return null===e.parentNode?e:d(e.parentNode)}function a(e,t){if(!e||!e.nodeType||!t||!t.nodeType)return document.documentElement;var o=e.compareDocumentPosition(t)&Node.DOCUMENT_POSITION_FOLLOWING,n=o?e:t,i=o?t:e,r=document.createRange();r.setStart(n,0),r.setEnd(i,0);var l=r.commonAncestorContainer;if(e!==l&&t!==l||n.contains(i))return s(l)?l:p(l);var f=d(e);return f.host?a(f.host,t):a(e,d(t).host)}function l(e){var t=1
| "+date_note+" | "+note['msg']+" | (by "+note['name']+") |
No Alerts for '+str(teams)+'!
'+IMAGE+' ' + config.TEMPLATE_FOOTER
+ else:
+ html_content = config.TEMPLATE_HEAD.replace('NAVBAR', config.NAVBAR) + response + config.TEMPLATE_FOOTER
+ return aiohttp.web.Response(text=html_content, content_type='text/html')
+
+def zabbix_login():
+ global zapi
+ x = 0
+
+ while x < 10:
+ try:
+ zapi = ZabbixAPI(server=ZABBIX_API, timeout=int(TIMEOUT))
+ zapi.login(ZABBIX_LOGIN, ZABBIX_PASS)
+ except Exception as e:
+ x+=1
+ _logger.error("[ERR] - {} Retry #{}: {}".format(datetime.datetime.now(), x, e))
+ time.sleep(x)
+ continue
+ break
+ if x >= 10:
+ sys.exit("Can't connect to Zabbix API.")
+
+def call_zabbix(request, method):
+ global zapi
+ x = 0
+
+ while x < 10:
+ try:
+ if method == 'hostgroup':
+ resp = zapi.hostgroup.get(request)
+ elif method == 'triggers':
+ resp = zapi.trigger.get(request)
+ except Exception as e:
+ x+=1
+ _logger.error("[ERR] - {} Retry #{}: {}".format(datetime.datetime.now(), x, e))
+ time.sleep(x)
+ continue
+ break
+ if x >= 10:
+ sys.exit("Can't perform calls to Zabbix API.")
+ else:
+ return resp
+
+async def process_zabbix_queue():
+ global CONTENT
+ global TOTAL_ALERTS
+ global HOSTGROUP
+ global LIMIT
+ global SEVERITY
+ global zapi
+
+ while True:
+ try:
+ zapi.logged_in()
+ except Exception as e:
+ _logger.info('[INFO] - {}: Connection to Zabbix API'.format(datetime.datetime.now()))
+ zabbix_login()
+
+ request = dict()
+ request['output'] = 'extend'
+ request['search'] = dict()
+ request['search']['name'] = [HOSTGROUP]
+ request['searchWildcardsEnabled'] = 1
+ resp = call_zabbix(request, 'hostgroup')
+ groupids = []
+ for x in range(len(resp)):
+ config.CONTENT[resp[x]['name']] = []
+ groupids.append(resp[x]['groupid'])
+
+ request = dict()
+ request['limit'] = LIMIT
+ request['groupids'] = groupids
+ request['monitored'] = 1
+ request['maintenance'] = 0
+ request['active'] = 1
+ request['min_severity'] = SEVERITY
+ request['output'] = "extend"
+ request['expandData'] = 1
+ request['selectHosts'] = "extend"
+ request['selectGroups'] = "extend"
+ request['expandDescription'] = 1
+ request['only_true'] = 1
+ request['skipDependent'] = 1
+ request['withUnacknowledgedEvents'] = 1
+ request['withLastEventUnacknowledged'] = 1
+ request['selectTags'] = "extend"
+ request['filter'] = dict()
+ request['filter']['value'] = 1
+ request['sortfield'] = ["priority","lastchange"]
+ request['sortorder'] = ["DESC"]
+ _logger.info(request)
+ resp = call_zabbix(request, 'triggers')
+ config.TOTAL_ALERTS = str(len(resp))
+ _logger.info('[NB ALERTS] - {}'.format(config.TOTAL_ALERTS))
+ hostgroup_to_search = HOSTGROUP.replace('*','')
+ for x in range(len(resp)):
+ data = resp[x]
+ if len(data['hosts']) > 0:
+ for z in range(len(data['groups'])):
+ if hostgroup_to_search in data['groups'][z]['name']:
+ group = data['groups'][z]['name']
+ config.CONTENT[group].append({'description': data['description'], 'host': data['hosts'][0]['host'], 'priority': data['priority'], 'triggerid': data['triggerid'], 'lastchange': data['lastchange'], 'team': group})
+ for y in range(len(data['tags'])):
+ if 'team' == data['tags'][y]['tag']:
+ team = data['tags'][y]['value']
+ config.CONTENT[team].append({'description': data['description'], 'host': data['hosts'][0]['host'], 'priority': data['priority'], 'triggerid': data['triggerid'], 'lastchange': data['lastchange'], 'team': team})
+ _logger.info('[INFO] - {}: Refresh...'.format(datetime.datetime.now()))
+ await asyncio.sleep(15)
+
+async def start_background_tasks(app):
+ app['dispatch'] = app.loop.create_task(process_zabbix_queue())
+ app['dispatch'] = app.loop.create_task(check_servers())
+
+
+async def cleanup_background_tasks(app):
+ app['dispatch'].cancel()
+ await app['dispatch']
+
+def main():
+
+ app = aiohttp.web.Application(logger=_logger)
+
+ app.add_routes([aiohttp.web.get('/', show_alerts),
+ aiohttp.web.post('/post', post_note),
+ aiohttp.web.post('/del', del_note),
+ aiohttp.web.get('/{teams}', show_alerts),
+ aiohttp.web.get('/tv/{teams}', show_alerts),
+ aiohttp.web.static('/images', '/images'),
+ aiohttp.web.static('/css', '/css'),
+ aiohttp.web.static('/js', '/js')])
+
+
+ app.on_startup.append(start_background_tasks)
+ app.on_cleanup.append(cleanup_background_tasks)
+ aiohttp.web.run_app(app, port=PORT)
+
+if __name__ == '__main__':
+ main()