--
-- (C) 2013-26 - ntop.org
--

local dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.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 page_utils = require("page_utils")
local script_manager = require("script_manager")
local internals_utils = require("internals_utils")
local cpu_utils = require("cpu_utils")
local ts_utils = require("ts_utils")
local graph_utils = require("graph_utils")
local format_utils = require("format_utils")
local template = require("template_utils")
local json = require("dkjson")

local ts_creation = script_manager.systemTimeseriesEnabled()

if not isAllowedSystemInterface() then
	return
end

sendHTTPContentTypeHeader("text/html")
page_utils.print_header_and_set_active_menu_entry(page_utils.menu_entries.system_status)

dofile(dirs.installdir .. "/scripts/lua/inc/menu.lua")

local page = _GET["page"] or "overview"
local url = ntop.getHttpPrefix() .. "/lua/system_stats.lua?ifid=" .. interface.getId()
local internals_url = ntop.getHttpPrefix()
	.. "/lua/system_stats.lua?ifid="
	.. interface.getId()
	.. "&page=internals&tab=queues"
local title = i18n("system")
local info = ntop.getInfo()

page_utils.print_navbar(title, url, {
	{
		active = page == "overview" or not page,
		page_name = "overview",
		label = '<i class="fas fa-home fa-lg"></i>',
	},
	{
		hidden = not ts_creation,
		active = page == "historical",
		page_name = "historical",
		label = "<i class='fas fa-lg fa-chart-area'></i>",
	},
	{
		active = page == "internals",
		page_name = "internals",
		url = internals_url,
		label = '<i class="fas fa-lg fa-wrench"></i>',
	},
	{
		hidden = not info.ntopcloud,
		active = page == "ntopcloud",
		page_name = "ntopcloud",
		label = '<i class="fas fa-lg fa-cloud"></i>',
	},
})

-- #######################################################

