ntopng/scripts/lua/inc/menu.lua
Simone Mainardi c7082a4647 Implements new alerts database and drilldown
alert store skeleton

Alert database type changes

Implement alert store for host alerts. All alert store skeletons.

Fix class method access

Enable tracing

Implements simple queries for host alerts

Implement flow alert store

Fixes escaping of INSERT queries

Flow alerts database schema fixes

Adds escaping for alert JSON in flows and hosts

Implements queries .select() for alerts store

Adds limit and offset to perform paginated queries

Adds new REST getter for flow alerts

Name changes alert_severity to severity, alert_json to json

Fixes alert message not shown

Implement active monitoring alerts store

Implements sort of queries in the new dataabase

Changes alert_type to alert_id

Implement mac alerts store

Fixes flow alert messages

Implement system alerts store

Implement snmp alert store

Add missing items to the flow alerts

Add missing items to the host alerts

Add missing items to the mac alerts

Implements COUNT aplerts api

Add device_name to snmp alerts

add flow alerts templates

updated gitignore

fix for missing order field

add families defined in `alert_store_schema.sql`

Reworks and simplifies alert store subclasses

Implements REST API to fetch alert timeseries

Fixes date in flow REST api

Host alert json fix

Add get/host/alert/list.lua

Move alert/list.lua to alert/past/list.lua

Add alert/past/list.lua for all alert families

Add entity_id to system table to identify the alert type based on <alert_id, entity_id>

Add missing field

Implements facilities to query engaged alerts via REST

Handle both historical and past alerts in alert/list.lua

Fix count

Update params of select_historical

Implement method to add family-specific filters

Add alert/ts.lua for all alert families

Implements facilities and REST endpoints to delete alerts

Implements ordering of alert queries

Fix add_order_by group_by

Rest API tests update

Tests output update

Remove debug trace

Use alert_id instead of type. Add more flow alert info.

Update http lint

Format obsolete tlv version alerts. Add more host info.

Add row_id to list of alerts

Fix selection of engaged alerts

Add test for mac alerts (bcast domains)

Removes attempt to format alerts as flow alerts

Fixes interface selection for active monitoring

Update test output with rest changes

Add more fields to be ignores

Set alert count to 1 for the time being

add bar timeseries chart

add apexcharts

improvements on timeseries bar chart

registered chart callbakcs

working on alert page

fix for date format

Fixes acrive monitoring REST API

Fixes alignment of grouped alert data

Additional fix for alert histogram

remove useless if

formatting alerts page

fixes on flows alert stats table

rename local networks to device

format host pagie in alert_stats

add tag support for hosts and flow

implemented single delete action

add release modal

Fixes format of threshold cross interface alerts

Fixes wrong increase of dropped alerts

Implements exclusion list for invalid dns queries

Reworks exclusions lists for hosts and flows

Addresses #5212
Addresses #5113

Adds host alert keys in host callbacks definitions

Adds alert ids to flow callbacks

