libs/cbi: Added magic ;-)
[project/luci.git] / libs / web / luasrc / dispatcher.lua
index 202e073..9ba74c4 100644 (file)
@@ -23,85 +23,116 @@ See the License for the specific language governing permissions and
 limitations under the License.
 
 ]]--
+
+--- LuCI web dispatcher.
 module("luci.dispatcher", package.seeall)
+require("luci.init")
 require("luci.http")
 require("luci.sys")
 require("luci.fs")
 
--- Local dispatch database
-local tree = {nodes={}}
+context = luci.util.threadlocal()
 
 -- Index table
-local index = {}
-
--- Indexdump
-local indexcache = "/tmp/.luciindex"
-
--- Global request object
-request = {}
+local index = nil
 
--- Active dispatched node
-dispatched = nil
+-- Fastindex
+local fi
 
--- Status fields
-built_index = false
-built_tree  = false
 
-
--- 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
 
--- 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"
 
        require("luci.template")
-       if not pcall(luci.template.render, "error404") then
+       if not luci.util.copcall(luci.template.render, "error404") then
                luci.http.prepare_content("text/plain")
-               print(message)
+               luci.http.write(message)
        end
        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")
 
        require("luci.template")
-       if not pcall(luci.template.render, "error500", {message=message}) then
+       if not luci.util.copcall(luci.template.render, "error500", {message=message}) then
                luci.http.prepare_content("text/plain")
-               print(message)
+               luci.http.write(message)
        end
        return false
 end
 
--- Creates a request object for dispatching
-function httpdispatch()
-       local pathinfo = luci.http.env.PATH_INFO or ""
-       local c = tree
+--- Render and evaluate the system authentication login form.
+-- @param default      Default username
+-- @return                     Authentication status
+function sysauth(default)
+       local user = luci.http.formvalue("username")
+       local pass = luci.http.formvalue("password")
+       
+       if user and luci.sys.user.checkpasswd(user, pass) then
+               local sid = luci.sys.uniqueid(16)
+               luci.http.header("Set-Cookie", "sysauth=" .. sid.."; path=/")
+               luci.sauth.write(sid, user)
+               return true
+       else
+               require("luci.i18n")
+               require("luci.template")
+               context.path = {}
+               luci.template.render("sysauth", {duser=default, fuser=user})
+               return false
+       end
+end
+
+--- Dispatch an HTTP request.
+-- @param request      LuCI HTTP Request object
+function httpdispatch(request)
+       luci.http.context.request = request
+       context.request = {}
+       local pathinfo = request:getenv("PATH_INFO") or ""
 
-       for s in pathinfo:gmatch("([%w_]+)") do
-               table.insert(request, s)
+       for node in pathinfo:gmatch("[^/]+") do
+               table.insert(context.request, node)
        end
 
-       dispatch()
+       dispatch(context.request)
+       luci.http.close()
 end
 
--- Dispatches a request
-function dispatch()
-       if not built_tree then
+--- Dispatches a LuCI virtual path.
+-- @param request      Virtual path
+function dispatch(request)
+       context.path = request
+       
+       require("luci.i18n")
+       luci.i18n.setlanguage(require("luci.config").main.lang)
+       
+       if not context.tree then
                createtree()
        end
-
-       local c = tree
+       
+       local c = context.tree
        local track = {}
+       local args = {}
+       local n
 
        for i, s in ipairs(request) do
                c = c.nodes[s]
-               if not c then
+               n = i
+               if not c or c.leaf then
                        break
                end
 
@@ -110,10 +141,48 @@ function dispatch()
                end
        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
+       
+       -- Init template engine
+       local tpl = require("luci.template")
+       local viewns = {}
+       tpl.context.viewns = viewns
+       viewns.write       = luci.http.write
+       viewns.translate   = function(...) return require("luci.i18n").translate(...) end
+       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 def  = (type(track.sysauth) == "string") and track.sysauth
+               local accs = def and {track.sysauth} or track.sysauth
+               local user = luci.sauth.read(luci.http.getcookie("sysauth"))
+               
+               
+               if not luci.util.contains(accs, user) then
+                       if not sysauth(def) then
+                               return
+                       end
+               end
+       end
 
        if track.setgroup then
                luci.sys.process.setgroup(track.setgroup)
@@ -122,27 +191,15 @@ function dispatch()
        if track.setuser then
                luci.sys.process.setuser(track.setuser)
        end
-       
-       -- Init template engine
-       local tpl = require("luci.template")
-       tpl.viewns.translate  = function(...) return require("luci.i18n").translate(...) end
-       tpl.viewns.controller = luci.http.dispatcher()
-       tpl.viewns.uploadctrl = luci.http.dispatcher_upload()
-       tpl.viewns.media      = luci.config.main.mediaurlbase
-       tpl.viewns.resource   = luci.config.main.resourcebase
-       
-       -- Load default translation
-       require("luci.i18n").loadc("default")
-       
 
        if c and type(c.target) == "function" then
-               dispatched = c
-               stat, mod = pcall(require, c.module)
+               context.dispatched = c
+               stat, mod = luci.util.copcall(require, c.module)
                if stat then
                        luci.util.updfenv(c.target, mod)
                end
                
-               stat, err = pcall(c.target)
+               stat, err = luci.util.copcall(c.target, unpack(args))
                if not stat then
                        error500(err)
                end
@@ -151,26 +208,29 @@ function dispatch()
        end
 end
 
--- Generates the dispatching tree
+--- Generate the dispatching index using the best possible strategy.
 function createindex()
