vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-29 15:39:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Port email, slack, syslog, webhook plugins to the new alert API

Browse source
This commit is contained in:
Alfredo Cardigliano 2020-07-28 10:28:35 +02:00
parent 5f4b7d0c02
commit 9acf38efa9
5 changed files with 67 additions and 571 deletions
Download patch file Download diff file Expand all files Collapse all files

95
scripts/plugins/syslog_alert_endpoint/alert_endpoints/syslog.lua
View file

@ -35,68 +35,6 @@ end
-- ##############################################
function syslog.dequeueAlerts(queue)
local notifications = ntop.lrangeCache(queue, 0, -1)
if not notifications then
return {success = true}
end
local syslog_format = ntop.getPref("ntopng.prefs.syslog_alert_format")
if isEmptyString(syslog_format) then
syslog_format = "plaintext"
end
-- Separate by severity and channel
local alerts_by_types = {}
for _, json_message in ipairs(notifications) do
local notif = json.decode(json_message)
if notif.alert_entity then
alerts_by_types[notif.alert_entity] = alerts_by_types[notif.alert_entity] or {}
alerts_by_types[notif.alert_entity][notif.alert_severity] = alerts_by_types[notif.alert_entity][notif.alert_severity] or {}
table.insert(alerts_by_types[notif.alert_entity][notif.alert_severity], notif)
end
end
for _, by_severity in pairs(alerts_by_types) do
for severity, notifications in pairs(by_severity) do
severity = alert_consts.alertSeverityRaw(severity)
-- Most recent notifications first
for _, notif in pairsByValues(notifications, alert_utils.notification_timestamp_rev) do
local syslog_severity = alert_consts.alertLevelToSyslogLevel(severity)
local msg
if syslog_format == "plaintext" then
-- prepare a plaintext message
msg = alert_utils.formatAlertNotification(notif, {nohtml = true,
show_severity = true,
show_entity = true})
else -- syslog_format == "json" then
-- send out the json message but prepare a nice
-- message
notif.message = alert_utils.formatAlertNotification(notif, {nohtml = true,
show_severity = false,
show_entity = false})
msg = json.encode(notif)
end
ntop.syslog(msg, syslog_severity)
end
end
end
-- Remove all the messages from queue on success
ntop.delCache(queue)
return {success = true}
end
-- ##############################################
-- Dequeue alerts from a recipient queue for sending notifications
function syslog.dequeueRecipientAlerts(recipient, budget)
@ -160,37 +98,4 @@ end
-- ##############################################
function syslog.printPrefs(alert_endpoints, subpage_active, showElements)
print('<thead class="thead-light"><tr><th colspan="2" class="info">'..i18n("prefs.syslog_notification")..'</th></tr></thead>')
local alertsEnabled = showElements
local elementToSwitch = {"row_syslog_alert_format"}
prefsToggleButton(subpage_active, {
field = "toggle_alert_syslog",
pref = alert_endpoints.getAlertNotificationModuleEnableKey("syslog", true),
default = "0",
disabled = alertsEnabled == false,
to_switch = elementToSwitch,
})
local format_labels = {i18n("prefs.syslog_alert_format_plaintext"), i18n("prefs.syslog_alert_format_json")}
local format_values = {"plaintext", "json"}
if ntop.getPref(alert_endpoints.getAlertNotificationModuleEnableKey("syslog")) == "0" then
alertsEnabled = false
end
multipleTableButtonPrefs(subpage_active.entries["syslog_alert_format"].title,
subpage_active.entries["syslog_alert_format"].description,
format_labels, format_values,
"plaintext",
"primary",
"syslog_alert_format",
"ntopng.prefs.syslog_alert_format", nil,
nil, nil, nil, alertsEnabled)
end
-- ##############################################
return syslog