RPC initial authentication API completed
[project/luci.git] / libs / web / luasrc / dispatcher.lua
index f5894bf..068f350 100644 (file)
@@ -23,7 +23,10 @@ See the License for the specific language governing permissions and
 limitations under the License.
 
 ]]--
+
+--- LuCI web dispatcher.
 module("luci.dispatcher", package.seeall)
+require("luci.util")
 require("luci.init")
 require("luci.http")
 require("luci.sys")
@@ -31,6 +34,8 @@ require("luci.fs")
 
 context = luci.util.threadlocal()
 
+authenticator = {}
+
 -- Index table
 local index = nil
 
@@ -38,24 +43,16 @@ local index = nil
 local fi
 
 
--- Builds a URL
+--- Build the URL relative to the server webroot from given virtual path.
+-- @param ...  Virtual path
+-- @return             Relative URL
 function build_url(...)
-       return luci.http.dispatcher() .. "/" .. table.concat(arg, "/")
+       return luci.http.getenv("SCRIPT_NAME") .. "/" .. table.concat(arg, "/")
 end
 
--- Prints an error message or renders the "error401" template if available
-function error401(message)
-       message = message or "Unauthorized"
-
-       require("luci.template")
-       if not luci.util.copcall(luci.template.render, "error401") then
-               luci.http.prepare_content("text/plain")
-               luci.http.write(message)
-       end
-       return false
-end
-
--- Sends a 404 error code and renders the "error404" template if available
+--- Send a 404 error code and render the "error404" template if available.
+-- @param message      Custom error message (optional)
+-- @return                     false
 function error404(message)
        luci.http.status(404, "Not Found")
        message = message or "Not Found"
@@ -68,7 +65,9 @@ function error404(message)
        return false
 end
 
--- Sends a 500 error code and renders the "error500" template if available
+--- Send a 500 error code and render the "error500" template if available.
+-- @param message      Custom error message (optional)#
+-- @return                     false
 function error500(message)
        luci.http.status(500, "Internal Server Error")
 
@@ -80,7 +79,24 @@ function error500(message)
        return false
 end
 
--- Creates a request object for dispatching
+function authenticator.htmlauth(validator, accs, default)
+       local user = luci.http.formvalue("username")
+       local pass = luci.http.formvalue("password")
+       
+       if user and validator(user, pass) then
+               return user
+       end
+       
+       require("luci.i18n")
+       require("luci.template")
+       context.path = {}
+       luci.template.render("sysauth", {duser=default, fuser=user})
+       return false
+       
+end
+
+--- Dispatch an HTTP request.
+-- @param request      LuCI HTTP Request object
 function httpdispatch(request)
        luci.http.context.request = request
        context.request = {}
@@ -94,7 +110,8 @@ function httpdispatch(request)
        luci.http.close()
 end
 
--- Dispatches a request
+--- Dispatches a LuCI virtual path.
+-- @param request      Virtual path
 function dispatch(request)
        context.path = request
        
@@ -107,46 +124,35 @@ function dispatch(request)
        
        local c = context.tree
        local track = {}
+       local args = {}
+       context.args = args
+       local n
 
        for i, s in ipairs(request) do
                c = c.nodes[s]
-               if not c or c.leaf then
+               n = i
+               if not c then
                        break
                end
 
                for k, v in pairs(c) do
                        track[k] = v
                end
-       end
-
-       if track.sysauth then
-               local accs = track.sysauth
-               accs = (type(accs) == "string") and {accs} or accs
                
-               --[[
-               local function sysauth(user, password)
-                       return (luci.util.contains(accs, user)
-                               and luci.sys.user.checkpasswd(user, password)) 
+               if c.leaf then
+                       break
                end
-               
-               if not luci.http.basic_auth(sysauth) then
-                       error401()
-                       return
+       end
+
+       if c and c.leaf then
+               for j=n+1, #request do
+                       table.insert(args, request[j])
                end
-               ]]--
        end
 
        if track.i18n then
                require("luci.i18n").loadc(track.i18n)
        end
-
-       if track.setgroup then
-               luci.sys.process.setgroup(track.setgroup)
-       end
-
-       if track.setuser then
-               luci.sys.process.setuser(track.setuser)
-       end
        
        -- Init template engine
        local tpl = require("luci.template")
@@ -154,11 +160,55 @@ function dispatch(request)
        tpl.context.viewns = viewns
        viewns.write       = luci.http.write
        viewns.translate   = function(...) return require("luci.i18n").translate(...) end