-       index = {}
-       local path = luci.sys.libpath() .. "/controller/"
+       local path = luci.util.libpath() .. "/controller/"
        local suff = ".lua"
        
-       if pcall(require, "fastindex") then
+       if luci.util.copcall(require, "luci.fastindex") then
                createindex_fastindex(path, suff)
        else
                createindex_plain(path, suff)
        end
-       
-       built_index = true
 end
 
--- Uses fastindex to create the dispatching tree
-function createindex_fastindex(path, suffix)   
-       local fi = fastindex.new("index")
-       fi.add(path .. "*" .. suffix)
-       fi.add(path .. "*/*" .. suffix)
+--- 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 = {}
+               
+       if not fi then
+               fi = luci.fastindex.new("index")
+               fi.add(path .. "*" .. suffix)
+               fi.add(path .. "*/*" .. suffix)
+       end
        fi.scan()
        
        for k, v in pairs(fi.indexes) do
@@ -178,9 +238,13 @@ function createindex_fastindex(path, suffix)
        end
 end
 
--- Calls the index function of all available controllers
+--- 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)
-       local cachetime = nil 
+       index = {}
+
+       local cache = nil 
        
        local controllers = luci.util.combine(
                luci.fs.glob(path .. "*" .. suffix) or {},
@@ -188,124 +252,212 @@ function createindex_plain(path, suffix)
        )
        
        if indexcache then
-               cachetime = luci.fs.mtime(indexcache)
+               cache = luci.fs.mtime(indexcache)
                
-               if not cachetime then
+               if not cache then
                        luci.fs.mkdir(indexcache)
                        luci.fs.chmod(indexcache, "a=,u=rwx")
+                       cache = luci.fs.mtime(indexcache)
                end
        end
 
-       if not cachetime then
-               for i,c in ipairs(controllers) do
-                       c = "luci.controller." .. c:sub(#path+1, #c-#suffix):gsub("/", ".")
-                       stat, mod = pcall(require, c)
+       for i,c in ipairs(controllers) do
+               local module = "luci.controller." .. c:sub(#path+1, #c-#suffix):gsub("/", ".")
+               local cachefile
+               local stime
+               local ctime
+               
+               if cache then
+                       cachefile = indexcache .. "/" .. module
+                       stime = luci.fs.mtime(c) or 0
+                       ctime = luci.fs.mtime(cachefile) or 0
+               end
+               
+               if not cache or stime > ctime then 
+                       stat, mod = luci.util.copcall(require, module)
        
                        if stat and mod and type(mod.index) == "function" then
-                               index[c] = mod.index
+                               index[module] = mod.index
                                
-                               if indexcache then
-                                       luci.fs.writefile(indexcache .. "/" .. c, string.dump(mod.index))
+                               if cache then
+                                       luci.fs.writefile(cachefile, luci.util.get_bytecode(mod.index))
                                end
                        end
-               end
-       else
-               for i,c in ipairs(luci.fs.dir(indexcache)) do
-                       if c:sub(1) ~= "." then
-                               index[c] = loadfile(indexcache .. "/" .. c)
-                       end
+               else
+                       index[module] = loadfile(cachefile)
                end
        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 built_index then
+       if not index then
                createindex()
        end
+       
+       context.tree = {nodes={}}
+       require("luci.i18n")
+               
+       -- Load default translation
+       luci.i18n.loadc("default")
+       
+       local scope = luci.util.clone(_G)
+       for k,v in pairs(luci.dispatcher) do
+               if type(v) == "function" then
+                       scope[k] = v
+               end
+       end
 
        for k, v in pairs(index) do
-               luci.util.updfenv(v, _M)
-               luci.util.extfenv(v, "_NAME", k)
-               pcall(v)
+               scope._NAME = k
+               setfenv(v, scope)
+
+               local stat, err = luci.util.copcall(v)
+               if not stat then
+                       error500("createtree failed: " .. k .. ": " .. err)
+                       luci.http.close()
+                       os.exit(1)
+               end
        end
-       
-       built_tree = true
 end
 
--- Shortcut for creating a dispatching node
-function entry(path, target, title, order, add)
-       add = add or {}
+--- 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(unpack(path))
+       obj.nodes  = nil
+       obj.module = nil
+       
+       obj.title = title
+       obj.order = order
+       
+       local c = context.tree
+       for k, v in ipairs(clone) do
+               if not c.nodes[v] then
+                       c.nodes[v] = {nodes={}}
+               end
 
-       local c = node(path)
+               c = c.nodes[v]
+       end
+       
+       setmetatable(obj, {__index = c})
+       
+       return obj
+end
+
+--- 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(unpack(path))
+       
        c.target = target
        c.title  = title
        c.order  = order
        c.module = getfenv(2)._NAME
 
-       for k,v in pairs(add) do
-               c[k] = v
-       end
-
        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 = tree
-
-       if arg[1] and type(arg[1]) == "table" then
-               arg = arg[1]
-       end
+       local c = context.tree
+       arg.n = nil
 
        for k,v in ipairs(arg) do
                if not c.nodes[v] then
-                       c.nodes[v] = {nodes={}, module=getfenv(2)._NAME}
+                       c.nodes[v] = {nodes={}, auto=true}
                end
 
                c = c.nodes[v]
        end
 
+       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()
-               request = req
+               dispatch(req)
+       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()
+               for i=1,n do 
+                       table.remove(context.path, 1)
+               end
+               
+               for i,r in ipairs(req) do
+                       table.insert(context.path, i, r)
+               end
+               
                dispatch()
        end
 end
 
-function call(name)
-       return function() getfenv()[name]() 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 = pcall(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 = pcall(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