mirror of
https://github.com/ntop/ntopng.git
synced 2026-05-02 00:40:10 +00:00
6c5f665a73
Local networks are aggregated on the basis of their string representation rather than their id which may change between ntopng restarts.
224 lines
7 KiB
Lua
224 lines
7 KiB
Lua
--
|
|
-- (C) 2013-15 - ntop.org
|
|
--
|
|
|
|
dirs = ntop.getDirs()
|
|
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
|
|
|
|
require "top_talkers"
|
|
require "json"
|
|
|
|
local top_networks_intf = {}
|
|
|
|
if (ntop.isPro()) then
|
|
package.path = dirs.installdir .. "/pro/scripts/lua/modules/top_scripts/?.lua;" .. package.path
|
|
local new = require("top_aggregate")
|
|
if (type(new) ~= "table") then new = {} end
|
|
-- Add pro methods to local method table
|
|
for k,v in pairs(new) do
|
|
top_networks_intf[k] = v
|
|
end
|
|
end
|
|
|
|
local function getTopNetworks(ifid, ifname)
|
|
return getCurrentTopGroupsSeparated(ifid, ifname, 10, true, false,
|
|
nil, nil, top_networks_intf.key,
|
|
top_networks_intf.JSONkey, nil, true, nil,
|
|
top_networks_intf.uniqueKey)
|
|
end
|
|
|
|
local function getTopNetworksBy(ifid, ifname, filter_col, filter_val)
|
|
return getCurrentTopGroupsSeparated(ifid, ifname, 10, true, false,
|
|
filter_col, filter_val, top_networks_intf.key,
|
|
top_networks_intf.JSONkey, nil, true, nil,
|
|
top_networks_intf.uniqueKey)
|
|
end
|
|
|
|
local function getTopNetworksClean(ifid, ifname, param)
|
|
top = getCurrentTopGroups(ifid, ifname, 5, false, false,
|
|
nil, nil, top_networks_intf.key,
|
|
top_networks_intf.JSONkey, true, param,
|
|
top_networks_intf.uniqueKey)
|
|
section_beginning = string.find(top, '%[')
|
|
if (section_beginning == nil) then
|
|
return("[ ]\n")
|
|
else
|
|
return(string.sub(top, section_beginning))
|
|
end
|
|
end
|
|
|
|
local function topNetworksSectionInTableOP(tblarray, arithOp)
|
|
local ret = {}
|
|
local outer_cnt = 1
|
|
local num_glob = 1
|
|
|
|
for _,tbl in pairs(tblarray) do
|
|
for _,outer in pairs(tbl) do
|
|
if (ret[outer_cnt] == nil) then ret[outer_cnt] = {} end
|
|
for key, value in pairs(outer) do
|
|
for _,record in pairs(value) do
|
|
local found = false
|
|
if (ret[outer_cnt][key] == nil) then ret[outer_cnt][key] = {} end
|
|
for _,el in pairs(ret[outer_cnt][key]) do
|
|
if (found == false and el["label"] == record["label"]) then
|
|
el["value"] = arithOp(el["value"], record["value"])
|
|
found = true
|
|
end
|
|
end
|
|
if (found == false) then
|
|
ret[outer_cnt][key][num_glob] = record
|
|
num_glob = num_glob + 1
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
return ret
|
|
end
|
|
|
|
local function printTopNetworksTable(tbl)
|
|
local rsp = "{\n"
|
|
|
|
for i,v in pairs(tbl) do
|
|
local outouterlooped = 0
|
|
for dk,dv in pairs(v) do
|
|
rsp = rsp..'"'..dk..'": [\n'
|
|
local keys = getKeys(dv, "value")
|
|
local outerlooped = 0
|
|
for tv,tk in pairsByKeys(keys, rev) do
|
|
rv = dv[tk]
|
|
rsp = rsp.."{ "
|
|
local looped = 0
|
|
for k,v in pairs(rv) do
|
|
rsp = rsp..'"'..k..'": '
|
|
if (k == "value") then
|
|
rsp = rsp..tostring(v)
|
|
else
|
|
rsp = rsp..'"'..v..'"'
|
|
end
|
|
rsp = rsp..", "
|
|
looped = looped + 1
|
|
end
|
|
if (looped > 0) then
|
|
rsp = string.sub(rsp, 1, -3)
|
|
end
|
|
rsp = rsp.."},\n"
|
|
outerlooped = outerlooped + 1
|
|
end
|
|
if (outerlooped > 0) then
|
|
rsp = string.sub(rsp, 1, -3)
|
|
end
|
|
rsp = rsp.."],\n"
|
|
outouterlooped = outouterlooped + 1
|
|
end
|
|
if (outouterlooped > 0) then
|
|
rsp= string.sub(rsp, 1, -3)
|
|
end
|
|
end
|
|
|
|
rsp = rsp.."\n}"
|
|
|
|
return rsp
|
|
|
|
end
|
|
|
|
local function getTopNetworksFromJSONDirection(table, wantedDir, add_vlan)
|
|
local elements = ""
|
|
|
|
-- For each VLAN, get networks and concatenate them
|
|
for i,vlan in pairs(table["vlan"]) do
|
|
local vlanid = vlan["label"]
|
|
local vlanname = vlan["name"]
|
|
-- XXX networks is an array of (senders, receivers) pairs?
|
|
for i2,networkspair in pairs(vlan[top_networks_intf.JSONkey]) do
|
|
-- networkspair is { "senders": [...], "receivers": [...] }
|
|
for k2,direction in pairs(networkspair) do
|
|
-- direction is "senders": [...] or "receivers": [...]
|
|
if (k2 ~= wantedDir) then goto continue end
|
|
-- scan networks
|
|
for i2,network in pairs(direction) do
|
|
-- network is { "label": ..., "value": ..., "url": ... }
|
|
elements = elements.."{ "
|
|
local n_el = 0
|
|
for k3,v3 in pairs(network) do
|
|
elements = elements..'"'..k3..'": '
|
|
if (k3 == "value") then
|
|
elements = elements..tostring(v3)
|
|
else
|
|
elements = elements..'"'..v3..'"'
|
|
end
|
|
elements = elements..", "
|
|
n_el = n_el + 1
|
|
end
|
|
if (add_vlan ~= nil) then
|
|
elements = elements..'"vlanm": "'..vlanname..'", '
|
|
elements = elements..'"vlan": "'..vlanid..'", '
|
|
end
|
|
if (n_el ~= 0) then
|
|
elements = string.sub(elements, 1, -3)
|
|
end
|
|
elements = elements.." },\n"
|
|
end
|
|
::continue::
|
|
end
|
|
end
|
|
end
|
|
|
|
return elements
|
|
end
|
|
|
|
local function printTopNetworksFromTable(table, add_vlan)
|
|
if (table == nil or table["vlan"] == nil) then return "[ ]\n" end
|
|
|
|
local elements = "{\n"
|
|
elements = elements..'"senders": [\n'
|
|
local result = getTopNetworksFromJSONDirection(table, "senders", add_vlan)
|
|
if (result ~= "") then
|
|
result = string.sub(result, 1, -3) --remove comma
|
|
end
|
|
elements = elements..result
|
|
elements = elements.."],\n"
|
|
elements = elements..'"receivers": [\n'
|
|
result = getTopNetworksFromJSONDirection(table, "receivers", add_vlan)
|
|
if (result ~= "") then
|
|
result = string.sub(result, 1, -3) --remove comma
|
|
end
|
|
elements = elements..result
|
|
elements = elements.."]\n"
|
|
elements = elements.."}\n"
|
|
|
|
return elements
|
|
end
|
|
|
|
local function getTopNetworksFromJSON(content, add_vlan)
|
|
if(content == nil) then return("[ ]\n") end
|
|
local table = parseJSON(content)
|
|
local rsp = printTopNetworksFromTable(table, add_vlan)
|
|
if (rsp == nil or rsp == "") then return "[ ]\n" end
|
|
return rsp
|
|
end
|
|
|
|
local function getHistoricalTopNetworks(ifid, ifname, epoch, add_vlan)
|
|
if (epoch == nil) then
|
|
return("[ ]\n")
|
|
end
|
|
return getTopNetworksFromJSON(ntop.getMinuteSampling(ifid, tonumber(epoch)), add_vlan)
|
|
end
|
|
|
|
top_networks_intf.name = "Networks"
|
|
top_networks_intf.infoScript = "hosts_stats.lua"
|
|
top_networks_intf.infoScriptKey = "network"
|
|
top_networks_intf.key = "network"
|
|
top_networks_intf.JSONkey = "networks"
|
|
top_networks_intf.uniqueKey = "top_local_nets"
|
|
top_networks_intf.getTop = getTopNetworks
|
|
top_networks_intf.getTopBy = getTopNetworksBy
|
|
top_networks_intf.getTopClean = getTopNetworksClean
|
|
top_networks_intf.getTopFromJSON = getTopNetworksFromJSON
|
|
top_networks_intf.printTopTable = printTopNetworksTable
|
|
top_networks_intf.getHistoricalTop = getHistoricalTopNetworks
|
|
top_networks_intf.topSectionInTableOp = topNetworksSectionInTableOP
|
|
top_networks_intf.numLevels = 2
|
|
|
|
return top_networks_intf
|