diff --git a/scripts/lua/get_flow_db_data.lua b/scripts/lua/get_flow_db_data.lua deleted file mode 100644 index 9411d4d510..0000000000 --- a/scripts/lua/get_flow_db_data.lua +++ /dev/null @@ -1,30 +0,0 @@ --- --- (C) 2013-23 - ntop.org --- - -local dirs = ntop.getDirs() -package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path - -if ntop.isPro() then - package.path = dirs.installdir .. "/pro/scripts/lua/modules/?.lua;" .. package.path -end - -require "lua_utils" -local json = require("dkjson") -local flow_dbms = require("flow_dbms"):new() - -local ifid = getInterfaceId(ifname) - -local now = os.time() -local ago_1h = now - 3600 - -local filter = {epoch_begin = ago_1h, epoch_end = now, offset = 0, limit = 10} - -sendHTTPHeader('application/json') - -local topk_host = flow_dbms:queryTopk(ifid, "host", filter) -local topk_port = flow_dbms:queryTopk(ifid, "port", filter) - -local res = {topk_host = topk_host, topk_port = topk_port} - -print(json.encode(res)) diff --git a/scripts/lua/modules/flow_dbms/drivers/mysql.lua b/scripts/lua/modules/flow_dbms/drivers/mysql.lua deleted file mode 100644 index 8ebd503a0a..0000000000 --- a/scripts/lua/modules/flow_dbms/drivers/mysql.lua +++ /dev/null @@ -1,21 +0,0 @@ --- --- (C) 2021 - ntop.org --- - -local driver = {} - -function driver:new(options) - local obj = {} - - setmetatable(obj, self) - self.__index = self - return obj -end - -function driver:topk(ifid, what_k, filter) - local res = {} - - return res -end - -return driver diff --git a/scripts/lua/modules/flow_dbms/drivers/nindex.lua b/scripts/lua/modules/flow_dbms/drivers/nindex.lua deleted file mode 100644 index c27c0c3dd7..0000000000 --- a/scripts/lua/modules/flow_dbms/drivers/nindex.lua +++ /dev/null @@ -1,21 +0,0 @@ --- --- (C) 2021 - ntop.org --- - -local driver = {} -function driver:new(options) - local obj = {} - - setmetatable(obj, self) - self.__index = self - - return obj -end - -function driver:topk(ifid, what_k, filter) - local res = {} - - return res -end - -return driver diff --git a/scripts/lua/modules/flow_dbms/flow_dbms.lua b/scripts/lua/modules/flow_dbms/flow_dbms.lua deleted file mode 100644 index 9aa6f830d7..0000000000 --- a/scripts/lua/modules/flow_dbms/flow_dbms.lua +++ /dev/null @@ -1,50 +0,0 @@ --- --- (C) 2021 - ntop.org --- - -local dirs = ntop.getDirs() -package.path = dirs.installdir .. "/scripts/lua/modules/flow_dbms/drivers/?.lua;" .. package.path -local flow_dbms = {} -local driver - -local available_tops = {"host", "src_host", "dst_host", - "port", "src_port", "dst_port", - "conversations"} - -local function checkTop(what_k) - for _, k in pairs(available_tops) do - if k == what_k then return true end - end - - return false -end - -function flow_dbms:new() - if ntop.getPrefs().is_dump_flows_to_mysql_enabled == true then - driver = require("mysql"):new() - else --[[ if nindex is enabled... --]] - end - - local obj = { - driver = driver - } - - setmetatable(obj, self) - self.__index = self - - return obj -end - -function flow_dbms:queryTopk(ifid, what_k, filter) - if not driver then - return {} -- TODO: handle error - end - - if not checkTop(what_k) then - return {} -- TODO: handle error - end - - return driver:topk(ifid, what_k, filter) -end - -return flow_dbms