mirror of
https://github.com/ntop/ntopng.git
synced 2026-07-23 06:36:57 +00:00
86 lines
2.4 KiB
Lua
86 lines
2.4 KiB
Lua
--
|
|
-- (C) 2013-26 - ntop.org
|
|
--
|
|
|
|
local dirs = ntop.getDirs()
|
|
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
|
|
require "lua_utils"
|
|
local json = require("dkjson")
|
|
local recording_utils = require "recording_utils"
|
|
local rest_utils = require("rest_utils")
|
|
|
|
--
|
|
-- Run a traffic extraction
|
|
-- Example: curl -u admin:admin -H "Content-Type: application/json" -d '{"ifid": "1", "epoch_begin": 1589822000, "epoch_end": 15898221000, "bpf_filter": "" }' http://localhost:3000/lua/rest/v2/get/pcap/live_extraction.lua
|
|
--
|
|
-- NOTE: in case of invalid login, no error is returned but redirected to login
|
|
--
|
|
|
|
local ifid = _GET["ifid"]
|
|
local filter = _GET["bpf_filter"]
|
|
local time_from = tonumber(_GET["epoch_begin"])
|
|
local time_to = tonumber(_GET["epoch_end"])
|
|
|
|
local rc = rest_utils.consts.success.ok
|
|
|
|
if not recording_utils.isExtractionAvailable() then
|
|
rc = rest_utils.consts.err.not_granted
|
|
rest_utils.answer(rc)
|
|
return
|
|
end
|
|
|
|
if isEmptyString(ifid) then
|
|
rc = rest_utils.consts.err.invalid_interface
|
|
rest_utils.answer(rc)
|
|
return
|
|
end
|
|
|
|
if _GET["epoch_begin"] == nil or _GET["epoch_end"] == nil then
|
|
rc = rest_utils.consts.err.invalid_arguments
|
|
rest_utils.answer(rc)
|
|
return
|
|
end
|
|
|
|
interface.select(ifid)
|
|
|
|
ifid = tonumber(ifid)
|
|
|
|
if filter == nil then
|
|
filter = ""
|
|
end
|
|
|
|
local ifstats = interface.getStats()
|
|
local timeline_path
|
|
|
|
if ifstats.isView then
|
|
-- View: return a comma-separated list of timelines from all viewed interfaces
|
|
-- that have recording enabled and data in the interval
|
|
local viewed_ifaces = recording_utils.getViewedInterfacesWithRecording(ifstats.id)
|
|
|
|
if table.empty(viewed_ifaces) then
|
|
rest_utils.answer(rest_utils.consts.err.not_granted)
|
|
return
|
|
end
|
|
|
|
local paths = {}
|
|
for _, iface in ipairs(viewed_ifaces) do
|
|
local tl = recording_utils.getTimelineByInterval(iface.ifid, time_from, time_to)
|
|
if tl then
|
|
table.insert(paths, tl)
|
|
end
|
|
end
|
|
|
|
if #paths == 0 then
|
|
rest_utils.answer(rest_utils.consts.err.bad_content)
|
|
return
|
|
end
|
|
|
|
timeline_path = table.concat(paths, ",")
|
|
else
|
|
timeline_path = recording_utils.getTimelineByInterval(ifid, time_from, time_to)
|
|
end
|
|
|
|
local fname = time_from.."-"..time_to..".pcap"
|
|
sendHTTPContentTypeHeader('application/vnd.tcpdump.pcap', 'attachment; filename="'..fname..'"')
|
|
|
|
ntop.runLiveExtraction(ifid, time_from, time_to, filter, timeline_path)
|