EVOLUTION-MANAGER

Edit File: list.lua

--
-- (C) 2021-21 - ntop.org
--
local dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
package.path = dirs.installdir .. "/scripts/lua/modules/alert_store/?.lua;" ..
                   package.path

local auth = require "auth"
local rest_utils = require("rest_utils")
local host_alert_store = require"host_alert_store".new()

--
-- Read alerts data
-- Example: curl -u admin:admin -H "Content-Type: application/json" -d '{"ifid": "1"}' http://localhost:3000/lua/rest/v2/get/host/alert/list.lua
--
-- NOTE: in case of invalid login, no error is returned but redirected to login
--

local rc = rest_utils.consts.success.ok
local res = {}

local ifid = _GET["ifid"]
local format = _GET["format"]
local telemetry = _GET["telemetry"]

local no_html = false
local download = false

if not format then
    -- GUI request - return formatted json
    format = "json"
else
    -- txt or (plain) json - return unformatted data
    no_html = true
    if format == "txt" then
        if ntop.isClickHouseEnabled() then download = true end
    else
        format = "json"
    end
end

if not auth.has_capability(auth.capabilities.alerts) then
    rest_utils.answer(rest_utils.consts.err.not_granted)
    return
end

if isEmptyString(ifid) then
    rc = rest_utils.consts.err.invalid_interface
    rest_utils.answer(rc)
    return
end

interface.select(ifid)

if not download then
    local debug = false

local alerts, recordsFiltered, info =
        host_alert_store:select_request(nil, "*", download, debug)

if (isEmptyString(telemetry)) then
        for _, _value in ipairs(alerts or {}) do
            res[#res + 1] = host_alert_store:format_record(_value, no_html)
        end
    else
        for _, _value in ipairs(alerts or {}) do
            res[#res + 1] = host_alert_store:format_record_telemetry(_value)
        end
    end
    if format == "txt" then
        res = host_alert_store:to_csv(res)
        rest_utils.vanilla_payload_response(rc, res, "text/csv")
    else
        local data = {records = res, stats = info}

rest_utils.extended_answer(rc, data, {
            ["draw"] = tonumber(_GET["draw"]),
            ["recordsFiltered"] = recordsFiltered,
            ["recordsTotal"] = recordsFiltered
        }, format)
    end
else
    local extra_headers = {}
    local rsp = "" -- data pushed by the query function clickhouse_utils.query (clickhouse_utils.lua)

extra_headers["Content-Disposition"] =
        "attachment;filename=\"host_alerts_export_" .. os.time() .. ".csv\""
    rest_utils.vanilla_payload_response(rest_utils.consts.success.ok, rsp,
                                        "application/octet-stream",
                                        extra_headers)
    host_alert_store:select_request(nil, "*", download)
end