vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-30 16:09:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

REST endpoints update

Browse source 
get_alerts_data.lua -> rest/get/alert/data.lua, host_get_json.lua -> rest/get/host/data.lua, get_interface_data.lua -> rest/get/interface/data.lua, live_traffic_extraction.lua -> rest/get/pcap/live_extraction.lua
This commit is contained in:
Alfredo Cardigliano 2019-01-30 14:18:45 +01:00
parent 183dfa41f9
commit 3381ddbcf5
16 changed files with 24 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

93
scripts/lua/get_alerts_data.lua
View file

@ -1,93 +0,0 @@
--
-- (C) 2013-18 - ntop.org
--
dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
require "lua_utils"
require "alert_utils"
require "flow_utils"
local format_utils = require "format_utils"
local json = require "dkjson"
sendHTTPHeader('application/json')
local status = _GET["status"]
local engaged = false
if status == "engaged" then
engaged = true
end
interface.select(ifname)
local alert_options = _GET
local function formatAlertRecord(alert_entity, record)
local flow = ""
local column_msg = record["alert_json"]
if alert_entity == "flow" then
column_msg = formatRawFlow(record, record["alert_json"])
elseif alert_entity == "User" then
column_msg = formatRawUserActivity(record, record["alert_json"])
end
column_msg = string.gsub(column_msg, '"', "'")
return column_msg
end
local alerts = getAlerts(status, alert_options)
if alerts == nil then alerts = {} end
local result = {}
for _key,_value in ipairs(alerts) do
local record = {}
local alert_entity
local alert_entity_val
if _value["alert_entity"] ~= nil then
alert_entity = alertEntityLabel(_value["alert_entity"], true)
else
alert_entity = "flow" -- flow alerts page doesn't have an entity
end
if _value["alert_entity_val"] ~= nil then
alert_entity_val = _value["alert_entity_val"]
else
alert_entity_val = ""
end
local column_duration
if engaged == true then
column_duration = os.time() - tonumber(_value["alert_tstamp"])
elseif tonumber(_value["alert_tstamp_end"]) ~= nil then
column_duration = tonumber(_value["alert_tstamp_end"]) - tonumber(_value["alert_tstamp"])
end
local column_severity = alertSeverityLabel(tonumber(_value["alert_severity"]), true)
local column_type = alertTypeLabel(tonumber(_value["alert_type"]), true)
local column_msg = formatAlertRecord(alert_entity, _value) or ""
local column_id = tostring(_value["rowid"])
local column_date = _value["alert_tstamp"]
record["key"] = column_id
record["date"] = column_date
record["duration"] = column_duration
record["severity"] = column_severity
record["type"] = column_type
record["msg"] = column_msg
record["entity"] = alert_entity
record["entity_val"] = alert_entity_val
result[#result + 1] = record
end -- for
print(json.encode(result))