autocore: move functions into luci-base
Signed-off-by: ZiMing Mo <msylgj@immortalwrt.org>
This commit is contained in:
ZiMing Mo
parent
4ac1291457
commit
c7c8ae9b0e
@ -38,7 +38,6 @@ endef
|
|||||||
define Package/autocore/install/Default
|
define Package/autocore/install/Default
|
||||||
$(INSTALL_DIR) $(1)/etc
|
$(INSTALL_DIR) $(1)/etc
|
||||||
$(CP) ./files/generic/10_system.js $(1)/etc/rpcd_10_system.js
|
$(CP) ./files/generic/10_system.js $(1)/etc/rpcd_10_system.js
|
||||||
$(CP) ./files/generic/luci $(1)/etc/rpcd_luci
|
|
||||||
|
|
||||||
$(INSTALL_DIR) $(1)/etc/uci-defaults
|
$(INSTALL_DIR) $(1)/etc/uci-defaults
|
||||||
$(INSTALL_BIN) ./files/generic/090-cover-index_files $(1)/etc/uci-defaults/
|
$(INSTALL_BIN) ./files/generic/090-cover-index_files $(1)/etc/uci-defaults/
|
||||||
|
|||||||
@ -2,8 +2,6 @@
|
|||||||
|
|
||||||
[ ! -f '/etc/rpcd_10_system.js' ] || \
|
[ ! -f '/etc/rpcd_10_system.js' ] || \
|
||||||
mv -f '/etc/rpcd_10_system.js' '/www/luci-static/resources/view/status/include/10_system.js'
|
mv -f '/etc/rpcd_10_system.js' '/www/luci-static/resources/view/status/include/10_system.js'
|
||||||
[ ! -f '/etc/rpcd_luci' ] || \
|
|
||||||
mv -f '/etc/rpcd_luci' '/usr/libexec/rpcd/luci'
|
|
||||||
/etc/init.d/rpcd restart
|
/etc/init.d/rpcd restart
|
||||||
|
|
||||||
exit 0
|
exit 0
|
||||||
|
|||||||
@ -1,748 +0,0 @@
|
|||||||
#!/usr/bin/env lua
|
|
||||||
|
|
||||||
local json = require "luci.jsonc"
|
|
||||||
local fs = require "nixio.fs"
|
|
||||||
|
|
||||||
local function readfile(path)
|
|
||||||
local s = fs.readfile(path)
|
|
||||||
return s and (s:gsub("^%s+", ""):gsub("%s+$", ""))
|
|
||||||
end
|
|
||||||
|
|
||||||
local methods = {
|
|
||||||
getInitList = {
|
|
||||||
args = { name = "name" },
|
|
||||||
call = function(args)
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local _, name, scripts = nil, nil, {}
|
|
||||||
for _, name in ipairs(args.name and { args.name } or sys.init.names()) do
|
|
||||||
local index = sys.init.index(name)
|
|
||||||
if index then
|
|
||||||
scripts[name] = { index = index, enabled = sys.init.enabled(name) }
|
|
||||||
else
|
|
||||||
return { error = "No such init script" }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
return scripts
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
setInitAction = {
|
|
||||||
args = { name = "name", action = "action" },
|
|
||||||
call = function(args)
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
if type(sys.init[args.action]) ~= "function" then
|
|
||||||
return { error = "Invalid action" }
|
|
||||||
end
|
|
||||||
return { result = sys.init[args.action](args.name) }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getLocaltime = {
|
|
||||||
call = function(args)
|
|
||||||
return { result = os.time() }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
setLocaltime = {
|
|
||||||
args = { localtime = 0 },
|
|
||||||
call = function(args)
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local date = os.date("*t", args.localtime)
|
|
||||||
if date then
|
|
||||||
sys.call("date -s '%04d-%02d-%02d %02d:%02d:%02d' >/dev/null" %{ date.year, date.month, date.day, date.hour, date.min, date.sec })
|
|
||||||
sys.call("/etc/init.d/sysfixtime restart >/dev/null")
|
|
||||||
end
|
|
||||||
return { result = args.localtime }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getTimezones = {
|
|
||||||
call = function(args)
|
|
||||||
local util = require "luci.util"
|
|
||||||
local zones = require "luci.sys.zoneinfo"
|
|
||||||
|
|
||||||
local tz = readfile("/etc/TZ")
|
|
||||||
local res = util.ubus("uci", "get", {
|
|
||||||
config = "system",
|
|
||||||
section = "@system[0]",
|
|
||||||
option = "zonename"
|
|
||||||
})
|
|
||||||
|
|
||||||
local result = {}
|
|
||||||
local _, zone
|
|
||||||
for _, zone in ipairs(zones.TZ) do
|
|
||||||
result[zone[1]] = {
|
|
||||||
tzstring = zone[2],
|
|
||||||
active = (res and res.value == zone[1]) and true or nil
|
|
||||||
}
|
|
||||||
end
|
|
||||||
return result
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getLEDs = {
|
|
||||||
call = function()
|
|
||||||
local iter = fs.dir("/sys/class/leds")
|
|
||||||
local result = { }
|
|
||||||
|
|
||||||
if iter then
|
|
||||||
local led
|
|
||||||
for led in iter do
|
|
||||||
local m, s
|
|
||||||
|
|
||||||
result[led] = { triggers = {} }
|
|
||||||
|
|
||||||
s = readfile("/sys/class/leds/"..led.."/trigger")
|
|
||||||
for s in (s or ""):gmatch("%S+") do
|
|
||||||
m = s:match("^%[(.+)%]$")
|
|
||||||
result[led].triggers[#result[led].triggers+1] = m or s
|
|
||||||
result[led].active_trigger = m or result[led].active_trigger
|
|
||||||
end
|
|
||||||
|
|
||||||
s = readfile("/sys/class/leds/"..led.."/brightness")
|
|
||||||
if s then
|
|
||||||
result[led].brightness = tonumber(s)
|
|
||||||
end
|
|
||||||
|
|
||||||
s = readfile("/sys/class/leds/"..led.."/max_brightness")
|
|
||||||
if s then
|
|
||||||
result[led].max_brightness = tonumber(s)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
return result
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getUSBDevices = {
|
|
||||||
call = function()
|
|
||||||
local fs = require "nixio.fs"
|
|
||||||
local iter = fs.glob("/sys/bus/usb/devices/[0-9]*/manufacturer")
|
|
||||||
local result = { }
|
|
||||||
|
|
||||||
if iter then
|
|
||||||
result.devices = {}
|
|
||||||
|
|
||||||
local p
|
|
||||||
for p in iter do
|
|
||||||
local id = p:match("/([^/]+)/manufacturer$")
|
|
||||||
|
|
||||||
result.devices[#result.devices+1] = {
|
|
||||||
id = id,
|
|
||||||
vid = readfile("/sys/bus/usb/devices/"..id.."/idVendor"),
|
|
||||||
pid = readfile("/sys/bus/usb/devices/"..id.."/idProduct"),
|
|
||||||
vendor = readfile("/sys/bus/usb/devices/"..id.."/manufacturer"),
|
|
||||||
product = readfile("/sys/bus/usb/devices/"..id.."/product"),
|
|
||||||
speed = tonumber((readfile("/sys/bus/usb/devices/"..id.."/product")))
|
|
||||||
}
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
iter = fs.glob("/sys/bus/usb/devices/*/*-port[0-9]*")
|
|
||||||
|
|
||||||
if iter then
|
|
||||||
result.ports = {}
|
|
||||||
|
|
||||||
local p
|
|
||||||
for p in iter do
|
|
||||||
local port = p:match("([^/]+)$")
|
|
||||||
local link = fs.readlink(p.."/device")
|
|
||||||
|
|
||||||
result.ports[#result.ports+1] = {
|
|
||||||
port = port,
|
|
||||||
device = link and fs.basename(link)
|
|
||||||
}
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
return result
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getConntrackHelpers = {
|
|
||||||
call = function()
|
|
||||||
local ok, fd = pcall(io.open, "/usr/share/fw3/helpers.conf", "r")
|
|
||||||
local rv = {}
|
|
||||||
|
|
||||||
if not (ok and fd) then
|
|
||||||
ok, fd = pcall(io.open, "/usr/share/firewall4/helpers", "r")
|
|
||||||
end
|
|
||||||
|
|
||||||
if ok and fd then
|
|
||||||
local entry
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local line = fd:read("*l")
|
|
||||||
if not line then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
|
|
||||||
if line:match("^%s*config%s") then
|
|
||||||
if entry then
|
|
||||||
rv[#rv+1] = entry
|
|
||||||
end
|
|
||||||
entry = {}
|
|
||||||
else
|
|
||||||
local opt, val = line:match("^%s*option%s+(%S+)%s+(%S.*)$")
|
|
||||||
if opt and val then
|
|
||||||
opt = opt:gsub("^'(.+)'$", "%1"):gsub('^"(.+)"$', "%1")
|
|
||||||
val = val:gsub("^'(.+)'$", "%1"):gsub('^"(.+)"$', "%1")
|
|
||||||
entry[opt] = val
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
if entry then
|
|
||||||
rv[#rv+1] = entry
|
|
||||||
end
|
|
||||||
|
|
||||||
fd:close()
|
|
||||||
end
|
|
||||||
|
|
||||||
return { result = rv }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getFeatures = {
|
|
||||||
call = function()
|
|
||||||
local fs = require "nixio.fs"
|
|
||||||
local rv = {}
|
|
||||||
local ok, fd
|
|
||||||
|
|
||||||
rv.firewall = fs.access("/sbin/fw3")
|
|
||||||
rv.firewall4 = fs.access("/sbin/fw4")
|
|
||||||
rv.opkg = fs.access("/bin/opkg")
|
|
||||||
rv.offloading = fs.access("/sys/module/xt_FLOWOFFLOAD/refcnt") or fs.access("/sys/module/nft_flow_offload/refcnt")
|
|
||||||
rv.br2684ctl = fs.access("/usr/sbin/br2684ctl")
|
|
||||||
rv.swconfig = fs.access("/sbin/swconfig")
|
|
||||||
rv.odhcpd = fs.access("/usr/sbin/odhcpd")
|
|
||||||
rv.zram = fs.access("/sys/class/zram-control")
|
|
||||||
rv.sysntpd = fs.readlink("/usr/sbin/ntpd") and true
|
|
||||||
rv.ipv6 = fs.access("/proc/net/ipv6_route")
|
|
||||||
rv.dropbear = fs.access("/usr/sbin/dropbear")
|
|
||||||
rv.cabundle = fs.access("/etc/ssl/certs/ca-certificates.crt")
|
|
||||||
rv.relayd = fs.access("/usr/sbin/relayd")
|
|
||||||
rv.dsl = fs.access("/sbin/dsl_cpe_control") or fs.access("/sbin/vdsl_cpe_control")
|
|
||||||
|
|
||||||
local wifi_features = { "eap", "11n", "11ac", "11r", "acs", "sae", "owe", "suiteb192", "wep", "wps" }
|
|
||||||
|
|
||||||
if fs.access("/usr/sbin/hostapd") then
|
|
||||||
rv.hostapd = { cli = fs.access("/usr/sbin/hostapd_cli") }
|
|
||||||
|
|
||||||
local _, feature
|
|
||||||
for _, feature in ipairs(wifi_features) do
|
|
||||||
rv.hostapd[feature] =
|
|
||||||
(os.execute(string.format("/usr/sbin/hostapd -v%s >/dev/null 2>/dev/null", feature)) == 0)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
if fs.access("/usr/sbin/wpa_supplicant") then
|
|
||||||
rv.wpasupplicant = { cli = fs.access("/usr/sbin/wpa_cli") }
|
|
||||||
|
|
||||||
local _, feature
|
|
||||||
for _, feature in ipairs(wifi_features) do
|
|
||||||
rv.wpasupplicant[feature] =
|
|
||||||
(os.execute(string.format("/usr/sbin/wpa_supplicant -v%s >/dev/null 2>/dev/null", feature)) == 0)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
ok, fd = pcall(io.popen, "dnsmasq --version 2>/dev/null")
|
|
||||||
if ok then
|
|
||||||
rv.dnsmasq = {}
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local line = fd:read("*l")
|
|
||||||
if not line then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
|
|
||||||
local opts = line:match("^Compile time options: (.+)$")
|
|
||||||
if opts then
|
|
||||||
local opt
|
|
||||||
for opt in opts:gmatch("%S+") do
|
|
||||||
local no = opt:match("^no%-(%S+)$")
|
|
||||||
rv.dnsmasq[string.lower(no or opt)] = not no
|
|
||||||
end
|
|
||||||
break
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
fd:close()
|
|
||||||
end
|
|
||||||
|
|
||||||
ok, fd = pcall(io.popen, "ipset --help 2>/dev/null")
|
|
||||||
if ok then
|
|
||||||
rv.ipset = {}
|
|
||||||
|
|
||||||
local sets = false
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local line = fd:read("*l")
|
|
||||||
if not line then
|
|
||||||
break
|
|
||||||
elseif line:match("^Supported set types:") then
|
|
||||||
sets = true
|
|
||||||
elseif sets then
|
|
||||||
local set, ver = line:match("^%s+(%S+)%s+(%d+)")
|
|
||||||
if set and not rv.ipset[set] then
|
|
||||||
rv.ipset[set] = tonumber(ver)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
fd:close()
|
|
||||||
end
|
|
||||||
|
|
||||||
return rv
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getSwconfigFeatures = {
|
|
||||||
args = { switch = "switch0" },
|
|
||||||
call = function(args)
|
|
||||||
local util = require "luci.util"
|
|
||||||
|
|
||||||
-- Parse some common switch properties from swconfig help output.
|
|
||||||
local swc, err = io.popen("swconfig dev %s help 2>/dev/null" % util.shellquote(args.switch))
|
|
||||||
if swc then
|
|
||||||
local is_port_attr = false
|
|
||||||
local is_vlan_attr = false
|
|
||||||
local rv = {}
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local line = swc:read("*l")
|
|
||||||
if not line then break end
|
|
||||||
|
|
||||||
if line:match("^%s+%-%-vlan") then
|
|
||||||
is_vlan_attr = true
|
|
||||||
|
|
||||||
elseif line:match("^%s+%-%-port") then
|
|
||||||
is_vlan_attr = false
|
|
||||||
is_port_attr = true
|
|
||||||
|
|
||||||
elseif line:match("cpu @") then
|
|
||||||
rv.switch_title = line:match("^switch%d: %w+%((.-)%)")
|
|
||||||
rv.num_vlans = tonumber(line:match("vlans: (%d+)")) or 16
|
|
||||||
rv.min_vid = 1
|
|
||||||
|
|
||||||
elseif line:match(": pvid") or line:match(": tag") or line:match(": vid") then
|
|
||||||
if is_vlan_attr then rv.vid_option = line:match(": (%w+)") end
|
|
||||||
|
|
||||||
elseif line:match(": enable_vlan4k") then
|
|
||||||
rv.vlan4k_option = "enable_vlan4k"
|
|
||||||
|
|
||||||
elseif line:match(": enable_vlan") then
|
|
||||||
rv.vlan_option = "enable_vlan"
|
|
||||||
|
|
||||||
elseif line:match(": enable_learning") then
|
|
||||||
rv.learning_option = "enable_learning"
|
|
||||||
|
|
||||||
elseif line:match(": enable_mirror_rx") then
|
|
||||||
rv.mirror_option = "enable_mirror_rx"
|
|
||||||
|
|
||||||
elseif line:match(": max_length") then
|
|
||||||
rv.jumbo_option = "max_length"
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
swc:close()
|
|
||||||
|
|
||||||
if not next(rv) then
|
|
||||||
return { error = "No such switch" }
|
|
||||||
end
|
|
||||||
|
|
||||||
return rv
|
|
||||||
else
|
|
||||||
return { error = err }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getSwconfigPortState = {
|
|
||||||
args = { switch = "switch0" },
|
|
||||||
call = function(args)
|
|
||||||
local util = require "luci.util"
|
|
||||||
|
|
||||||
local swc, err = io.popen("swconfig dev %s show 2>/dev/null" % util.shellquote(args.switch))
|
|
||||||
if swc then
|
|
||||||
local ports = { }
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local line = swc:read("*l")
|
|
||||||
if not line or (line:match("^VLAN %d+:") and #ports > 0) then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
|
|
||||||
local pnum = line:match("^Port (%d+):$")
|
|
||||||
if pnum then
|
|
||||||
port = {
|
|
||||||
port = tonumber(pnum),
|
|
||||||
duplex = false,
|
|
||||||
speed = 0,
|
|
||||||
link = false,
|
|
||||||
auto = false,
|
|
||||||
rxflow = false,
|
|
||||||
txflow = false
|
|
||||||
}
|
|
||||||
|
|
||||||
ports[#ports+1] = port
|
|
||||||
end
|
|
||||||
|
|
||||||
if port then
|
|
||||||
local m
|
|
||||||
|
|
||||||
if line:match("full[%- ]duplex") then
|
|
||||||
port.duplex = true
|
|
||||||
end
|
|
||||||
|
|
||||||
m = line:match(" speed:(%d+)")
|
|
||||||
if m then
|
|
||||||
port.speed = tonumber(m)
|
|
||||||
end
|
|
||||||
|
|
||||||
m = line:match("(%d+) Mbps")
|
|
||||||
if m and port.speed == 0 then
|
|
||||||
port.speed = tonumber(m)
|
|
||||||
end
|
|
||||||
|
|
||||||
m = line:match("link: (%d+)")
|
|
||||||
if m and port.speed == 0 then
|
|
||||||
port.speed = tonumber(m)
|
|
||||||
end
|
|
||||||
|
|
||||||
if line:match("link: ?up") or line:match("status: ?up") then
|
|
||||||
port.link = true
|
|
||||||
end
|
|
||||||
|
|
||||||
if line:match("auto%-negotiate") or line:match("link:.-auto") then
|
|
||||||
port.auto = true
|
|
||||||
end
|
|
||||||
|
|
||||||
if line:match("link:.-rxflow") then
|
|
||||||
port.rxflow = true
|
|
||||||
end
|
|
||||||
|
|
||||||
if line:match("link:.-txflow") then
|
|
||||||
port.txflow = true
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
swc:close()
|
|
||||||
|
|
||||||
if not next(ports) then
|
|
||||||
return { error = "No such switch" }
|
|
||||||
end
|
|
||||||
|
|
||||||
return { result = ports }
|
|
||||||
else
|
|
||||||
return { error = err }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
setPassword = {
|
|
||||||
args = { username = "root", password = "password" },
|
|
||||||
call = function(args)
|
|
||||||
local util = require "luci.util"
|
|
||||||
return {
|
|
||||||
result = (os.execute("(echo %s; sleep 1; echo %s) | /bin/busybox passwd %s >/dev/null 2>&1" %{
|
|
||||||
luci.util.shellquote(args.password),
|
|
||||||
luci.util.shellquote(args.password),
|
|
||||||
luci.util.shellquote(args.username)
|
|
||||||
}) == 0)
|
|
||||||
}
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getBlockDevices = {
|
|
||||||
call = function()
|
|
||||||
local fs = require "nixio.fs"
|
|
||||||
|
|
||||||
local block = io.popen("/sbin/block info", "r")
|
|
||||||
if block then
|
|
||||||
local rv = {}
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local ln = block:read("*l")
|
|
||||||
if not ln then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
|
|
||||||
local dev = ln:match("^/dev/(.-):")
|
|
||||||
if dev then
|
|
||||||
local s = tonumber((fs.readfile("/sys/class/block/" .. dev .."/size")))
|
|
||||||
local e = {
|
|
||||||
dev = "/dev/" .. dev,
|
|
||||||
size = s and s * 512
|
|
||||||
}
|
|
||||||
|
|
||||||
local key, val = { }
|
|
||||||
for key, val in ln:gmatch([[(%w+)="(.-)"]]) do
|
|
||||||
e[key:lower()] = val
|
|
||||||
end
|
|
||||||
|
|
||||||
rv[dev] = e
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
block:close()
|
|
||||||
|
|
||||||
return rv
|
|
||||||
else
|
|
||||||
return { error = "Unable to execute block utility" }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
setBlockDetect = {
|
|
||||||
call = function()
|
|
||||||
return { result = (os.execute("/sbin/block detect > /etc/config/fstab") == 0) }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getMountPoints = {
|
|
||||||
call = function()
|
|
||||||
local fs = require "nixio.fs"
|
|
||||||
|
|
||||||
local fd, err = io.open("/proc/mounts", "r")
|
|
||||||
if fd then
|
|
||||||
local rv = {}
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local ln = fd:read("*l")
|
|
||||||
if not ln then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
|
|
||||||
local device, mount, fstype, options, freq, pass = ln:match("^(%S*) (%S*) (%S*) (%S*) (%d+) (%d+)$")
|
|
||||||
if device and mount then
|
|
||||||
device = device:gsub("\\(%d+)", function(n) return string.char(tonumber(n, 8)) end)
|
|
||||||
mount = mount:gsub("\\(%d+)", function(n) return string.char(tonumber(n, 8)) end)
|
|
||||||
|
|
||||||
local stat = fs.statvfs(mount)
|
|
||||||
if stat and stat.blocks > 0 then
|
|
||||||
rv[#rv+1] = {
|
|
||||||
device = device,
|
|
||||||
mount = mount,
|
|
||||||
size = stat.bsize * stat.blocks,
|
|
||||||
avail = stat.bsize * stat.bavail,
|
|
||||||
free = stat.bsize * stat.bfree
|
|
||||||
}
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
fd:close()
|
|
||||||
|
|
||||||
return { result = rv }
|
|
||||||
else
|
|
||||||
return { error = err }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getRealtimeStats = {
|
|
||||||
args = { mode = "interface", device = "eth0" },
|
|
||||||
call = function(args)
|
|
||||||
local util = require "luci.util"
|
|
||||||
|
|
||||||
local flags
|
|
||||||
if args.mode == "interface" then
|
|
||||||
flags = "-i %s" % util.shellquote(args.device)
|
|
||||||
elseif args.mode == "wireless" then
|
|
||||||
flags = "-r %s" % util.shellquote(args.device)
|
|
||||||
elseif args.mode == "conntrack" then
|
|
||||||
flags = "-c"
|
|
||||||
elseif args.mode == "load" then
|
|
||||||
flags = "-l"
|
|
||||||
else
|
|
||||||
return { error = "Invalid mode" }
|
|
||||||
end
|
|
||||||
|
|
||||||
local fd, err = io.popen("luci-bwc %s" % flags, "r")
|
|
||||||
if fd then
|
|
||||||
local parse = json.new()
|
|
||||||
local done
|
|
||||||
|
|
||||||
parse:parse("[")
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local ln = fd:read("*l")
|
|
||||||
if not ln then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
|
|
||||||
done, err = parse:parse((ln:gsub("%d+", "%1.0")))
|
|
||||||
|
|
||||||
if done then
|
|
||||||
err = "Unexpected JSON data"
|
|
||||||
end
|
|
||||||
|
|
||||||
if err then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
fd:close()
|
|
||||||
|
|
||||||
done, err = parse:parse("]")
|
|
||||||
|
|
||||||
if err then
|
|
||||||
return { error = err }
|
|
||||||
elseif not done then
|
|
||||||
return { error = "Incomplete JSON data" }
|
|
||||||
else
|
|
||||||
return { result = parse:get() }
|
|
||||||
end
|
|
||||||
else
|
|
||||||
return { error = err }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getConntrackList = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
return { result = sys.net.conntrack() }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getProcessList = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local res = {}
|
|
||||||
for _, v in pairs(sys.process.list()) do
|
|
||||||
res[#res + 1] = v
|
|
||||||
end
|
|
||||||
return { result = res }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getCPUBench = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local cpubench = {}
|
|
||||||
|
|
||||||
cpubench.cpubench = sys.exec("cat /etc/bench.log 2>/dev/null")
|
|
||||||
return cpubench
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getCPUInfo = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local cpuinfo = {}
|
|
||||||
|
|
||||||
cpuinfo.cpuinfo = sys.exec("/sbin/cpuinfo")
|
|
||||||
|
|
||||||
if (cpuinfo.cpuinfo == nil) or (cpuinfo.cpuinfo == "") then
|
|
||||||
cpuinfo.cpuinfo = "? x ? (2.33MHz, 2.33°C)"
|
|
||||||
end
|
|
||||||
|
|
||||||
return cpuinfo
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getCPUUsage = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local cpuusage = {}
|
|
||||||
|
|
||||||
cpuusage.cpuusage = sys.exec("top -n1 | awk '/^CPU/ {printf(\"%d%\", 100 - $8)}'") or "6%"
|
|
||||||
return cpuusage
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getETHInfo = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local rv = json.parse(sys.exec("/sbin/ethinfo")) or {}
|
|
||||||
|
|
||||||
return { ethinfo = rv }
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getOnlineUsers = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local onlineusers = {}
|
|
||||||
|
|
||||||
onlineusers.onlineusers = sys.exec("cat /proc/net/arp | grep 'br-lan' | grep '0x2' | wc -l")
|
|
||||||
return onlineusers
|
|
||||||
|
|
||||||
end
|
|
||||||
},
|
|
||||||
|
|
||||||
getTempInfo = {
|
|
||||||
call = function()
|
|
||||||
local sys = require "luci.sys"
|
|
||||||
local tempinfo = {}
|
|
||||||
|
|
||||||
tempinfo.tempinfo = sys.exec("/sbin/tempinfo 2>/dev/null")
|
|
||||||
return tempinfo
|
|
||||||
end
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
local function parseInput()
|
|
||||||
local parse = json.new()
|
|
||||||
local done, err
|
|
||||||
|
|
||||||
while true do
|
|
||||||
local chunk = io.read(4096)
|
|
||||||
if not chunk then
|
|
||||||
break
|
|
||||||
elseif not done and not err then
|
|
||||||
done, err = parse:parse(chunk)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
if not done then
|
|
||||||
print(json.stringify({ error = err or "Incomplete input" }))
|
|
||||||
os.exit(1)
|
|
||||||
end
|
|
||||||
|
|
||||||
return parse:get()
|
|
||||||
end
|
|
||||||
|
|
||||||
local function validateArgs(func, uargs)
|
|
||||||
local method = methods[func]
|
|
||||||
if not method then
|
|
||||||
print(json.stringify({ error = "Method not found" }))
|
|
||||||
os.exit(1)
|
|
||||||
end
|
|
||||||
|
|
||||||
if type(uargs) ~= "table" then
|
|
||||||
print(json.stringify({ error = "Invalid arguments" }))
|
|
||||||
os.exit(1)
|
|
||||||
end
|
|
||||||
|
|
||||||
uargs.ubus_rpc_session = nil
|
|
||||||
|
|
||||||
local k, v
|
|
||||||
local margs = method.args or {}
|
|
||||||
for k, v in pairs(uargs) do
|
|
||||||
if margs[k] == nil or
|
|
||||||
(v ~= nil and type(v) ~= type(margs[k]))
|
|
||||||
then
|
|
||||||
print(json.stringify({ error = "Invalid arguments" }))
|
|
||||||
os.exit(1)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
return method
|
|
||||||
end
|
|
||||||
|
|
||||||
if arg[1] == "list" then
|
|
||||||
local _, method, rv = nil, nil, {}
|
|
||||||
for _, method in pairs(methods) do rv[_] = method.args or {} end
|
|
||||||
print((json.stringify(rv):gsub(":%[%]", ":{}")))
|
|
||||||
elseif arg[1] == "call" then
|
|
||||||
local args = parseInput()
|
|
||||||
local method = validateArgs(arg[2], args)
|
|
||||||
local result, code = method.call(args)
|
|
||||||
print((json.stringify(result):gsub("^%[%]$", "{}")))
|
|
||||||
os.exit(code or 0)
|
|
||||||
end
|
|
||||||
Loading…
Reference in New Issue
Block a user