+       viewns.striptags   = luci.util.striptags
        viewns.controller  = luci.http.getenv("SCRIPT_NAME")
        viewns.media       = luci.config.main.mediaurlbase
        viewns.resource    = luci.config.main.resourcebase
        viewns.REQUEST_URI = luci.http.getenv("SCRIPT_NAME") .. (luci.http.getenv("PATH_INFO") or "")
        
+       if track.dependent then
+               local stat, err = pcall(assert, not track.auto)
+               if not stat then
+                       error500(err)
+                       return
+               end
+       end
+       
+       if track.sysauth then
+               require("luci.sauth")
+               local authen = type(track.sysauth_authenticator) == "function"
+                and track.sysauth_authenticator
+                or authenticator[track.sysauth_authenticator]
+               local def  = (type(track.sysauth) == "string") and track.sysauth
+               local accs = def and {track.sysauth} or track.sysauth
+               local sess = luci.http.getcookie("sysauth")
+               sess = sess and sess:match("^[A-F0-9]+$")
+               local user = luci.sauth.read(sess)
+               
+               if not luci.util.contains(accs, user) then
+                       if authen then
+                               local user = authen(luci.sys.user.checkpasswd, accs, def)
+                               if not user or not luci.util.contains(accs, user) then
+                                       return
+                               else
+                                       local sid = luci.sys.uniqueid(16)
+                                       luci.http.header("Set-Cookie", "sysauth=" .. sid.."; path=/")
+                                       luci.sauth.write(sid, user)
+                               end
+                       else
+                               luci.http.status(403, "Forbidden")
+                               return
+                       end
+               end
+       end
+
+       if track.setgroup then
+               luci.sys.process.setgroup(track.setgroup)
+       end
+
+       if track.setuser then
+               luci.sys.process.setuser(track.setuser)
+       end
 
        if c and type(c.target) == "function" then
                context.dispatched = c
@@ -167,7 +217,7 @@ function dispatch(request)
                        luci.util.updfenv(c.target, mod)
                end
                
-               stat, err = luci.util.copcall(c.target)
+               stat, err = luci.util.copcall(c.target, unpack(args))
                if not stat then
                        error500(err)
                end
@@ -176,9 +226,9 @@ function dispatch(request)
        end
 end
 
--- Generates the dispatching tree
+--- Generate the dispatching index using the best possible strategy.
 function createindex()
-       local path = luci.sys.libpath() .. "/controller/"
+       local path = luci.util.libpath() .. "/controller/"
        local suff = ".lua"
        
        if luci.util.copcall(require, "luci.fastindex") then
@@ -188,7 +238,9 @@ function createindex()
        end
 end
 
--- Uses fastindex to create the dispatching tree
+--- Generate the dispatching index using the fastindex C-indexer.
+-- @param path         Controller base directory
+-- @param suffix       Controller file suffix
 function createindex_fastindex(path, suffix)
        index = {}
                
@@ -204,8 +256,9 @@ function createindex_fastindex(path, suffix)
        end
 end
 
--- Calls the index function of all available controllers
--- Fallback for transition purposes / Leave it in as long as it works otherwise throw it away
+--- Generate the dispatching index using the native file-cache based strategy.
+-- @param path         Controller base directory
+-- @param suffix       Controller file suffix
 function createindex_plain(path, suffix)
        index = {}
 
@@ -245,7 +298,7 @@ function createindex_plain(path, suffix)
                                index[module] = mod.index
                                
                                if cache then
-                                       luci.fs.writefile(cachefile, luci.util.dump(mod.index))
+                                       luci.fs.writefile(cachefile, luci.util.get_bytecode(mod.index))
                                end
                        end
                else
@@ -254,7 +307,8 @@ function createindex_plain(path, suffix)
        end
 end
 
--- Creates the dispatching tree from the index
+--- Create the dispatching tree from the index.
+-- Build the index before if it does not exist yet.
 function createtree()
        if not index then
                createindex()
@@ -267,7 +321,7 @@ function createtree()
        luci.i18n.loadc("default")
        
        local scope = luci.util.clone(_G)
-       for k,v in pairs(_M) do
+       for k,v in pairs(luci.dispatcher) do
                if type(v) == "function" then
                        scope[k] = v
                end
@@ -276,18 +330,24 @@ function createtree()
        for k, v in pairs(index) do
                scope._NAME = k
                setfenv(v, scope)
-               
+
                local stat, err = luci.util.copcall(v)
                if not stat then
-                       error500(err)   
+                       error500("createtree failed: " .. k .. ": " .. err)
+                       luci.http.close()
                        os.exit(1)
                end
        end
 end
 