fix for not working button (#5215)

Fixes reported timeseries name

removed any additional button inside chart's toolbar (#5200)

Add tables for interfaces, networks, users to the schema. Skeleton alert_store classes

fixed broken range picker layout in firefox (#5199)

Alert insert fixes

Add more info to network alerts

Add rest endpoint for interface, network, user alerts

Fix endpoint selection in alerts_stats

Unifies columns between engaged and past alerts

Fixes Missing mandatory 'alert_granularity'

Minor fixes for missing alert_severity

Fixes arithmetic on a nil value (field 'last_seen')

Fixes get/system/alert/list.lua

use tstamp for column names (#5221)

Implements host alert formatter

Add alerts_store format_record_common

Use common format_record for am, system alerts

Use common format_record for all alerts

Fixes formatting of alerts of all types

Fixes nil in function 'hostinfo2label'

fixes on disable modal

add pages for network, user and interface endpoint (#5224)

Set alert_entity in all classes

Unifies influxdb alerts into system alerts

Addresses #5224

Unifies process alerts into system alerts

Addresses #5224

Cleanup unused periodicActivityEntity

Unifies category lists alerts into system alerts

Addresses #5224

Aligns new alert enums

Addresses #5224

Fixes alert page links

Fixes insertion of interface alerts

Implement filters for Host alerts

Fixes active monitoring alerts not triggering

Implement filters on flow alerts

Fixes for internal alerts timestamp and subtype

implements disable for the alerts

formatted alert disable label

Add address and device type to mac alert records

fix for delete alert toggle

Fix access to entity_val in alert_unexpected_new_device

add mac address and device type inside table

Fixes for new alert fields not handled

Fixes alert_definitions to handle new fields

Add ip/port to snmp alert records

Implements deletion of stored flow alerts

Add alert_name to all alert records via rest. Fix duration.

fixes for snmp tab

Implements delete of past host alerts

Add name to snmp alert records

fixes on system tab

Fix Date column

fixes link

Update menu

Fixes bad argument #3 to 'format' in snmp alerts

updated interface link

new alerts url for host (#5228)

Fixes sort of engaged alert

Minor cleanup

Fixes data returned for local network alerts

Fix duration for one shot. Note.

Fix duration override

Fixes interface selection for system alerts

Move host alert page

fixes for local network tab

Minor fix

Fix engaged host alerts

fixes on user tab

Fix alert_user_activity message
2021-04-26 19:41:34 +02:00

1266 lines
40 KiB
Lua

--
-- (C) 2013-21 - ntop.org
--
local dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
package.path = dirs.installdir .. "/scripts/lua/modules/toasts/?.lua;" .. package.path
if((dirs.scriptdir ~= nil) and (dirs.scriptdir ~= "")) then package.path = dirs.scriptdir .. "/lua/modules/?.lua;" .. package.path end
require "lua_utils"
local alerts_api = require("alerts_api")
local recording_utils = require "recording_utils"
local telemetry_utils = require "telemetry_utils"
local ts_utils = require("ts_utils_core")
local page_utils = require("page_utils")
local delete_data_utils = require "delete_data_utils"
local toasts_manager = require("toasts_manager")
local host_pools = require "host_pools"
local auth = require "auth"
local blog_utils = require("blog_utils")
local template_utils = require "template_utils"
local is_nedge = ntop.isnEdge()
local is_appliance = ntop.isAppliance()
local is_admin = isAdministrator()
local is_windows = ntop.isWindows()
local info = ntop.getInfo()
local updates_supported = (is_admin and ntop.isPackage() and not ntop.isWindows())
local has_local_auth = (ntop.getPref("ntopng.prefs.local.auth_enabled") ~= '0')
-- this is a global variable
local is_system_interface = page_utils.is_system_view()
blog_utils.fetchLatestPosts()
print([[
<div class='wrapper'>
]])
print[[
<script type='text/javascript'>
const isAdministrator = ]] print(is_admin) print[[;
const loggedUser = "]] print(_SESSION['user']) print[[";
const interfaceID = ]] print(interface.getStats().id) print[[;
/* Some localization strings to pass from lua to javascript */
const i18n = {
"no_results_found": "]] print(i18n("no_results_found")) print[[",
"are_you_sure": "]] print(i18n("scripts_list.are_you_sure")) print[[",
"change_number_of_rows": "]] print(i18n("change_number_of_rows")) print[[",
"no_data_available": "]] print(i18n("no_data_available")) print[[",
"showing_x_to_y_rows": "]] print(i18n("showing_x_to_y_rows", {x="{0}", y="{1}", tot="{2}"})) print[[",
"actions": "]] print(i18n("actions")) print[[",
"query_was_aborted": "]] print(i18n("graphs.query_was_aborted")) print[[",
"exports": "]] print(i18n("system_stats.exports_label")) print[[",
"no_file": "]] print(i18n("config_scripts.no_file")) print[[",
"invalid_file": "]] print(i18n("config_scripts.invalid_file")) print[[",
"request_failed_message": "]] print(i18n("request_failed_message")) print[[",
"all": "]] print(i18n("all")) print[[",
"edit": "]] print(i18n("edit")) print[[",
"remove": "]] print(i18n("remove")) print[[",
"and": "]] print(i18n("and")) print[[",
"other": "]] print(i18n("other")) print[[",
"others": "]] print(i18n("others")) print[[",
"warning": "]] print(i18n("warning")) print[[",
"search": "]] print(i18n("search")) print[[",
"and_x_more": "]] print(i18n("and_x_more", { num = '$num'})) print[[",
"invalid_input": "]] print(i18n("validation.invalid_input")) print[[",
"missing_field": "]] print(i18n("validation.missing_field")) print[[",
"unreachable_host": "]] print(i18n("graphs.unreachable_host")) print[[",
"NAME_RESOLUTION_FAILED": "]] print(i18n("rest_consts.NAME_RESOLUTION_FAILED")) print[[",
"FAILED_HTTP_REQUEST": "]] print(i18n("validation.FAILED_HTTP_REQUEST")) print[[",
"rest_consts": {
"PARTIAL_IMPORT": "]] print(i18n("rest_consts.PARTIAL_IMPORT")) print[[",
"CONFIGURATION_FILE_MISMATCH": "]] print(i18n("rest_consts.CONFIGURATION_FILE_MISMATCH")) print[[",
}
};
const systemInterfaceEnabled = ]] print(ternary(is_system_interface, "true", "false")) print[[;
const http_prefix = "]] print(ntop.getHttpPrefix()) print[[";
window.__CSRF_DATATABLE__ = `]] print(ntop.getRandomCSRFValue()) print[[`;
if(document.cookie.indexOf("tzoffset=") < 0) {
// Tell the server the client timezone
document.cookie = "tzoffset=" + (new Date().getTimezoneOffset() * 60 * -1);
}
</script>]]
local template = require "template_utils"
prefs = ntop.getPrefs()
local iface_names = interface.getIfNames()
-- tprint(prefs)
-- tprint(iface_names)
num_ifaces = 0
for k,v in pairs(iface_names) do
num_ifaces = num_ifaces+1
end
interface.select(ifname)
local ifs = interface.getStats()
local is_pcap_dump = interface.isPcapDumpInterface()
local is_packet_interface = interface.isPacketInterface()
ifId = ifs.id
-- NOTE: see sidebar.js for the client logic
page_utils.init_menubar()
if is_nedge then
dofile(dirs.installdir .. "/pro/scripts/lua/nedge/inc/menubar.lua")
else
-- ##############################################
-- Shortcuts
-- The Shortcuts entry are used to go to the System interface pages
-- without using the Interface dropdown. The section is hidden
-- in system interface.
page_utils.add_menubar_section({
section = page_utils.menu_sections.shortcuts,
hidden = is_system_interface or not is_admin,
entries = {
{
entry = page_utils.menu_entries.snmp,
hidden = (not ntop.isEnterpriseM() and not ntop.isnEdgeEnterprise()),
url = "/lua/pro/enterprise/snmpdevices_stats.lua"
},
{
entry = page_utils.menu_entries.active_monitoring,
url = "/plugins/active_monitoring_stats.lua"
},
{
entry = page_utils.menu_entries.divider,
hidden = not ntop.isEnterpriseM(),
},
{
entry = page_utils.menu_entries.manage_pools,
hidden = not is_admin,
url = '/lua/admin/manage_pools.lua'
},
{
entry = page_utils.menu_entries.divider,
},
{
entry = page_utils.menu_entries.endpoint_notifications,
hidden = not is_admin,
url = '/lua/admin/endpoint_notifications_list.lua',
},
{
entry = page_utils.menu_entries.endpoint_recipients,
hidden = not is_admin,
url = '/lua/admin/recipients_list.lua',
},
}
})
-- Dashboard
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.dashboard,
hidden = is_pcap_dump or is_system_interface,
entries = {
{
entry = page_utils.menu_entries.traffic_dashboard,
url = ntop.isPro() and '/lua/pro/dashboard.lua' or '/lua/index.lua',
},
{
entry = page_utils.menu_entries.divider,
},
{
entry = page_utils.menu_entries.network_discovery,
hidden = not interface.isDiscoverableInterface() or interface.isLoopback(),
url = "/lua/discover.lua",
},
{
entry = page_utils.menu_entries.traffic_report,
hidden = not ntop.isPro(),
url = "/lua/pro/report.lua",
},
{
entry = page_utils.menu_entries.divider,
hidden = not ntop.isPro() or not (prefs.is_dump_flows_to_mysql_enabled or prefs.is_nindex_enabled) or ifs.isViewed,
},
{
entry = page_utils.menu_entries.db_explorer,
hidden = not ntop.isPro() or not prefs.is_dump_flows_to_mysql_enabled or ifs.isViewed,
url = "/lua/pro/db_explorer.lua?ifid="..ifId,
},
{
entry = page_utils.menu_entries.db_explorer,
hidden = not ntop.isPro() or not prefs.is_nindex_enabled or ifs.isViewed,
url = "/lua/pro/nindex_query.lua",
},
},
}
)
-- ##############################################
-- Alerts
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.alerts,
hidden = not ntop.getPrefs().are_alerts_enabled or is_system_interface,
url = '/lua/alert_stats.lua?page=flow',
}
)
-- ##############################################
-- Flows
page_utils.add_menubar_section(
{
hidden = is_system_interface,
section = page_utils.menu_sections.flows,
url = "/lua/flows_stats.lua",
}
)
-- ##############################################
local service_map_available = false
if(ntop.isEnterpriseL() and (ntop.getPref("ntopng.prefs.is_behaviour_analysis_enabled") == "1")) then
local service_map = interface.serviceMap()
if service_map and (table.len(service_map) > 0) then
service_map_available = true
end
end
local periodic_info_available = false
if(ntop.isEnterpriseL() and (ntop.getPref("ntopng.prefs.is_behaviour_analysis_enabled") == "1")) then
local periodicity_map = interface.periodicityMap()
if periodicity_map and (table.len(periodicity_map) > 0) then
periodic_info_available = true
end
end
-- Hosts
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.hosts,
hidden = ifs.isViewed or is_system_interface,
entries = {
{
entry = page_utils.menu_entries.hosts,
url = '/lua/hosts_stats.lua',
},
{
entry = page_utils.menu_entries.devices,
hidden = not ifs.has_macs,
url = '/lua/macs_stats.lua?devices_mode=source_macs_only',
},
{
entry = page_utils.menu_entries.networks,
url = '/lua/network_stats.lua',
},
{
entry = page_utils.menu_entries.host_pools,
url = '/lua/pool_stats.lua',
},
{
entry = page_utils.menu_entries.autonomous_systems,
hidden = not ntop.hasGeoIP(),
url = '/lua/as_stats.lua',
},
{
entry = page_utils.menu_entries.countries,
hidden = not ntop.hasGeoIP(),
url = '/lua/country_stats.lua',
},
{
entry = page_utils.menu_entries.operating_systems,
url = '/lua/os_stats.lua',
},
{
entry = page_utils.menu_entries.vlans,
hidden = not interface.hasVLANs(),
url = '/lua/vlan_stats.lua',
},
{
entry = page_utils.menu_entries.pods,
hidden = not ifs.has_seen_pods,
url = '/lua/pods_stats.lua',
},
{
entry = page_utils.menu_entries.containers,
hidden = not ifs.has_seen_containers,
url = '/lua/containers_stats.lua',
},
{
entry = page_utils.menu_entries.divider,
},
{
entry = page_utils.menu_entries.http_servers,
url = '/lua/http_servers_stats.lua',
},
{
entry = page_utils.menu_entries.top_hosts,
hidden = is_pcap_dump,
url = '/lua/top_hosts.lua',
},
},
}
)
-- ##############################################
-- Maps
page_utils.add_menubar_section({
section = page_utils.menu_sections.maps,
hidden = is_system_interface,
entries = {
{
entry = page_utils.menu_entries.service_map,
hidden = not service_map_available,
url = '/lua/pro/enterprise/service_map.lua',
},
{
entry = page_utils.menu_entries.periodicity_map,
hidden = not periodic_info_available,
url = '/lua/pro/enterprise/periodicity_map.lua',
},
{
entry = page_utils.menu_entries.geo_map,
hidden = interface.isLoopback() or not ntop.hasGeoIP(),
url = '/lua/hosts_geomap.lua',
},
{
entry = page_utils.menu_entries.hosts_map,
url = '/lua/hosts_map.lua',
},
}
})
-- ##############################################
-- Exporters
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.exporters,
hidden = ((ifs.type ~= "zmq" and ifs.type ~= "custom") or not ntop.isEnterpriseM()) or is_system_interface,
entries = {
{
entry = page_utils.menu_entries.event_exporters,
hidden = not ifs.has_seen_ebpf_events,
url = '/lua/pro/enterprise/event_exporters.lua',
},
{
entry = page_utils.menu_entries.sflow_exporters,
hidden = table.len(interface.getSFlowDevices() or {}) == 0,
url = '/lua/pro/enterprise/sflowdevices_stats.lua',
},
{
entry = page_utils.menu_entries.flow_exporters,
url = '/lua/pro/enterprise/flowdevices_stats.lua',
},
},
}
)
end
-- ##############################################
-- Interface
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.if_stats,
hidden = is_system_interface,
url = "/lua/if_stats.lua",
}
)
-- ##############################################
-- System Health
local health_entries = {
{
entry = page_utils.menu_entries.system_status,
url = '/lua/system_stats.lua',
},
{
entry = page_utils.menu_entries.interfaces_status,
url = '/lua/system_interfaces_stats.lua',
},
{
entry = page_utils.menu_entries.alerts_status,
url = '/lua/system_alerts_stats.lua',
},
}
-- Add plugin entries relative to system health (e.g., redis) ...
for k, entry in pairsByField(page_utils.plugins_menu, "sort_order", rev) do
-- NOTE: match on the health key to only pick the right subset of entries
if entry.menu_entry.section == page_utils.menu_sections.health.key then
health_entries[#health_entries + 1] = {
entry = page_utils.menu_entries[entry.menu_entry.key],
url = entry.url,
}
end
end
page_utils.add_menubar_section({
hidden = not is_system_interface,
section = page_utils.menu_sections.health,
entries = health_entries
})
-- ##############################################
-- Pollers (e.g., SNMP, active monitoring)
local poller_entries = {
{
entry = page_utils.menu_entries.infrastructure_dashboard,
hidden = not ntop.isEnterpriseL() or not is_admin,
url = '/lua/pro/enterprise/infrastructure_dashboard.lua'
}
}
-- Add SNMP to the poller entries
poller_entries[#poller_entries + 1] = {
entry = page_utils.menu_entries.snmp,
hidden = not is_system_interface or (not ntop.isEnterpriseM() and not ntop.isnEdgeEnterprise()),
url = "/lua/pro/enterprise/snmpdevices_stats.lua",
}
-- Add plugin entries relative to pollers (e.g., active monitoring) ...
for k, entry in pairsByField(page_utils.plugins_menu, "sort_order", rev) do
if entry.menu_entry.section == page_utils.menu_sections.pollers.key then
poller_entries[#poller_entries + 1] = {
entry = page_utils.menu_entries[entry.menu_entry.key],
url = entry.url,
}
end
end
page_utils.add_menubar_section({
hidden = not is_system_interface,
section = page_utils.menu_sections.pollers,
entries = poller_entries
})
-- ##############################################
-- System
local system_entries = {}
-- Add plugin entries...
for k, entry in pairsByField(page_utils.plugins_menu, "sort_order", rev) do
-- Skip pollers, they've already been set under pollers section
if not entry.menu_entry.section == "pollers" then
system_entries[#system_entries + 1] = {
entry = page_utils.menu_entries[entry.menu_entry.key],
url = entry.url,
}
end
end
-- Possibly add nEdge entries
if is_nedge or is_appliance then
-- Possibly add a divider if system_entries already contain elements
if #system_entries > 0 then
system_entries[#system_entries + 1] = {
entry = page_utils.menu_entries.divider,
hidden = not is_admin,
}
end
end
if is_nedge then
for _, entry in ipairs(
{
{
entry = page_utils.menu_entries.system_setup,
hidden = not is_admin,
url = '/lua/system_setup_ui/interfaces.lua',
},
{
entry = page_utils.menu_entries.dhcp_leases,
hidden = not is_admin or not ntop.isRoutingMode(),
url = '/lua/pro/nedge/admin/dhcp_leases.lua',
},
{
entry = page_utils.menu_entries.port_forwarding,
hidden = not is_admin or not ntop.isRoutingMode(),
url = '/lua/pro/nedge/admin/port_forwarding.lua',
},
}) do
system_entries[#system_entries + 1] = entry
end
end
if is_appliance then
for _, entry in ipairs(
{
{
entry = page_utils.menu_entries.system_setup,
hidden = not is_admin,
url = '/lua/system_setup_ui/mode.lua',
},
}) do
system_entries[#system_entries + 1] = entry
end
end
if #system_entries > 0 then
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.system_stats,
hidden = not isAllowedSystemInterface() or not is_system_interface,
entries = system_entries,
}
)
end
-- ##############################################
-- Pools
page_utils.add_menubar_section({
hidden = not is_system_interface,
section = page_utils.menu_sections.pools,
entries = {
{
entry = page_utils.menu_entries.manage_pools,
hidden = not is_admin,
url = '/lua/admin/manage_pools.lua'
},
{
entry = page_utils.menu_entries.host_members,
hidden = not is_admin,
url = '/lua/admin/manage_host_members.lua',
}
}
})
-- ##############################################
page_utils.add_menubar_section({
section = page_utils.menu_sections.notifications,
hidden = not is_system_interface,
entries = {
{
entry = page_utils.menu_entries.endpoint_notifications,
hidden = not is_admin,
url = '/lua/admin/endpoint_notifications_list.lua',
},
{
entry = page_utils.menu_entries.endpoint_recipients,
hidden = not is_admin,
url = '/lua/admin/recipients_list.lua',
}
}
})
-- ##############################################
-- Admin
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.admin,
hidden = not is_admin,
entries = {
{
entry = page_utils.menu_entries.nedge_users,
hidden = not is_admin or not is_nedge,
url = '/lua/pro/nedge/admin/nf_list_users.lua',
},
{
entry = page_utils.menu_entries.manage_users,
-- Note: 'not _SESSION["localuser"]' indicates that this is an external
-- user (e.g. LDAP), in that case allow users management if fallback is enabled.
hidden = not is_admin or (not _SESSION["localuser"] and not has_local_auth),
url = '/lua/admin/users.lua',
},
{
entry = page_utils.menu_entries.preferences,
hidden = not is_admin,
url = '/lua/admin/prefs.lua',
},
{
entry = page_utils.menu_entries.scripts_config,
section = page_utils.menu_sections.user_scripts,
hidden = not is_admin,
url = '/lua/admin/edit_configset.lua?subdir=host',
},
{
entry = page_utils.menu_entries.license,
hidden = info["pro.forced_community"],
url = '/lua/license.lua',
},
{
entry = page_utils.menu_entries.divider,
},
{
entry = page_utils.menu_entries.manage_configurations,
hidden = not is_admin or is_windows,
url = '/lua/admin/manage_configurations.lua',
},
{
entry = page_utils.menu_entries.manage_data,
hidden = not is_admin,
url = '/lua/manage_data.lua',
},
{
entry = page_utils.menu_entries.divider,
},
{
entry = page_utils.menu_entries.profiles,
hidden = not is_admin or not ntop.isPro() or is_nedge,
url = '/lua/pro/admin/edit_profiles.lua',
},
{
entry = page_utils.menu_entries.categories,
hidden = not is_admin,
url = '/lua/admin/edit_categories.lua',
},
{
entry = page_utils.menu_entries.category_lists,
hidden = not is_admin,
url = '/lua/admin/edit_category_lists.lua',
},
{
entry = page_utils.menu_entries.device_protocols,
hidden = not is_admin,
url = '/lua/admin/edit_device_protocols.lua',
},
},
}
)
-- ##############################################
-- Developer
if not info.oem and auth.has_capability(auth.capabilities.developer) then
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.dev,
entries = {
{
entry = page_utils.menu_entries.plugins,
url = '/lua/plugins_overview.lua',
},
{
entry = page_utils.menu_entries.user_scripts_dev,
url = '/lua/user_scripts_overview.lua',
},
{
entry = page_utils.menu_entries.alert_definitions,
url = '/lua/defs_overview.lua',
},
{
entry = page_utils.menu_entries.directories,
url = '/lua/directories.lua',
},
{
entry = page_utils.menu_entries.api,
url = 'https://www.ntop.org/guides/ntopng/api/',
},
},
}
)
end
-- ##############################################
-- About
page_utils.add_menubar_section(
{
section = page_utils.menu_sections.about,
hidden = info.oem,
entries = {
{
entry = page_utils.menu_entries.about,
url = '/lua/about.lua',
},
{
entry = page_utils.menu_entries.telemetry,
url = '/lua/telemetry.lua',
},
{
entry = page_utils.menu_entries.blog,
url = 'http://blog.ntop.org/',
},
{
entry = page_utils.menu_entries.telegram,
url = 'https://t.me/ntop_community',
},
{
entry = page_utils.menu_entries.manual,
url = 'https://www.ntop.org/guides/ntopng/',
},
{
entry = page_utils.menu_entries.divider
},
{
entry = page_utils.menu_entries.report_issue,
url = 'https://github.com/ntop/ntopng/issues',
},
{
entry = page_utils.menu_entries.suggest_feature,
url = 'https://www.ntop.org/support/need-help-2/contact-us/',
}
},
}
)
-- ##############################################
page_utils.print_menubar()
-- ##############################################
-- Interface
if(num_ifaces > 0) then
url = ntop.getHttpPrefix().."/lua/if_stats.lua"
-- ##############################################
-- Updates submenu
if updates_supported then
-- Updates check
print[[
<script type='text/javascript'>
$('#updates-info-li').html(']] print(i18n("updates.checking")) print[[');
$('#updates-install-li').hide();
const updates_csrf = ']] print(ntop.getRandomCSRFValue()) print[[';
/* Install latest update */
var installUpdate = function() {
if (confirm(']] print(i18n("updates.install_confirm"))
if info["pro.license_days_left"] ~= nil and info["pro.license_days_left"] <= 0 then
-- License is valid, however maintenance is expired: warning the user
print(" "..i18n("updates.maintenance_expired"))
end
print[[')) {
$.ajax({
type: 'POST',
url: ']] print (ntop.getHttpPrefix()) print [[/lua/install_update.lua',
data: {
csrf: updates_csrf
},
success: function(rsp) {
$('#updates-info-li').html(']] print(i18n("updates.installing")) print[[')
$('#updates-install-li').hide();
$('#admin-badge').hide();
}
});
}
}
/* Check for new updates */
var checkForUpdates = function() {
$.ajax({
type: 'POST',
url: ']] print (ntop.getHttpPrefix()) print [[/lua/check_update.lua',
data: {
csrf: updates_csrf,
search: 'true'
},
success: function(rsp) {
$('#updates-info-li').html(']] print(i18n("updates.checking")) print[[');
$('#updates-install-li').hide();
$('#admin-badge').hide();
}
});
}
/* Update the menu with the current updates status */
var updatesRefresh = function() {
$.ajax({
type: 'GET',
url: ']] print (ntop.getHttpPrefix()) print [[/lua/check_update.lua',
data: {},
success: function(rsp) {
if(rsp && rsp.status) {
if (rsp.status == 'installing') {
$('#updates-info-li').html(']] print(i18n("updates.installing")) print[[')
$('#updates-info-li').attr('title', '');
$('#updates-install-li').hide();
$('#admin-badge').hide();
} else if (rsp.status == 'checking') {
$('#updates-info-li').html(']] print(i18n("updates.checking")) print[[');
$('#updates-info-li').attr('title', '');
$('#updates-install-li').hide();
$('#admin-badge').hide();
} else if (rsp.status == 'update-avail' || rsp.status == 'upgrade-failure') {
$('#updates-info-li').html('<span class="badge badge-pill badge-danger">]] print(i18n("updates.available")) print[[</span> ]] print(info["product"]) print[[ ' + rsp.version);
$('#updates-info-li').attr('title', '');
var icon = '<i class="fas fa-download"></i>';
$('#updates-install-li').attr('title', '');
if (rsp.status !== 'update-avail') {
icon = '<i class="fas fa-exclamation-triangle text-danger"></i>';
$('#updates-install-li').attr('title', "]] print(i18n("updates.update_failure_message")) print [[: " + rsp.status);
}
$('#updates-install-li').html(icon + " ]] print(i18n("updates.install")) print[[");
$('#updates-install-li').show();
$('#updates-install-li').off("click");
$('#updates-install-li').click(installUpdate);
if (rsp.status !== 'update-avail') $('#admin-badge').html('!');
else $('#admin-badge').html('1');
$('#admin-badge').show();
} else /* (rsp.status == 'not-avail' || rsp.status == 'update-failure' || rsp.status == <other errors>) */ {
var icon = '';
$('#updates-info-li').attr('title', '');
if (rsp.status !== 'not-avail') {
icon = '<i class="fas fa-exclamation-triangle text-danger"></i> ';
$('#updates-info-li').attr('title', "]] print(i18n("updates.update_failure_message")) print [[: " + rsp.status);
}
$('#updates-info-li').html(icon + ']] print(i18n("updates.no_updates")) print[[');
$('#updates-install-li').html("<i class='fas fa-sync'></i> ]] print(i18n("updates.check")) print[[");
$('#updates-install-li').show();
$('#updates-install-li').off("click");
$('#updates-install-li').click(checkForUpdates);
$('#admin-badge').hide();
}
}
}
});
}
updatesRefresh();
setInterval(updatesRefresh, 10000);
</script>
]]
end
end -- num_ifaces > 0
-- ##############################################
print([[
<nav class="navbar navbar-expand-md navbar-expand-lg fixed-top navbar-light justify-content-between" id='n-navbar'>
<ul class='navbar-nav flex-row flex-wrap'>
<li class='nav-item'>
<button class='btn btn-outline-dark border-0 btn-sidebar' data-toggle='sidebar'>
<i class="fas fa-bars"></i>
</button>
</li>
]])
-- ##############################################
-- Interfaces Selector
local views = {}
local drops = {}
local recording = {}
local packetinterfaces = {}
local pcapdump = {}
local ifnames = {}
local iftype = {}
local ifHdescr = {}
local ifCustom = {}
local dynamic = {}
local action_urls = {}
for v,k in pairs(iface_names) do
interface.select(k)
local _ifstats = interface.getStats()
ifnames[_ifstats.id] = k
action_urls[_ifstats.id] = page_utils.switch_interface_form_action_url(_ifstats.id, _ifstats.type)
--io.write("["..k.."/"..v.."][".._ifstats.id.."] "..ifnames[_ifstats.id].."=".._ifstats.id.."\n")
if interface.isPcapDumpInterface() then pcapdump[k] = true end
if(_ifstats.isView == true) then views[k] = true end
if(_ifstats.isDynamic == true) then dynamic[k] = true end
if(recording_utils.isEnabled(_ifstats.id)) then recording[k] = true end
if(interface.isPacketInterface()) then packetinterfaces[k] = true end
if(_ifstats.stats_since_reset.drops * 100 > _ifstats.stats_since_reset.packets) then
drops[k] = true
end
ifCustom[_ifstats.id] = _ifstats.customIftype
local descr = getHumanReadableInterfaceName(v)
if ntop.isWindows() and string.contains(descr, "{") then -- Windows
descr = _ifstats.description
elseif ntop.isEnterpriseM() and _ifstats.isDynamic and _ifstats.dynamic_interface_probe_ip then
-- Attempt at printing SNMP information rather than plain disaggregated IPs
local snmp_utils = require "snmp_utils"
local snmp_cached_dev = require "snmp_cached_dev"
local cached_device = snmp_cached_dev:create(_ifstats.dynamic_interface_probe_ip)
local snmp_name, snmp_if_name
if cached_device then
-- See if there is a name for this exporter in SNMP
if cached_device.system and cached_device.system.name then
snmp_name = cached_device.system.name
-- Now check for the existance of the interface name
if _ifstats.dynamic_interface_inifidx then
if cached_device.interfaces and cached_device.interfaces[tostring(_ifstats.dynamic_interface_inifidx)] then
snmp_if_name = snmp_utils.get_snmp_interface_label(cached_device.interfaces[tostring(_ifstats.dynamic_interface_inifidx)], true)
else
snmp_if_name = _ifstats.dynamic_interface_inifidx
end
end
end
end
if snmp_name then
-- Something has been found in SNMP
local fmt = ""
if snmp_if_name then
-- There's the interface name as well
fmt = string.format("%s [%s]", snmp_name, snmp_if_name)
else
-- Only the device name
fmt = string.format("%s", snmp_name)
end
if descr ~= _ifstats.description then
-- There's a custom alias
descr = string.format("%s (%s)", descr, fmt)
else
descr = fmt
end
end
else
if descr ~= _ifstats.description and not views[k] and not pcapdump[k] then
if descr == shortenCollapse(_ifstats.description) then
descr = _ifstats.description
else
descr = descr .. " (".. _ifstats.description ..")" -- Add description
end
end
end
-- tprint({k, dynamic[k], _ifstats.dynamic_interface_probe_ip, _ifstats.dynamic_interface_inifidx})
ifHdescr[_ifstats.id] = descr
end
interface.select(ifs.id.."")
local context = {
ifnames = ifnames,
views = views,
dynamic = dynamic,
recording = recording,
pcapdump = pcapdump,
packetinterfaces = packetinterfaces,
drops = drops,
ifHdescr = ifHdescr,
ifCustom = ifCustom,
action_urls = action_urls,
is_system_interface = is_system_interface,
}
print(template_utils.gen("pages/components/ifaces-dropdown.template", context))
-- ##############################################
-- Up/Down info
if not is_pcap_dump and not is_system_interface then
print([[
<li class='nav-item d-none d-sm-done d-md-flex d-lg-flex ml-2'>
<div class='info-stats'>
]].. page_utils.generate_info_stats() ..[[
</div>
</li>
]])
end
-- License Badge
local info = ntop.getInfo(true)
if (_POST["ntopng_license"] == nil) and (info["pro.systemid"] and (info["pro.systemid"] ~= "")) then
if (info["pro.release"]) then
if (info["pro.demo_ends_at"] ~= nil) then
local rest = info["pro.demo_ends_at"] - os.time()
if (rest > 0) then
print('<li class="nav-item nav-link"><a href="https://shop.ntop.org"><span class="badge badge-warning">')
print(" " .. i18n("about.licence_expires_in", {time=secondsToTime(rest)}))
print('</span></a></li>')
end
end
else
if(not(ntop.getInfo()["pro.forced_community"])) then
print('<li class="nav-item nav-link"><a href="https://shop.ntop.org"><span class="badge badge-warning">')
print(i18n("about.upgrade_to_professional")..' <i class="fas fa-external-link-alt"></i>')
print('</span></a></li>')
end
end
end
-- ########################################
-- Network Load
print([[
<li class="network-load d-none d-lg-inline"></li>
]])
-- ########################################
-- end of navbar-nav
print('</ul>')
print([[
<ul class='navbar-nav flex-row ml-auto'>
]])
-- ########################################
-- Searchbox hosts
-- append searchbox
if (not is_system_interface) then
print("<li class='nav-item'>")
print(
template.gen("typeahead_input.html", {
typeahead={
base_id = "host_search",
action = "", -- see makeFindHostBeforeSubmitCallback
json_key = "ip",
query_field = "host",
class = "typeahead-dropdown-right",
query_url = ntop.getHttpPrefix() .. "/lua/find_host.lua",
query_title = i18n("search_host"),
style = "width: 16em;",
before_submit = [[NtopUtils.makeFindHostBeforeSubmitCallback("]] .. ntop.getHttpPrefix() .. [[")]],
max_items = "'all'" --[[ let source script decide ]],
parameters = { ifid = ternary(is_system_interface, getSystemInterfaceId(), ifId) },
}
})
)
print("</li>")
end
-- #########################################
-- User Navbar Menu
-- Render Blog Notifications
if (not info.oem) then
local username = _SESSION["user"] or ''
if (isNoLoginUser()) then username = 'no_login' end
local posts, new_posts_counter = blog_utils.readPostsFromRedis(username)
print([[
<li class="nav-item">
<a id="notification-list" href="#" class="nav-link dropdown-toggle mx-2 dark-gray position-relative" data-toggle="dropdown">
<i class='fas fa-bell'></i>
]])
if((new_posts_counter ~= nil) and (new_posts_counter > 0)) then
print([[<span class="badge notification-bell badge-pill badge-danger">]].. new_posts_counter ..[[</span>]])
end
print([[
</a>
<div class="dropdown-menu dropdown-menu-right p-1">
<div class="blog-section">
<span class="dropdown-header p-2 mb-0">]].. i18n("blog_feed.news_from_blog") ..[[</span>
<ul class="list-unstyled">]])
if (posts ~= nil) then
for _, p in pairs(posts) do
local user_has_read_post = not (p.users_read[username] == nil)
local post_date = os.date("%x", p.epoch)
local post_title = p.title or ''
if (string.len(post_title)) then
post_title = string.sub(p.title, 1, 48) .. "..."
end
print([[
<li class='media-body pt-2 pr-2 pl-2 pb-1'>
<a target="_about"
class="blog-notification text-dark"
data-read="]].. (user_has_read_post and "true" or "false") ..[["
data-id="]].. p.id ..[["
class='text-dark'
href="]].. (p.link or '/') ..[[">
<h6 class='mt-0 mb-1'>
]].. ((not user_has_read_post) and "<span class='badge badge-primary'>".. i18n('new') .."</span>" or '') ..[[
]].. post_title ..[[
<i class='fas fa-external-link-alt float-right ml-1'></i>
</h6>
<p class='mb-0'>
]].. (p.shortDesc) ..[[]
</p>
<small>
]].. i18n('posted') .. " " .. post_date ..[[
</small>
</a>
</li>
]])
end
else
print([[<li class="text-muted p-2">]].. i18n("blog_feed.nothing_to_show") ..[[</li>]])
end
print([[
</ul>
</div>
</div>
</li>]])
end
local session_user = _SESSION['user']
local is_no_login_user = isNoLoginUser()
print([[
<li class="nav-item">
<a href='#' class="nav-link dropdown-toggle mx-2 dark-gray" data-toggle="dropdown">
<i class='fas fa-user'></i>
</a>
<ul class="dropdown-menu dropdown-menu-right">]])
if (not _SESSION["localuser"] or not is_admin) and (not is_no_login_user) then
print[[
<a class="dropdown-item" href='#password_dialog' data-toggle='modal'>
<i class='fas fa-user'></i> ]] print(i18n("manage_users.manage_user_x", {user = _SESSION["user"]})) print[[
</a>
]]
else
if (not is_no_login_user) then
print([[<a class='dropdown-item' href=']].. ntop.getHttpPrefix() ..[[/lua/admin/users.lua?user=]].. session_user:gsub("%.", "\\\\\\\\.") ..[['><i class='fas fa-user'></i> ]].. session_user ..[[</a>]])
else
print([[<li class='dropdown-item disabled'>]])
print([[<i class='fas fa-user'></i> ]].. session_user ..[[]])
print([[</li>]])
end
end
-- Render nendge services
if is_nedge and is_admin then
print([[
<li class="dropdown-divider"></li>
<li class="dropdown-header">]] .. i18n("nedge.product_status", {product=info.product}) .. [[</li>
<li>
<a class="dropdown-item" href="#poweroff_dialog" data-toggle="modal">
<i class="fas fa-power-off"></i> ]]..i18n("nedge.power_off")..[[
</a>
</li>
<li>
<a class="dropdown-item" href="#reboot_dialog" data-toggle="modal">
<i class="fas fa-redo"></i> ]]..i18n("nedge.reboot")..[[
</a>
</li>
]])
end
-- Render Update Menu
if updates_supported then
print([[
<li class="dropdown-divider"></li>
<li class="dropdown-header" id="updates-info-li">]] .. i18n("updates.no_updates") .. [[.</li>
<li><button class="dropdown-item" id="updates-install-li"><i class="fas fa-sync"></i> ]] .. (i18n("updates.check")) ..[[</button></li>
]])
end
-- Rende Toggle Dark theme menu button
if is_admin then
print([[
<li class='dropdown-divider'></li>
<a class='dropdown-item toggle-dark-theme' href='#'><i class="fas fa-adjust"></i> ]].. i18n("toggle_dark_theme") ..[[</a>
]])
end
-- Logout
if(_SESSION["user"] ~= nil and (not is_no_login_user)) then
print[[
<li class='dropdown-divider'></li>
<li class="nav-item">
<a class="dropdown-item" href="]]
print(ntop.getHttpPrefix())
print [[/lua/logout.lua" onclick="return confirm(']] print(i18n("login.logout_message")) print [[')"><i class="fas fa-sign-out-alt"></i> ]] print(i18n("login.logout")) print[[</a></li>]]
end
-- Restart menu, the restart JS code can be found inside footer.lua
if(is_admin and ntop.isPackage() and not ntop.isWindows()) then
print [[
<li class="dropdown-divider"></li>
<li class="nav-item"><a class="dropdown-item restart-service" href="#"><i class="fas fa-redo-alt"></i> ]] print(i18n("restart.restart")) print[[</a></li>
]]
end
print([[
</ul>
</li>
</ul>
</nav>
]])
-- begging of #n-container
print([[<main id='n-container' class='px-md-4 px-sm-1'>]])
-- ###################################################
-- Render toasts
toasts_manager.render_toasts("main-container", toasts_manager.load_main_toasts())
-- ###################################################
print("<div class='main-alerts'>")
-- Hidden by default, will be shown by the footer if necessary
print('<div id="influxdb-error-msg" class="alert alert-danger" style="display:none" role="alert"><i class="fas fa-exclamation-triangle fa-lg" id="alerts-menu-triangle"></i> <span id="influxdb-error-msg-text"></span>')
print[[<button type="button" class="close" data-dismiss="alert" aria-label="Close"><span aria-hidden="true">&times;</span></button>]]
print('</div>')
-- Hidden by default, will be shown by the footer if necessary
print('<div id="major-release-alert" class="alert alert-info" style="display:none" role="alert"><i class="fas fa-cloud-download-alt" id="alerts-menu-triangle"></i> <span id="ntopng_update_available"></span>')
print('</div>')
-- Hidden by default, will be shown by the footer if necessary
print('<div id="move-rrd-to-influxdb" class="alert alert-warning" style="display:none" role="alert"><i class="fas fa-exclamation-triangle fa-lg" id="alerts-menu-triangle"></i> ')
print[[<button type="button" class="close" data-dismiss="alert" aria-label="Close"><span aria-hidden="true">&times;</span></button>]]
print(i18n("alert_messages.influxdb_migration_msg", {url="https://www.ntop.org/ntopng/ntopng-and-time-series-from-rrd-to-influxdb-new-charts-with-time-shift/"}))
print('</div>')
if(_SESSION["INVALID_CSRF"]) then
print('<div id="move-rrd-to-influxdb" class="alert alert-warning" role="alert"><i class="fas fa-exclamation-triangle fa-lg" id="alerts-menu-triangle"></i> ')
print[[<button type="button" class="close" data-dismiss="alert" aria-label="Close"><span aria-hidden="true">&times;</span></button>]]
print(i18n("expired_csrf"))
print('</div>')
end
-- end of main alerts
print("</div>")
-- append password change modal
if(not is_admin) then
dofile(dirs.installdir .. "/scripts/lua/inc/password_dialog.lua")
end