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

Implement alert release

Browse source
This commit is contained in:
emanuele-f 2019-06-28 15:04:56 +02:00
parent e78039c2f2
commit 2df194a282
12 changed files with 205 additions and 56 deletions
Download patch file Download diff file Expand all files Collapse all files

44
scripts/lua/modules/alerts_api.lua
View file

@ -90,7 +90,8 @@ end
-- ##############################################
function alerts:emit(entity_value, alert_message, when)
-- Triggers a new alert or refreshes an existing one
function alerts:trigger(entity_value, alert_message, when)
local force = false
local msg = alert_message
when = when or os.time()
@ -99,7 +100,7 @@ function alerts:emit(entity_value, alert_message, when)
msg = json.encode(alert_message)
end
local rv = interface.emitAlert(when, self.periodicity,
local rv = interface.triggerAlert(when, self.periodicity,
self.type_id, self.severity_id,
self.entity_type_id, entity_value, msg, self.subtype)
@ -121,7 +122,44 @@ function alerts:emit(entity_value, alert_message, when)
end
end
return(rv)
return(rv.success)
end
-- ##############################################
-- Releases an engaged alert
-- NOTE: alerts are automomatically released based on their periodicity,
-- this function is for premature release
function alerts:release(entity_value, when)
when = when or os.time()
local rv = interface.releaseAlert(when, self.periodicity,
self.type_id, self.severity_id, self.entity_type_id, entity_value)
if(rv ~= nil) then
if(rv.success and rv.rowid) then
local res = interface.queryAlertsRaw("SELECT alert_json", string.format("WHERE rowid=%u", rv.rowid))
if((res ~= nil) and (#res == 1)) then
local msg = res[1].alert_json
local message = {
ifid = interface.getId(),
entity_type = self.entity_type_id,
entity_value = entity_value,
type = self.entity_type_id,
severity = self.severity_id,
message = msg,
tstamp = when,
action = "release",
}
alert_endpoints.dispatchNotification(message, json.encode(message))
end
end
end
return(rv.success)
end
-- ##############################################