Merge pull request #1735 from sumpfralle/olsr-jsoninfo-parser-handle-empty-result
[oweals/luci.git] / modules / luci-base / luasrc / controller / admin / index.lua
index 39e6e573b15d03947e9f44a1c81fa4ee48ad323b..928faa14b40e78fd243e36172272304ccc14c340 100644 (file)
@@ -16,6 +16,8 @@ function index()
                end
        end
 
+       local uci = require("luci.model.uci").cursor()
+
        local root = node()
        if not root.target then
                root.target = alias("admin")
@@ -23,13 +25,14 @@ function index()
        end
 
        local page   = node("admin")
+
        page.title   = _("Administration")
        page.order   = 10
        page.sysauth = "root"
        page.sysauth_authenticator = "htmlauth"
        page.ucidata = true
        page.index = true
-       toplevel_page(page, "admin/status/overview", alias("admin", "status"))
+       page.target = firstnode()
 
        -- Empty menu tree to be populated by addons and modules
 
@@ -45,7 +48,14 @@ function index()
        page.order = 20
        page.index = true
        -- system/system is from mod-admin-full
-       toplevel_page(page, "admin/system/system", alias("admin", "system", "system")) 
+       toplevel_page(page, "admin/system/system", alias("admin", "system", "system"))
+
+       -- Only used if applications add items
+       page = node("admin", "vpn")
+       page.title = _("VPN")
+       page.order = 30
+       page.index = true
+       toplevel_page(page, false, false)
 
        -- Only used if applications add items
        page = node("admin", "services")
@@ -61,6 +71,34 @@ function index()
        page.index = true
        toplevel_page(page, false, false)
 
+       if nixio.fs.access("/etc/config/dhcp") then
+               page = entry({"admin", "dhcplease_status"}, call("lease_status"), nil)
+               page.leaf = true
+       end
+
+       local has_wifi = false
+
+       uci:foreach("wireless", "wifi-device",
+               function(s)
+                       has_wifi = true
+                       return false
+               end)
+
+       if has_wifi then
+               page = entry({"admin", "wireless_assoclist"}, call("wifi_assoclist"), nil)
+               page.leaf = true
+
+               page = entry({"admin", "wireless_deauth"}, post("wifi_deauth"), nil)
+               page.leaf = true
+       end
+
+       page = entry({"admin", "translations"}, call("action_translations"), nil)
+       page.leaf = true
+
+       page = entry({"admin", "ubus"}, call("action_ubus"), nil)
+       page.sysauth = false
+       page.leaf = true
+
        -- Logout is last
        entry({"admin", "logout"}, call("action_logout"), _("Logout"), 999)
 end
@@ -73,10 +111,207 @@ function action_logout()
        if sid then
                utl.ubus("session", "destroy", { ubus_rpc_session = sid })
 