if page == "overview" then
	local storage_utils = require("storage_utils")

	print("<div class='table-responsive-lg table-responsive-md'>")
	print('<table class="table table-bordered table-striped">\n')

	local system_rowspan = 1
	local ntopng_rowspan = 20
	local system_host_stats = cpu_utils.systemHostStats()
	local has_system = false

	if system_host_stats["cpu_load"] ~= nil then
		system_rowspan = system_rowspan + 1
		has_system = true
	end
	if system_host_stats["mem_total"] ~= nil then
		system_rowspan = system_rowspan + 1
		has_system = true
	end
	if system_host_stats["cpu_states"] and system_host_stats["cpu_states"]["iowait"] then
		system_rowspan = system_rowspan + 1
		has_system = true
	end

	if has_system then
		print("<tr><th rowspan=" .. system_rowspan .. " width=5%>" .. i18n("about.system") .. "</th></tr>\n")
	end

	if system_host_stats["cpu_load"] ~= nil then
		local chart_available = ts_utils.exists("system:cpu_load", { ifid = getSystemInterfaceId() })
		print(
			"<tr><th nowrap>"
				.. i18n("about.cpu_load")
				.. " "
				.. ternary(
					chart_available,
					"<A HREF='"
						.. url
						.. "&page=historical&ts_schema=system:cpu_load'><i class='fas fa-chart-area fa-sm'></i></A>",
					""
				)
				.. "</th><td><span id='cpu-load-pct'>"
				.. system_host_stats["cpu_load"]
				.. "%</span></td></tr>\n"
		)
	end

	if system_host_stats["cpu_states"] and system_host_stats["cpu_states"]["iowait"] then
		local chart_available = ts_utils.exists("system:cpu_states", { ifid = getSystemInterfaceId() })
		local iowait = i18n("about.iowait")
			.. ": "
			.. round(formatValue(system_host_stats["cpu_states"]["iowait"]), 2)
			.. "%"
		local active = i18n("about.active")
			.. ": "
			.. round(
				formatValue(
					system_host_stats["cpu_states"]["user"]
						+ system_host_stats["cpu_states"]["system"]
						+ system_host_stats["cpu_states"]["nice"]
						+ system_host_stats["cpu_states"]["irq"]
						+ system_host_stats["cpu_states"]["softirq"]
						+ system_host_stats["cpu_states"]["guest"]
						+ system_host_stats["cpu_states"]["guest_nice"]
				),
				2
			)
			.. "%"
		local idle = i18n("about.idle")
			.. ": "
			.. round(formatValue(system_host_stats["cpu_states"]["idle"] + system_host_stats["cpu_states"]["steal"]), 2)
			.. "%"
		print(
			"<tr><th nowrap>"
				.. i18n("about.cpu_states")
				.. " "
				.. ternary(
					chart_available,
					"<A HREF='"
						.. url
						.. "&page=historical&ts_schema=system:cpu_states'><i class='fas fa-chart-area fa-sm'></i></A>",
					""
				)
				.. "</th><td><span id='cpu-states'>"
				.. iowait
				.. " / "
				.. active
				.. " / "
				.. idle
				.. "</span></td></tr>\n"
		)
	end

	if system_host_stats["mem_total"] ~= nil then
		local chart_available = ts_utils.exists("system:memory_used", { ifid = getSystemInterfaceId() })
		local ram_used = system_host_stats["mem_used"]
		local ram_used_ratio = i18n("ram_used")
			.. ": "
			.. tostring(round((ram_used / system_host_stats["mem_total"]) * 100 * 100) / 100)
			.. "%"
		local ram_available = i18n("ram_available")
			.. ": "
			.. format_utils.bytesToSize((system_host_stats["mem_total"] - ram_used) * 1024)
		local ram_total = i18n("ram_total") .. ": " .. format_utils.bytesToSize(system_host_stats["mem_total"] * 1024)

		print(
			"<tr><th nowrap>"
				.. i18n("about.ram_memory")
				.. ternary(
					chart_available,
					" <A HREF='"
						.. url
						.. "&page=historical&ts_schema=system:memory_used'><i class='fas fa-chart-area fa-sm'></i></A>",
					""
				)
				.. "</th><td><span id='ram-used'>"
				.. ram_used_ratio
				.. " / "
				.. ram_available
				.. " / "
				.. ram_total
				.. "</span></td></tr>\n"
		)
	end

	print("<tr><th rowspan=" .. ntopng_rowspan .. ">" .. info["product"] .. "</th>")

	if info.pid ~= nil then
		print("<tr><th nowrap>PID (Process ID)</th><td>" .. info.pid .. "</td></tr>\n")
	end

	if system_host_stats["mem_ntopng_resident"] ~= nil then
		local chart_available = ts_utils.exists("process:resident_memory", { ifid = getSystemInterfaceId() })
		print(
			"<tr><th nowrap>"
				.. i18n("about.ram_memory")
				.. " "
				.. ternary(
					chart_available,
					"<A HREF='"
						.. url
						.. "&page=historical&ts_schema=process:resident_memory'><i class='fas fa-chart-area fa-sm'></i></A>",
					""
				)
				.. "</th><td><span id='ram-process-used'>"
				.. i18n("ram_used")
				.. ": "
				.. format_utils.bytesToSize(system_host_stats["mem_ntopng_resident"] * 1024)
				.. "</span></td></tr>\n"
		)
	end

	if areAlertsEnabled() then
		local chart_available = ts_utils.exists("process:num_alerts", { ifid = getSystemInterfaceId() })
		print(
			"<tr><th nowrap>"
				.. i18n("details.alerts")
				.. " "
				.. ternary(
					chart_available,
					"<A HREF='"
						.. url
						.. "&page=historical&ts_schema=process:num_alerts'><i class='fas fa-chart-area fa-sm'></i></A>",
					""
				)
				.. "</th><td>"
				.. i18n("about.alert_queries")
				.. ": <span id='alerts-queries'>"
				.. round(system_host_stats["alerts_queries"])
				.. "</span> / "
				.. i18n("about.alerts_stored")
				.. ": <span id='stored-alerts'>"
				.. round(system_host_stats["written_alerts"])
				.. "</span> / "
				.. i18n("about.alerts_dropped")
				.. ": <span id='dropped-alerts'>"
				.. round(system_host_stats["dropped_alerts"])
				.. "</span></td></tr>\n"
		)
	end

	print("<tr id='storage-info-tr'><th>" .. i18n("traffic_recording.storage_utilization") .. "</th><td>")
	print("<div id='storage-info'></div>")
	print("</td></tr>")

	print("<tr id='storage-pcap-info-tr'><th>" .. i18n("traffic_recording.storage_utilization_pcap") .. "</th><td>")
	print("<div id='storage-pcap-info'></div>")
	print("</td></tr>")

	if not info.oem then
		print("<tr><th nowrap>" .. i18n("about.last_log"))

		if not ntop.isWindows() and not ntop.isFreeBSD() then
			local days = 1
			print(
				" <A HREF='"
					.. ntop.getHttpPrefix()
					.. "/lua/rest/v2/get/system/logs.lua?days="
					.. days
					.. "'><i class='fas fa-download fa-sm' title='"
					.. i18n("download_days", { days = days })
					.. "'></i></a>"
			)
		end

		print("</th>")
		print("<td><div class='scrollable-log'><code>\n")

		for i = 0, 32 do
			msg = ntop.listIndexCache("ntopng.trace", i)
			if msg ~= nil then
				local text = noHtml(msg)

				-- encapsule the ERROR or WARNING string in a badge
				-- so the log are more visible
				if text:find("ERROR") then
					text = text:gsub("(ERROR)(:)", "<span class='badge bg-danger'>%1</span>")
				elseif text:find("WARNING") then
					text = text:gsub("(WARNING)(:)", "<span class='badge bg-warning'>%1</span>")
				end

				print(text)
				print("<br>")
			end
		end
		print("</code></div></td></tr>\n")
	end

	print("</table>")
	print("</div>")

	print([[
   <script>
   var storageRefresh = function() {
     $.ajax({
       type: 'GET',
       url: ']])
	print(ntop.getHttpPrefix())
	print([[/lua/system_stats_data.lua',
       data: { },
       success: function(rsp) {
	 if(rsp.storage !== undefined) {
	   $('#storage-info').html(rsp.storage);
           $("#storage-info-tr").show();
         }
	 if(rsp.pcap_storage !== undefined) {
	   $('#storage-pcap-info').html(rsp.pcap_storage);
           $("#storage-pcap-info-tr").show();
         }
       }
     });
   }
   $("#storage-info-tr").hide();
   $("#storage-pcap-info-tr").hide();
   storageRefresh();
   </script>
   ]])
elseif page == "historical" and ts_creation then
	graph_utils.drawNewGraphs({ ifid = interface.getId() })
elseif page == "internals" then
	local context = {
		is_sys_iface = true,
		ifid = getSystemInterfaceId(),
		show_hash_tables = false,
		show_periodic_activities = true,
		show_checks = true,
		show_queues = true,
		ts_driver_name = ts_utils.getDriverDisplayName(),
	}

	template.render("pages/vue_page.template", {
		vue_page_name = "PageInternals",
		page_context = json.encode(context),
	})
elseif page == "ntopcloud" then
	local cloud = info.ntopcloud

	if cloud ~= nil then
		local stats = cloud.stats

		print([[
      <div class='table-responsive-lg table-responsive-md'>
      <table class="table table-bordered table-striped">
      ]])

		print("<tr><th>Account Id</th><td nowrap>" .. cloud.account_id .. "</td></tr>\n")
		print("<tr><th>Instance Name</th><td nowrap>" .. cloud.my_topic .. "</td></tr>\n")
		print("<tr><th>Cloud Node</th><td nowrap>" .. cloud.ntopcloud.server .. " [")
		if cloud.ntopcloud.use_tls then
			print("TLS")
		else
			print("PlainText")
		end
		print("]")
		if cloud.ntopcloud.connected then
			print(' <span class="badge text-bg-success">' .. i18n("connected") .. "</span>")
		else
			print(' <span class="badge text-bg-warning">' .. i18n("disconnected") .. "</span>")
		end
		print("</td></tr>\n")
		print("<tr><th colspan=2>Connections</th></tr>\n")
		print(
			"<tr><th>First Connected</th><td nowrap>" .. format_utils.formatEpoch(stats.first_connect) .. "</td></tr>\n"
		)
		print(
			"<tr><th>Last Connected</th><td nowrap>"
				.. format_utils.formatEpoch(stats.last_connect)
				.. " ["
				.. secondsToTime(os.time() - stats.last_connect)
				.. " "
				.. i18n("details.ago")
				.. "]</td></tr>\n"
		)
		print("<tr><th colspan=2>Message Statistics</th></tr>\n")
		print("<tr><th>Connect</th><td nowrap>" .. format_utils.formatValue(stats.num_connect) .. "</td></tr>\n")
		print("<tr><th>Disconnect</th><td nowrap>" .. format_utils.formatValue(stats.num_disconnect) .. "</td></tr>\n")
		print("<tr><th>Ping</th><td nowrap>" .. format_utils.formatValue(stats.num_ping) .. "</td></tr>\n")
		print("<tr><th>Subscribe</th><td nowrap>" .. format_utils.formatValue(stats.num_subscribe) .. "</td></tr>\n")
		print("<tr><th>Errors</th><td nowrap>" .. format_utils.formatValue(stats.num_errors) .. "</td></tr>\n")

		print("</table>\n")
	end
end

-- #######################################################

dofile(dirs.installdir .. "/scripts/lua/inc/footer.lua")