| rev | line source | 
| jbe/bsw@0 | 1 #!/usr/bin/env lua | 
| jbe/bsw@0 | 2 | 
| jbe@116 | 3 _WEBMCP_VERSION = "1.2.6" | 
| jbe@64 | 4 | 
| jbe@64 | 5 -- Lua 5.1 compatibility | 
| jbe@64 | 6 if not table.unpack then | 
| jbe@64 | 7   table.unpack = unpack | 
| jbe@64 | 8 end | 
| jbe@68 | 9 do | 
| jbe@68 | 10   local old_load = load | 
| jbe@68 | 11   function load(ld, ...) | 
| jbe@69 | 12     if type(ld) == "string" then | 
| jbe@68 | 13       local done = false | 
| jbe@68 | 14       local func = function() | 
| jbe@68 | 15         if not done then | 
| jbe@68 | 16           done = true | 
| jbe@68 | 17           return ld | 
| jbe@68 | 18         end | 
| jbe@68 | 19       end | 
| jbe@68 | 20       return old_load(func, ...) | 
| jbe@68 | 21     else | 
| jbe@68 | 22       return old_load(ld, ...) | 
| jbe@68 | 23     end | 
| jbe@68 | 24   end | 
| jbe@68 | 25 end | 
| jbe@1 | 26 | 
| jbe/bsw@0 | 27 -- include "../lib/" in search path for libraries | 
| poelzi@28 | 28 if not WEBMCP_PATH then | 
| poelzi@28 | 29   WEBMCP_PATH = "../" | 
| poelzi@28 | 30 end | 
| jbe/bsw@0 | 31 do | 
| jbe@43 | 32   package.path = WEBMCP_PATH .. 'lib/?.lua;' .. package.path | 
| jbe/bsw@0 | 33   -- find out which file name extension shared libraries have | 
| jbe/bsw@0 | 34   local slib_exts = {} | 
| jbe/bsw@0 | 35   for ext in string.gmatch(package.cpath, "%?%.([A-Za-z0-9_-]+)") do | 
| jbe/bsw@0 | 36     slib_exts[ext] = true | 
| jbe/bsw@0 | 37   end | 
| jbe/bsw@0 | 38   local paths = {} | 
| jbe/bsw@0 | 39   for ext in pairs(slib_exts) do | 
| jbe@43 | 40     paths[#paths+1] = WEBMCP_PATH .. "accelerator/?." .. ext | 
| jbe/bsw@0 | 41   end | 
| jbe/bsw@0 | 42   for ext in pairs(slib_exts) do | 
| jbe@43 | 43     paths[#paths+1] = WEBMCP_PATH .. "lib/?." .. ext | 
| jbe/bsw@0 | 44   end | 
| jbe/bsw@0 | 45   paths[#paths+1] = package.cpath | 
| jbe/bsw@0 | 46   package.cpath = table.concat(paths, ";") | 
| jbe/bsw@0 | 47 end | 
| jbe/bsw@0 | 48 | 
| jbe/bsw@0 | 49 -- load os extensions for lua | 
| jbe/bsw@0 | 50 -- (should happen as soon as possible due to run time measurement) | 
| jbe@64 | 51 extos = require 'extos' | 
| jbe/bsw@0 | 52 | 
| jbe/bsw@0 | 53 -- load nihil library | 
| jbe@64 | 54 nihil = require 'nihil' | 
| jbe/bsw@0 | 55 | 
| jbe/bsw@0 | 56 -- load random generator library | 
| jbe@64 | 57 multirand = require 'multirand' | 
| jbe/bsw@0 | 58 | 
| jbe@86 | 59 -- load rocketcgi library and map it to cgi, unless interactive | 
| jbe/bsw@0 | 60 do | 
| jbe/bsw@0 | 61   local option = os.getenv("WEBMCP_INTERACTIVE") | 
| jbe/bsw@0 | 62   if option and option ~= "" and option ~= "0" then | 
| jbe/bsw@0 | 63     cgi = nil | 
| jbe/bsw@0 | 64   else | 
| jbe@69 | 65     rocketcgi = require 'rocketcgi'  -- TODO: no "rocketcgi" alias | 
| jbe/bsw@0 | 66     cgi = rocketcgi | 
| jbe/bsw@0 | 67   end | 
| jbe/bsw@0 | 68 end | 
| jbe/bsw@0 | 69 | 
| jbe/bsw@0 | 70 -- load database access library with object relational mapper | 
| jbe@64 | 71 mondelefant = require 'mondelefant' | 
| jbe/bsw@0 | 72 mondelefant.connection_prototype.error_objects = true | 
| jbe/bsw@0 | 73 | 
| jbe/bsw@0 | 74 -- load type system "atom" | 
| jbe@64 | 75 atom = require 'atom' | 
| jbe/bsw@0 | 76 | 
| jbe@176 | 77 -- load JSON library | 
| jbe@176 | 78 json = require 'json' | 
| jbe@176 | 79 | 
| jbe/bsw@0 | 80 -- load mondelefant atom connector | 
| jbe/bsw@0 | 81 require 'mondelefant_atom_connector' | 
| jbe/bsw@0 | 82 | 
| jbe/bsw@0 | 83 --[[-- | 
| jbe/bsw@0 | 84 cloned_table =  -- newly generated table | 
| jbe/bsw@0 | 85 table.new( | 
| jbe/bsw@0 | 86   table_or_nil  -- keys of a given table will be copied to the new table | 
| jbe/bsw@0 | 87 ) | 
| jbe/bsw@0 | 88 | 
| jbe/bsw@0 | 89 If a table is given, then a cloned table is returned. | 
| jbe/bsw@0 | 90 If nil is given, then a new empty table is returned. | 
| jbe/bsw@0 | 91 | 
| jbe/bsw@0 | 92 --]]-- | 
| jbe/bsw@0 | 93 function table.new(tbl) | 
| jbe/bsw@0 | 94   new_tbl = {} | 
| jbe/bsw@0 | 95   if tbl then | 
| jbe/bsw@0 | 96     for key, value in pairs(tbl) do | 
| jbe/bsw@0 | 97       new_tbl[key] = value | 
| jbe/bsw@0 | 98     end | 
| jbe/bsw@0 | 99   end | 
| jbe/bsw@0 | 100   return new_tbl | 
| jbe/bsw@0 | 101 end | 
| jbe/bsw@0 | 102 --//-- | 
| jbe/bsw@0 | 103 | 
| jbe/bsw@0 | 104 --[[-- | 
| jbe/bsw@0 | 105 at_exit( | 
| jbe/bsw@0 | 106   func  -- function to be called before the process is ending | 
| jbe/bsw@0 | 107 ) | 
| jbe/bsw@0 | 108 | 
| jbe/bsw@0 | 109 Registers a function to be called before the CGI process is exiting. | 
| jbe/bsw@0 | 110 --]]-- | 
| jbe/bsw@0 | 111 do | 
| jbe/bsw@0 | 112   local exit_handlers = {} | 
| jbe/bsw@0 | 113   function at_exit(func) | 
| jbe/bsw@0 | 114     table.insert(exit_handlers, func) | 
| jbe/bsw@0 | 115   end | 
| jbe/bsw@0 | 116   function exit(code) | 
| jbe/bsw@0 | 117     for i = #exit_handlers, 1, -1 do | 
| jbe/bsw@0 | 118       exit_handlers[i]() | 
| jbe/bsw@0 | 119     end | 
| jbe/bsw@0 | 120     os.exit(code) | 
| jbe/bsw@0 | 121   end | 
| jbe/bsw@0 | 122 end | 
| jbe/bsw@0 | 123 --//-- | 
| jbe/bsw@0 | 124 | 
| jbe/bsw@0 | 125 --[[-- | 
| jbe/bsw@0 | 126 app  -- table to store an application state | 
| jbe/bsw@0 | 127 | 
| jbe/bsw@0 | 128 'app' is a global table for storing any application state data | 
| jbe/bsw@0 | 129 --]]-- | 
| jbe/bsw@0 | 130 app = {} | 
| jbe/bsw@0 | 131 --//-- | 
| jbe/bsw@0 | 132 | 
| jbe/bsw@0 | 133 --[[-- | 
| jbe/bsw@0 | 134 config  -- table to store application configuration | 
| jbe/bsw@0 | 135 | 
| jbe/bsw@0 | 136 'config' is a global table, which can be modified by a config file of an application to modify the behaviour of that application. | 
| jbe/bsw@0 | 137 --]]-- | 
| jbe/bsw@0 | 138 config = {} | 
| jbe/bsw@0 | 139 --//-- | 
| jbe/bsw@0 | 140 | 
| jbe/bsw@0 | 141 -- autoloader system for WebMCP environment "../env/", | 
| jbe/bsw@0 | 142 -- application environment extensions "$WEBMCP_APP_BASE/env/" | 
| jbe/bsw@0 | 143 -- and models "$WEBMCP_APP_BASE/model/" | 
| jbe/bsw@0 | 144 do | 
| jbe/bsw@0 | 145   local app_base = os.getenv("WEBMCP_APP_BASEPATH") | 
| jbe/bsw@0 | 146   if not app_base then | 
| jbe/bsw@0 | 147     error( | 
| jbe/bsw@0 | 148       "Failed to initialize autoloader " .. | 
| jbe/bsw@0 | 149       "due to unset WEBMCP_APP_BASEPATH environment variable." | 
| jbe/bsw@0 | 150     ) | 
| jbe/bsw@0 | 151   end | 
| jbe/bsw@0 | 152   local weakkey_mt = { __mode = "k" } | 
| jbe/bsw@0 | 153   local autoloader_category = setmetatable({}, weakkey_mt) | 
| jbe/bsw@0 | 154   local autoloader_path     = setmetatable({}, weakkey_mt) | 
| jbe/bsw@0 | 155   local autoloader_mt       = {} | 
| jbe/bsw@0 | 156   local function install_autoloader(self, category, path) | 
| jbe/bsw@0 | 157     autoloader_category[self] = category | 
| jbe/bsw@0 | 158     autoloader_path[self]     = path | 
| jbe/bsw@0 | 159     setmetatable(self, autoloader_mt) | 
| jbe/bsw@0 | 160   end | 
| jbe/bsw@0 | 161   local function try_exec(filename) | 
| jbe/bsw@0 | 162     local file = io.open(filename, "r") | 
| jbe/bsw@0 | 163     if file then | 
| jbe/bsw@0 | 164       local filedata = file:read("*a") | 
| jbe/bsw@0 | 165       io.close(file) | 
| jbe@68 | 166       local func, errmsg = load(filedata, "=" .. filename) | 
| jbe/bsw@0 | 167       if func then | 
| jbe/bsw@0 | 168         func() | 
| jbe/bsw@0 | 169         return true | 
| jbe/bsw@0 | 170       else | 
| jbe/bsw@0 | 171         error(errmsg, 0) | 
| jbe/bsw@0 | 172       end | 
| jbe/bsw@0 | 173     else | 
| jbe/bsw@0 | 174       return false | 
| jbe/bsw@0 | 175     end | 
| jbe/bsw@0 | 176   end | 
| jbe/bsw@0 | 177   local function compose_path_string(base, path, key) | 
| jbe/bsw@0 | 178     return string.gsub( | 
| jbe/bsw@0 | 179       base .. table.concat(path, "/") .. "/" .. key, "/+", "/" | 
| jbe/bsw@0 | 180     ) | 
| jbe/bsw@0 | 181   end | 
| jbe/bsw@0 | 182   function autoloader_mt.__index(self, key) | 
| jbe/bsw@0 | 183     local category, base_path, merge_base_path, file_key | 
| jbe/bsw@0 | 184     local merge = false | 
| jbe/bsw@0 | 185     if | 
| jbe/bsw@0 | 186       string.find(key, "^[a-z_][A-Za-z0-9_]*$") and | 
| jbe/bsw@0 | 187       not string.find(key, "^__") | 
| jbe/bsw@0 | 188     then | 
| jbe/bsw@0 | 189       category        = "env" | 
| jbe@43 | 190       base_path       = WEBMCP_PATH .. "/env/" | 
| jbe/bsw@0 | 191       merge           = true | 
| jbe/bsw@0 | 192       merge_base_path = app_base .. "/env/" | 
| jbe/bsw@0 | 193       file_key        = key | 
| jbe/bsw@0 | 194     elseif string.find(key, "^[A-Z][A-Za-z0-9]*$") then | 
| jbe/bsw@0 | 195       category        = "model" | 
| jbe/bsw@0 | 196       base_path       = app_base .. "/model/" | 
| jbe/bsw@0 | 197       local first = true | 
| jbe/bsw@0 | 198       file_key = string.gsub(key, "[A-Z]", | 
| jbe/bsw@0 | 199         function(c) | 
| jbe/bsw@0 | 200           if first then | 
| jbe/bsw@0 | 201             first = false | 
| jbe/bsw@0 | 202             return string.lower(c) | 
| jbe/bsw@0 | 203           else | 
| jbe/bsw@0 | 204             return "_" .. string.lower(c) | 
| jbe/bsw@0 | 205           end | 
| jbe/bsw@0 | 206         end | 
| jbe/bsw@0 | 207       ) | 
| jbe/bsw@0 | 208     else | 
| jbe/bsw@0 | 209       return | 
| jbe/bsw@0 | 210     end | 
| jbe/bsw@0 | 211     local required_category = autoloader_category[self] | 
| jbe/bsw@0 | 212     if required_category and required_category ~= category then return end | 
| jbe/bsw@0 | 213     local path = autoloader_path[self] | 
| jbe/bsw@0 | 214     local path_string = compose_path_string(base_path, path, file_key) | 
| jbe/bsw@0 | 215     local merge_path_string | 
| jbe/bsw@0 | 216     if merge then | 
| jbe/bsw@0 | 217       merge_path_string = compose_path_string( | 
| jbe/bsw@0 | 218         merge_base_path, path, file_key | 
| jbe/bsw@0 | 219       ) | 
| jbe/bsw@0 | 220     end | 
| jbe/bsw@0 | 221     local function try_dir(dirname) | 
| jbe/bsw@0 | 222       local dir = io.open(dirname) | 
| jbe/bsw@0 | 223       if dir then | 
| jbe/bsw@0 | 224         io.close(dir) | 
| jbe/bsw@0 | 225         local obj = {} | 
| jbe/bsw@0 | 226         local sub_path = {} | 
| jbe/bsw@0 | 227         for i, v in ipairs(path) do sub_path[i] = v end | 
| jbe/bsw@0 | 228         table.insert(sub_path, file_key) | 
| jbe/bsw@0 | 229         install_autoloader(obj, category, sub_path) | 
| jbe/bsw@0 | 230         rawset(self, key, obj) | 
| jbe/bsw@0 | 231         try_exec(path_string .. "/__init.lua") | 
| jbe/bsw@0 | 232         if merge then try_exec(merge_path_string .. "/__init.lua") end | 
| jbe/bsw@0 | 233         return true | 
| jbe/bsw@0 | 234       else | 
| jbe/bsw@0 | 235         return false | 
| jbe/bsw@0 | 236       end | 
| jbe/bsw@0 | 237     end | 
| jbe/bsw@0 | 238     if merge and try_exec(merge_path_string .. ".lua") then | 
| jbe/bsw@0 | 239     elseif merge and try_dir(merge_path_string .. "/") then | 
| jbe/bsw@0 | 240     elseif try_exec(path_string .. ".lua") then | 
| jbe/bsw@0 | 241     elseif try_dir(path_string .. "/") then | 
| jbe/bsw@0 | 242     else end | 
| jbe/bsw@0 | 243     return rawget(self, key) | 
| jbe/bsw@0 | 244   end | 
| jbe/bsw@0 | 245   install_autoloader(_G, nil, {}) | 
| jbe@43 | 246   try_exec(WEBMCP_PATH .. "env/__init.lua") | 
| jbe/bsw@0 | 247 end | 
| jbe/bsw@0 | 248 | 
| jbe/bsw@0 | 249 -- interactive console mode | 
| jbe/bsw@0 | 250 if not cgi then | 
| jbe@86 | 251   trace.disable()  -- avoids memory leakage | 
| jbe/bsw@0 | 252   local config_name = request.get_config_name() | 
| jbe/bsw@0 | 253   if config_name then | 
| jbe/bsw@0 | 254     execute.config(config_name) | 
| jbe/bsw@0 | 255   end | 
| jbe/bsw@0 | 256   return | 
| jbe/bsw@0 | 257 end | 
| jbe/bsw@0 | 258 | 
| jbe/bsw@0 | 259 local success, error_info = xpcall( | 
| jbe/bsw@0 | 260   function() | 
| jbe/bsw@0 | 261 | 
| jbe/bsw@0 | 262     -- execute configuration file | 
| jbe/bsw@0 | 263     do | 
| jbe/bsw@0 | 264       local config_name = request.get_config_name() | 
| jbe/bsw@0 | 265       if config_name then | 
| jbe/bsw@0 | 266         execute.config(config_name) | 
| jbe/bsw@0 | 267       end | 
| jbe/bsw@0 | 268     end | 
| jbe/bsw@0 | 269 | 
| jbe/bsw@0 | 270     -- restore slots if coming from http redirect | 
| jbe/bsw@0 | 271     if cgi.params.tempstore then | 
| jbe/bsw@0 | 272       trace.restore_slots{} | 
| jbe/bsw@0 | 273       local blob = tempstore.pop(cgi.params.tempstore) | 
| jbe/bsw@0 | 274       if blob then slot.restore_all(blob) end | 
| jbe/bsw@0 | 275     end | 
| jbe/bsw@0 | 276 | 
| jbe/bsw@0 | 277     local function file_exists(filename) | 
| jbe/bsw@0 | 278       local file = io.open(filename, "r") | 
| jbe/bsw@0 | 279       if file then | 
| jbe/bsw@0 | 280         io.close(file) | 
| jbe/bsw@0 | 281         return true | 
| jbe/bsw@0 | 282       else | 
| jbe/bsw@0 | 283         return false | 
| jbe/bsw@0 | 284       end | 
| jbe/bsw@0 | 285     end | 
| jbe/bsw@0 | 286 | 
| jbe@97 | 287     if request.is_404() then | 
| jbe/bsw@0 | 288       request.set_status("404 Not Found") | 
| jbe/bsw@0 | 289       if request.get_404_route() then | 
| jbe/bsw@0 | 290         request.forward(request.get_404_route()) | 
| jbe/bsw@0 | 291       else | 
| jbe/bsw@0 | 292         error("No 404 page set.") | 
| jbe/bsw@0 | 293       end | 
| jbe/bsw@0 | 294     elseif request.get_action() then | 
| jbe/bsw@0 | 295       trace.request{ | 
| jbe/bsw@0 | 296         module = request.get_module(), | 
| jbe/bsw@0 | 297         action = request.get_action() | 
| jbe/bsw@0 | 298       } | 
| jbe/bsw@0 | 299       if | 
| jbe/bsw@0 | 300         request.get_404_route() and | 
| jbe/bsw@0 | 301         not file_exists( | 
| jbe/bsw@0 | 302           encode.action_file_path{ | 
| jbe/bsw@0 | 303             module = request.get_module(), | 
| jbe/bsw@0 | 304             action = request.get_action() | 
| jbe/bsw@0 | 305           } | 
| jbe/bsw@0 | 306         ) | 
| jbe/bsw@0 | 307       then | 
| jbe/bsw@0 | 308         request.set_status("404 Not Found") | 
| jbe/bsw@0 | 309         request.forward(request.get_404_route()) | 
| jbe/bsw@0 | 310       else | 
| jbe/bsw@0 | 311         if cgi.method ~= "POST" then | 
| jbe/bsw@0 | 312           request.set_status("405 Method Not Allowed") | 
| jbe/bsw@0 | 313           cgi.add_header("Allow: POST") | 
| jbe/bsw@0 | 314           error("Tried to invoke an action with a GET request.") | 
| jbe/bsw@0 | 315         end | 
| jbe/bsw@0 | 316         local action_status = execute.filtered_action{ | 
| jbe/bsw@0 | 317           module = request.get_module(), | 
| jbe/bsw@0 | 318           action = request.get_action(), | 
| jbe/bsw@0 | 319         } | 
| jbe/bsw@0 | 320         if not request.is_rerouted() then | 
| jbe/bsw@0 | 321           local routing_mode, routing_module, routing_view | 
| jbe/bsw@0 | 322           routing_mode   = cgi.params["_webmcp_routing." .. action_status .. ".mode"] | 
| jbe/bsw@0 | 323           routing_module = cgi.params["_webmcp_routing." .. action_status .. ".module"] | 
| jbe/bsw@0 | 324           routing_view   = cgi.params["_webmcp_routing." .. action_status .. ".view"] | 
| jbe@113 | 325           routing_anchor = cgi.params["_webmcp_routing." .. action_status .. ".anchor"] | 
| jbe/bsw@0 | 326           if not (routing_mode or routing_module or routing_view) then | 
| jbe/bsw@0 | 327             action_status = "default" | 
| jbe/bsw@0 | 328             routing_mode   = cgi.params["_webmcp_routing.default.mode"] | 
| jbe/bsw@0 | 329             routing_module = cgi.params["_webmcp_routing.default.module"] | 
| jbe/bsw@0 | 330             routing_view   = cgi.params["_webmcp_routing.default.view"] | 
| jbe@113 | 331             routing_anchor = cgi.params["_webmcp_routing.default.anchor"] | 
| jbe/bsw@0 | 332           end | 
| jbe/bsw@0 | 333           assert(routing_module, "Routing information has no module.") | 
| jbe/bsw@0 | 334           assert(routing_view,   "Routing information has no view.") | 
| jbe/bsw@0 | 335           if routing_mode == "redirect" then | 
| jbe/bsw@0 | 336             local routing_params = {} | 
| jbe/bsw@0 | 337             for key, value in pairs(cgi.params) do | 
| jbe/bsw@0 | 338               local status, stripped_key = string.match( | 
| jbe/bsw@0 | 339                 key, "^_webmcp_routing%.([^%.]*)%.params%.(.*)$" | 
| jbe/bsw@0 | 340               ) | 
| jbe/bsw@0 | 341               if status == action_status then | 
| jbe/bsw@0 | 342                 routing_params[stripped_key] = value | 
| jbe/bsw@0 | 343               end | 
| jbe/bsw@0 | 344             end | 
| jbe/bsw@0 | 345             request.redirect{ | 
| jbe/bsw@0 | 346               module = routing_module, | 
| jbe/bsw@0 | 347               view   = routing_view, | 
| jbe/bsw@0 | 348               id     = cgi.params["_webmcp_routing." .. action_status .. ".id"], | 
| jbe@113 | 349               params = routing_params, | 
| jbe@113 | 350               anchor = routing_anchor | 
| jbe/bsw@0 | 351             } | 
| jbe/bsw@0 | 352           elseif routing_mode == "forward" then | 
| jbe/bsw@0 | 353             request.forward{ module = routing_module, view = routing_view } | 
| jbe/bsw@0 | 354           else | 
| jbe/bsw@0 | 355             error("Missing or unknown routing mode in request parameters.") | 
| jbe/bsw@0 | 356           end | 
| jbe/bsw@0 | 357         end | 
| jbe/bsw@0 | 358       end | 
| jbe/bsw@0 | 359     else | 
| jbe/bsw@0 | 360       -- no action | 
| jbe/bsw@0 | 361       trace.request{ | 
| jbe/bsw@0 | 362         module = request.get_module(), | 
| jbe/bsw@0 | 363         view   = request.get_view() | 
| jbe/bsw@0 | 364       } | 
| jbe/bsw@0 | 365       if | 
| jbe/bsw@0 | 366         request.get_404_route() and | 
| jbe/bsw@0 | 367         not file_exists( | 
| jbe/bsw@0 | 368           encode.view_file_path{ | 
| jbe/bsw@0 | 369             module = request.get_module(), | 
| jbe/bsw@0 | 370             view   = request.get_view() | 
| jbe/bsw@0 | 371           } | 
| jbe/bsw@0 | 372         ) | 
| jbe/bsw@0 | 373       then | 
| jbe/bsw@0 | 374         request.set_status("404 Not Found") | 
| jbe/bsw@0 | 375         request.forward(request.get_404_route()) | 
| jbe/bsw@0 | 376       end | 
| jbe/bsw@0 | 377     end | 
| jbe/bsw@0 | 378 | 
| jbe/bsw@0 | 379     if not request.get_redirect_data() then | 
| jbe@3 | 380       request.process_forward() | 
| jbe/bsw@2 | 381       local view = request.get_view() | 
| jbe/bsw@2 | 382       if string.find(view, "^_") then | 
| jbe/bsw@2 | 383         error("Tried to call a private view (prefixed with underscore).") | 
| jbe/bsw@2 | 384       end | 
| jbe/bsw@0 | 385       execute.filtered_view{ | 
| jbe/bsw@0 | 386         module = request.get_module(), | 
| jbe/bsw@2 | 387         view   = view, | 
| jbe/bsw@0 | 388       } | 
| jbe/bsw@0 | 389     end | 
| jbe/bsw@0 | 390 | 
| jbe/bsw@0 | 391     -- force error due to missing absolute base URL until its too late to display error message | 
| jbe/bsw@0 | 392     --if request.get_redirect_data() then | 
| jbe/bsw@0 | 393     --  request.get_absolute_baseurl() | 
| jbe/bsw@0 | 394     --end | 
| jbe/bsw@0 | 395 | 
| jbe/bsw@0 | 396   end, | 
| jbe/bsw@0 | 397 | 
| jbe/bsw@0 | 398   function(errobj) | 
| jbe/bsw@0 | 399     return { | 
| jbe/bsw@0 | 400       errobj = errobj, | 
| jbe/bsw@0 | 401       stacktrace = string.gsub( | 
| jbe/bsw@0 | 402         debug.traceback('', 2), | 
| jbe/bsw@0 | 403         "^\r?\n?stack traceback:\r?\n?", "" | 
| jbe/bsw@0 | 404       ) | 
| jbe/bsw@0 | 405     } | 
| jbe/bsw@0 | 406   end | 
| jbe/bsw@0 | 407 ) | 
| jbe/bsw@0 | 408 | 
| jbe/bsw@0 | 409 if not success then trace.error{} end | 
| jbe/bsw@0 | 410 | 
| jbe/bsw@0 | 411 -- laufzeitermittlung | 
| jbe@65 | 412 trace.exectime{ real = extos.monotonic_hires_time(), cpu = os.clock() } | 
| jbe/bsw@0 | 413 | 
| jbe/bsw@0 | 414 slot.select('trace', trace.render)  -- render trace information | 
| jbe/bsw@0 | 415 | 
| jbe/bsw@0 | 416 local redirect_data = request.get_redirect_data() | 
| jbe/bsw@0 | 417 | 
| jbe/bsw@0 | 418 -- log error and switch to error layout, unless success | 
| jbe/bsw@0 | 419 if not success then | 
| jbe/bsw@0 | 420   local errobj     = error_info.errobj | 
| jbe/bsw@0 | 421   local stacktrace = error_info.stacktrace | 
| jbe/bsw@11 | 422   if not request.get_status() and not request.get_json_request_slots() then | 
| jbe/bsw@0 | 423     request.set_status("500 Internal Server Error") | 
| jbe/bsw@0 | 424   end | 
| jbe/bsw@0 | 425   slot.set_layout('system_error') | 
| jbe/bsw@0 | 426   slot.select('system_error', function() | 
| jbe/bsw@0 | 427     if getmetatable(errobj) == mondelefant.errorobject_metatable then | 
| jbe/bsw@0 | 428       slot.put( | 
| jbe/bsw@0 | 429         "<p>Database error of class <b>", | 
| jbe/bsw@0 | 430         encode.html(errobj.code), | 
| jbe/bsw@0 | 431         "</b> occured:<br/><b>", | 
| jbe/bsw@0 | 432         encode.html(errobj.message), | 
| jbe/bsw@0 | 433         "</b></p>" | 
| jbe/bsw@0 | 434       ) | 
| jbe/bsw@0 | 435     else | 
| jbe/bsw@0 | 436       slot.put("<p><b>", encode.html(tostring(errobj)), "</b></p>") | 
| jbe/bsw@0 | 437     end | 
| jbe/bsw@0 | 438     slot.put("<p>Stack trace follows:<br/>") | 
| jbe/bsw@0 | 439     slot.put(encode.html_newlines(encode.html(stacktrace))) | 
| jbe/bsw@0 | 440     slot.put("</p>") | 
| jbe/bsw@0 | 441   end) | 
| jbe/bsw@0 | 442 elseif redirect_data then | 
| jbe/bsw@0 | 443   local redirect_params = {} | 
| jbe/bsw@0 | 444   for key, value in pairs(redirect_data.params) do | 
| jbe/bsw@0 | 445     redirect_params[key] = value | 
| jbe/bsw@0 | 446   end | 
| jbe/bsw@0 | 447   local slot_dump = slot.dump_all() | 
| jbe/bsw@0 | 448   if slot_dump ~= "" then | 
| jbe/bsw@0 | 449     redirect_params.tempstore = tempstore.save(slot_dump) | 
| jbe/bsw@0 | 450   end | 
| jbe/bsw@11 | 451   local json_request_slots = request.get_json_request_slots() | 
| jbe/bsw@11 | 452   if json_request_slots then | 
| jbe/bsw@11 | 453     redirect_params["_webmcp_json_slots[]"] = json_request_slots | 
| jbe/bsw@11 | 454   end | 
| jbe/bsw@0 | 455   cgi.redirect( | 
| jbe/bsw@0 | 456     encode.url{ | 
| jbe/bsw@0 | 457       base   = request.get_absolute_baseurl(), | 
| jbe/bsw@0 | 458       module = redirect_data.module, | 
| jbe/bsw@0 | 459       view   = redirect_data.view, | 
| jbe/bsw@0 | 460       id     = redirect_data.id, | 
| jbe@113 | 461       params = redirect_params, | 
| jbe@113 | 462       anchor = redirect_data.anchor | 
| jbe/bsw@0 | 463     } | 
| jbe/bsw@0 | 464   ) | 
| jbe/bsw@0 | 465   cgi.send_data() | 
| jbe/bsw@0 | 466 end | 
| jbe/bsw@0 | 467 | 
| jbe/bsw@0 | 468 if not success or not redirect_data then | 
| jbe/bsw@0 | 469 | 
| jbe/bsw@0 | 470   local http_status = request.get_status() | 
| jbe/bsw@0 | 471   if http_status then | 
| jbe/bsw@0 | 472     cgi.set_status(http_status) | 
| jbe/bsw@0 | 473   end | 
| jbe/bsw@0 | 474 | 
| jbe@1 | 475   local json_request_slots = request.get_json_request_slots() | 
| jbe@1 | 476   if json_request_slots then | 
| jbe@1 | 477     cgi.set_content_type('application/json') | 
| jbe@1 | 478     local data = {} | 
| jbe@1 | 479     for idx, slot_ident in ipairs(json_request_slots) do | 
| jbe@1 | 480       data[slot_ident] = slot.get_content(slot_ident) | 
| jbe/bsw@0 | 481     end | 
| jbe@1 | 482     cgi.send_data(encode.json(data)) | 
| jbe/bsw@0 | 483   else | 
| jbe/bsw@0 | 484     cgi.set_content_type(slot.get_content_type()) | 
| jbe/bsw@0 | 485     cgi.send_data(slot.render_layout()) | 
| jbe/bsw@0 | 486   end | 
| jbe/bsw@0 | 487 end | 
| jbe/bsw@0 | 488 | 
| jbe/bsw@0 | 489 exit() |