-               luci.http.header("Set-Cookie", "sysauth=%s; expires=%s; path=%s/" %{
-                       sid, 'Thu, 01 Jan 1970 01:00:00 GMT', dsp.build_url()
+               luci.http.header("Set-Cookie", "sysauth=%s; expires=%s; path=%s" %{
+                       '', 'Thu, 01 Jan 1970 01:00:00 GMT', dsp.build_url()
                })
        end
 
        luci.http.redirect(dsp.build_url())
 end
+
+function action_translations(lang)
+       local i18n = require "luci.i18n"
+       local http = require "luci.http"
+       local fs = require "nixio".fs
+
+       if lang and #lang > 0 then
+               lang = i18n.setlanguage(lang)
+               if lang then
+                       local s = fs.stat("%s/base.%s.lmo" %{ i18n.i18ndir, lang })
+                       if s then
+                               http.header("Cache-Control", "public, max-age=31536000")
+                               http.header("ETag", "%x-%x-%x" %{ s["ino"], s["size"], s["mtime"] })
+                       end
+               end
+       end
+
+       http.prepare_content("application/javascript; charset=utf-8")
+       http.write("window.TR=")
+       http.write_json(i18n.dump())
+end
+
+local function ubus_reply(id, data, code, errmsg)
+       local reply = { jsonrpc = "2.0", id = id }
+       if errmsg then
+               reply.error = {
+                       code = code,
+                       message = errmsg
+               }
+       elseif type(code) == "table" then
+               reply.result = code
+       else
+               reply.result = { code, data }
+       end
+
+       return reply
+end
+
+local ubus_types = {
+       nil,
+       "array",
+       "object",
+       "string",
+       nil, -- INT64
+       "number",
+       nil, -- INT16,
+       "boolean",
+       "double"
+}
+
+local function ubus_access(sid, obj, fun)
+       local res, code = luci.util.ubus("session", "access", {
+               ubus_rpc_session = sid,
+               scope            = "ubus",
+               object           = obj,
+               ["function"]     = fun
+       })
+
+       return (type(res) == "table" and res.access == true)
+end
+
+local function ubus_request(req)
+       if type(req) ~= "table" or type(req.method) ~= "string" or req.jsonrpc ~= "2.0" or req.id == nil then
+               return ubus_reply(nil, nil, -32600, "Invalid request")
+
+       elseif req.method == "call" then
+               if type(req.params) ~= "table" or #req.params < 3 then
+                       return ubus_reply(nil, nil, -32600, "Invalid parameters")
+               end
+
+               local sid, obj, fun, arg =
+                       req.params[1], req.params[2], req.params[3], req.params[4] or {}
+               if type(arg) ~= "table" or arg.ubus_rpc_session ~= nil then
+                       return ubus_reply(req.id, nil, -32602, "Invalid parameters")
+               end
+
+               if sid == "00000000000000000000000000000000" and luci.dispatcher.context.authsession then
+                       sid = luci.dispatcher.context.authsession
+               end
+
+               if not ubus_access(sid, obj, fun) then
+                       return ubus_reply(req.id, nil, -32002, "Access denied")
+               end
+
+               arg.ubus_rpc_session = sid
+
+               local res, code = luci.util.ubus(obj, fun, arg)
+               return ubus_reply(req.id, res, code or 0)
+
+       elseif req.method == "list" then
+               if req.params == nil or (type(req.params) == "table" and #req.params == 0) then
+                       local objs = luci.util.ubus()
+                       return ubus_reply(req.id, nil, objs)
+
+               elseif type(req.params) == "table" then
+                       local n, rv = nil, {}
+                       for n = 1, #req.params do
+                               if type(req.params[n]) ~= "string" then
+                                       return ubus_reply(req.id, nil, -32602, "Invalid parameters")
+                               end
+
+                               local sig = luci.util.ubus(req.params[n])
+                               if sig and type(sig) == "table" then
+                                       rv[req.params[n]] = {}
+
+                                       local m, p
+                                       for m, p in pairs(sig) do
+                                               if type(p) == "table" then
+                                                       rv[req.params[n]][m] = {}
+
+                                                       local pn, pt
+                                                       for pn, pt in pairs(p) do
+                                                               rv[req.params[n]][m][pn] = ubus_types[pt] or "unknown"
+                                                       end
+                                               end
+                                       end
+                               end
+                       end
+                       return ubus_reply(req.id, nil, rv)
+
+               else
+                       return ubus_reply(req.id, nil, -32602, "Invalid parameters")
+               end
+       end
+
+       return ubus_reply(req.id, nil, -32601, "Method not found")
+end
+
+function action_ubus()
+       local parser = require "luci.jsonc".new()
+
+       luci.http.context.request:setfilehandler(function(_, s)
+               if not s then
+                       return nil
+               end
+
+               local ok, err = parser:parse(s)
+               return (not err or nil)
+       end)
+
+       luci.http.context.request:content()
+
+       local json = parser:get()
+       if json == nil or type(json) ~= "table" then
+               luci.http.prepare_content("application/json")
+               luci.http.write_json(ubus_reply(nil, nil, -32700, "Parse error"))
+               return
+       end
+
+       local response
+       if #json == 0 then
+               response = ubus_request(json)
+       else
+               response = {}
+
+               local _, request
+               for _, request in ipairs(json) do
+                       response[_] = ubus_request(request)
+               end
+       end
+
+       luci.http.prepare_content("application/json")
+       luci.http.write_json(response)
+end
+
+function lease_status()
+       local s = require "luci.tools.status"
+
+       luci.http.prepare_content("application/json")
+       luci.http.write('[')
+       luci.http.write_json(s.dhcp_leases())
+       luci.http.write(',')
+       luci.http.write_json(s.dhcp6_leases())
+       luci.http.write(']')
+end
+
+function wifi_assoclist()
+       local s = require "luci.tools.status"
+
+       luci.http.prepare_content("application/json")
+       luci.http.write_json(s.wifi_assoclist())
+end
+
+function wifi_deauth()
+       local iface = luci.http.formvalue("iface")
+       local bssid = luci.http.formvalue("bssid")
+
+       if iface and bssid then
+               luci.util.ubus("hostapd.%s" % iface, "del_client", {
+                       addr = bssid,
+                       deauth = true,
+                       reason = 5,
+                       ban_time = 60000
+               })
+       end
+       luci.http.status(200, "OK")
+end