--- Reassigns a node to another position
+--- Clone a node of the dispatching tree to another position.
+-- @param      path    Virtual path destination
+-- @param      clone   Virtual path source
+-- @param      title   Destination node title (optional)
+-- @param      order   Destination node order value (optional)
+-- @return                     Dispatching tree node
 function assign(path, clone, title, order)
-       local obj  = node(path)
+       local obj  = node(unpack(path))
        obj.nodes  = nil
        obj.module = nil
        
@@ -308,9 +368,14 @@ function assign(path, clone, title, order)
        return obj
 end
 
--- Shortcut for creating a dispatching node
+--- Create a new dispatching node and define common parameters.
+-- @param      path    Virtual path
+-- @param      target  Target function to call when dispatched. 
+-- @param      title   Destination node title
+-- @param      order   Destination node order value (optional)
+-- @return                     Dispatching tree node
 function entry(path, target, title, order)
-       local c = node(path)
+       local c = node(unpack(path))
        
        c.target = target
        c.title  = title
@@ -320,19 +385,16 @@ function entry(path, target, title, order)
        return c
 end
 
--- Fetch a dispatching node
+--- Fetch or create a new dispatching node.
+-- @param      ...             Virtual path
+-- @return                     Dispatching tree node
 function node(...)
        local c = context.tree
        arg.n = nil
-       if arg[1] then
-               if type(arg[1]) == "table" then
-                       arg = arg[1]
-               end
-       end
 
        for k,v in ipairs(arg) do
                if not c.nodes[v] then
-                       c.nodes[v] = {nodes={}}
+                       c.nodes[v] = {nodes={}, auto=true}
                end
 
                c = c.nodes[v]
@@ -340,11 +402,15 @@ function node(...)
 
        c.module = getfenv(2)._NAME
        c.path = arg
+       c.auto = nil
 
        return c
 end
 
 -- Subdispatchers --
+
+--- Create a redirect to another dispatching node.
+-- @param      ...             Virtual path destination
 function alias(...)
        local req = arg
        return function()
@@ -352,6 +418,9 @@ function alias(...)
        end
 end
 
+--- Rewrite the first x path values of the request.
+-- @param      n               Number of path values to replace
+-- @param      ...             Virtual path to replace removed path values with
 function rewrite(n, ...)
        local req = arg
        return function()
@@ -367,35 +436,75 @@ function rewrite(n, ...)
        end
 end
 
+--- Create a function-call dispatching target.
+-- @param      name    Target function of local controller 
+-- @param      ...             Additional parameters passed to the function
 function call(name, ...)
        local argv = {...}
        return function() return getfenv()[name](unpack(argv)) end
 end
 
+--- Create a template render dispatching target.
+-- @param      name    Template to be rendered
 function template(name)
        require("luci.template")
        return function() luci.template.render(name) end
 end
 
+--- Create a CBI model dispatching target.
+-- @param      model   CBI model tpo be rendered
 function cbi(model)
        require("luci.cbi")
        require("luci.template")
 
-       return function()
-               local stat, res = luci.util.copcall(luci.cbi.load, model)
+       return function(...)
+               local stat, maps = luci.util.copcall(luci.cbi.load, model, ...)
                if not stat then
-                       error500(res)
+                       error500(maps)
                        return true
                end
 
-               local stat, err = luci.util.copcall(res.parse, res)
-               if not stat then
-                       error500(err)
-                       return true
+               for i, res in ipairs(maps) do
+                       local stat, err = luci.util.copcall(res.parse, res)
+                       if not stat then
+                               error500(err)
+                               return true
+                       end
                end
 
                luci.template.render("cbi/header")
-               res:render()
+               for i, res in ipairs(maps) do
+                       res:render()
+               end
                luci.template.render("cbi/footer")
        end
 end
+
+--- Create a CBI form model dispatching target.
+-- @param      model   CBI form model tpo be rendered
+function form(model)
+       require("luci.cbi")
+       require("luci.template")
+
+       return function(...)
+               local stat, maps = luci.util.copcall(luci.cbi.load, model, ...)
+               if not stat then
+                       error500(maps)
+                       return true
+               end
+
+               for i, res in ipairs(maps) do
+                       local stat, err = luci.util.copcall(res.parse, res)
+                       if not stat then
+                               error500(err)
+                               return true
+                       end
+               end
+
+               luci.template.render("header")
+               for i, res in ipairs(maps) do
+                       res:render()
+               end
+               luci.template.render("footer")
+       end
+end