vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-05-02 00:40:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Improved ASN Mode tables (#9446)

Browse source 
* Added as table for ASN Mode #9422

* Reworked live flows in IXP Mode #9423
This commit is contained in:
GabrieleDeri 2025-07-28 15:46:26 +02:00 • committed by GitHub
parent 4bb2f117bd
commit 11f6bb69e1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
7 changed files with 247 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

43
scripts/lua/rest/v2/get/flow/active_list.lua
View file

@ -107,12 +107,15 @@ end
for _, value in ipairs(flows_stats.flows) do
local record = {}
local key = value["ntopng.key"]
local info_cli = interface.getHostMinInfo(value["cli.ip"], value["cli.vlan"])
local info_srv = interface.getHostMinInfo(value["srv.ip"], value["srv.vlan"])
local cli_ip = value["cli.ip"]
local srv_ip = value["srv.ip"]
local info_cli = interface.getHostMinInfo(cli_ip, value["cli.vlan"])
local info_srv = interface.getHostMinInfo(srv_ip, value["srv.vlan"])
if not info_cli then
info_cli = {
host = value["cli.ip"],
host = cli_ip,
vlan = value["cli.vlan"],
localhost = value["cli.localhost"],
systemhost = value["cli.systemhost"]
@ -121,16 +124,40 @@ for _, value in ipairs(flows_stats.flows) do
if not info_srv then
info_srv = {
host = value["srv.ip"],
host = srv_ip,
vlan = value["srv.vlan"],
localhost = value["srv.localhost"],
systemhost = value["srv.systemhost"]
}
end
-- ASN data extraction
local cli_asn = value['cli.asn']
local srv_asn = value['srv.asn']
local transit_asn = ""
--peer src !- src -> transit richiesta
--peer dst !- dst -> transit risposta
--se transit = 0 non far vedere
local cli_asn_data = {
asn = cli_asn,
name = ntop.getASName(cli_ip)
}
local srv_asn_data = {
asn = srv_asn,
name = ntop.getASName(srv_ip)
}
local transit_asn_data = {
asn = transit_asn,
name
}
-- Formatting client column
local client = {
ip = value["cli.ip"],
ip = cli_ip,
vlan = value["cli.vlan"],
name = hostinfo2label(info_cli, true),
port = value["cli.port"],
@ -163,7 +190,7 @@ for _, value in ipairs(flows_stats.flows) do
-- Formatting server column
local server = {
ip = value["srv.ip"],
ip = srv_ip,
vlan = value["srv.vlan"],
name = hostinfo2label(info_srv, true),
port = value["srv.port"],
@ -274,6 +301,10 @@ for _, value in ipairs(flows_stats.flows) do
record["periodic_flow"] = value.periodic_flow
record["client"] = client
record["server"] = server
record["cli_asn"] = cli_asn_data
record["srv_asn"] = srv_asn_data
record["transit_asn"] = transit_asn_data
record["ifid"] = ifid
if value.score then
record["score"] = value.score.flow_score