webmcp

annotate framework/env/request/handler.lua @ 266:98537ccd0800

find changesets by author, revision, files, or words in the commit message
Renamed local variable in mcp.lua to avoid shaddowing of global "request" variable
author jbe
date Fri Mar 20 13:41:28 2015 +0100 (2015-03-20)
parents 8aa38ddcc1b2
children 56d237b81c18
rev   line source
jbe@215 1 --[[--
jbe@215 2 request.handler(
jbe@264 3 request, -- HTTP request object
jbe@264 4 close -- boolean indicating whether the server should announce to close the connection
jbe@215 5 )
jbe@215 6
jbe@255 7 Called by mcp.lua to process an HTTP request. Performs some initializations, calls request.router(), and handles the request.
jbe@215 8
jbe@215 9 --]]--
jbe@210 10
jbe@255 11 local function file_exists(filename)
jbe@255 12 local file = io.open(filename, "r")
jbe@255 13 if file then
jbe@255 14 io.close(file)
jbe@255 15 return true
jbe@255 16 else
jbe@255 17 return false
jbe@255 18 end
jbe@255 19 end
jbe@255 20
jbe@255 21 -- TODO: function incomplete yet
jbe@264 22 function request.handler(http_request, close)
jbe@258 23 _G.app = {} -- may be overwritten or modified by request initializers
jbe@255 24 do
jbe@255 25 request._in_progress = true -- NOTE: must be set to true before initializer functions are called
jbe@255 26 for i, func in ipairs(request._initializers) do
jbe@262 27 func()
jbe@255 28 end
jbe@255 29 end
jbe@255 30
jbe@212 31 request._http_request = http_request
jbe@215 32 local path = http_request.path
jbe@215 33 if path then
jbe@221 34 local relative_baseurl_elements = {}
jbe@215 35 for match in string.gmatch(path, "/") do
jbe@221 36 relative_baseurl_elements[#relative_baseurl_elements+1] = "../"
jbe@215 37 end
jbe@221 38 request._relative_baseurl = table.concat(relative_baseurl_elements)
jbe@215 39 else
jbe@215 40 request._relative_baseurl = nil
jbe@215 41 end
jbe@241 42 request._route = request.router() or {}
jbe@255 43
jbe@264 44 if close then
jbe@264 45 request.add_header("Connection", "close")
jbe@264 46 end
jbe@264 47
jbe@255 48 local success, error_info = xpcall(
jbe@255 49 function()
jbe@255 50
jbe@255 51 if request._route.static then
jbe@255 52 local f = assert(io.open(WEBMCP_BASE_PATH .. "static/" .. request._route.static, "r"))
jbe@255 53 local d = f:read("*a")
jbe@255 54 f:close()
jbe@255 55 slot.put_into("data", d)
jbe@255 56 slot.set_layout(nil, "application/octet-stream") -- TODO
jbe@255 57 return
jbe@255 58 end
jbe@255 59
jbe@255 60 -- restore slots if coming from http redirect
jbe@255 61 local tempstore_value = http_request.get_params["_tempstore"]
jbe@255 62 if tempstore_value then
jbe@255 63 trace.restore_slots{}
jbe@255 64 local blob = tempstore.pop(tempstore_value)
jbe@255 65 if blob then slot.restore_all(blob) end
jbe@255 66 end
jbe@255 67
jbe@255 68 if request.get_action() then
jbe@255 69 trace.request{
jbe@255 70 module = request.get_module(),
jbe@255 71 action = request.get_action()
jbe@255 72 }
jbe@255 73 if
jbe@255 74 request.get_404_route() and
jbe@255 75 not file_exists(
jbe@255 76 encode.action_file_path{
jbe@255 77 module = request.get_module(),
jbe@255 78 action = request.get_action()
jbe@255 79 }
jbe@255 80 )
jbe@255 81 then
jbe@255 82 request.set_status("404 Not Found")
jbe@255 83 request.forward(request.get_404_route())
jbe@255 84 else
jbe@255 85 if http_request.method ~= "POST" then
jbe@255 86 request.set_status("405 Method Not Allowed")
jbe@255 87 request.add_header("Allow", "POST")
jbe@255 88 error("Tried to invoke an action with a GET request.")
jbe@255 89 end
jbe@255 90 local action_status = execute.filtered_action{
jbe@255 91 module = request.get_module(),
jbe@255 92 action = request.get_action(),
jbe@255 93 }
jbe@255 94 if not request.is_rerouted() then
jbe@255 95 local routing_mode, routing_module, routing_view, routing_anchor
jbe@255 96 routing_mode = http_request.post_params["_webmcp_routing." .. action_status .. ".mode"]
jbe@255 97 routing_module = http_request.post_params["_webmcp_routing." .. action_status .. ".module"]
jbe@255 98 routing_view = http_request.post_params["_webmcp_routing." .. action_status .. ".view"]
jbe@255 99 routing_anchor = http_request.post_params["_webmcp_routing." .. action_status .. ".anchor"]
jbe@255 100 if not (routing_mode or routing_module or routing_view) then
jbe@255 101 action_status = "default"
jbe@255 102 routing_mode = http_request.post_params["_webmcp_routing.default.mode"]
jbe@255 103 routing_module = http_request.post_params["_webmcp_routing.default.module"]
jbe@255 104 routing_view = http_request.post_params["_webmcp_routing.default.view"]
jbe@255 105 routing_anchor = http_request.post_params["_webmcp_routing.default.anchor"]
jbe@255 106 end
jbe@255 107 assert(routing_module, "Routing information has no module.")
jbe@255 108 assert(routing_view, "Routing information has no view.")
jbe@255 109 if routing_mode == "redirect" then
jbe@255 110 local routing_params = {}
jbe@255 111 for key, value in pairs(request.get_param_strings{ method="POST", include_internal=true }) do
jbe@255 112 local status, stripped_key = string.match(
jbe@255 113 key, "^_webmcp_routing%.([^%.]*)%.params%.(.*)$"
jbe@255 114 )
jbe@255 115 if status == action_status then
jbe@255 116 routing_params[stripped_key] = value
jbe@255 117 end
jbe@255 118 end
jbe@255 119 request.redirect{
jbe@255 120 module = routing_module,
jbe@255 121 view = routing_view,
jbe@255 122 id = http_request.post_params["_webmcp_routing." .. action_status .. ".id"],
jbe@255 123 params = routing_params,
jbe@255 124 anchor = routing_anchor
jbe@255 125 }
jbe@255 126 elseif routing_mode == "forward" then
jbe@255 127 request.forward{ module = routing_module, view = routing_view }
jbe@255 128 else
jbe@255 129 error("Missing or unknown routing mode in request parameters.")
jbe@255 130 end
jbe@255 131 end
jbe@255 132 end
jbe@255 133 else
jbe@255 134 -- no action
jbe@255 135 trace.request{
jbe@255 136 module = request.get_module(),
jbe@255 137 view = request.get_view()
jbe@255 138 }
jbe@255 139 if
jbe@255 140 request.get_404_route() and
jbe@255 141 not file_exists(
jbe@255 142 encode.view_file_path{
jbe@255 143 module = request.get_module(),
jbe@255 144 view = request.get_view()
jbe@255 145 }
jbe@255 146 )
jbe@255 147 then
jbe@255 148 request.set_status("404 Not Found")
jbe@255 149 request.forward(request.get_404_route())
jbe@255 150 end
jbe@255 151 end
jbe@255 152
jbe@255 153 if not request.get_redirect_data() then
jbe@255 154 request.process_forward()
jbe@255 155 local view = request.get_view()
jbe@255 156 if string.find(view, "^_") then
jbe@255 157 error("Tried to call a private view (prefixed with underscore).")
jbe@255 158 end
jbe@255 159 execute.filtered_view{
jbe@255 160 module = request.get_module(),
jbe@255 161 view = view,
jbe@255 162 }
jbe@255 163 end
jbe@255 164
jbe@255 165 -- force error due to missing absolute base URL until its too late to display error message
jbe@255 166 --if request.get_redirect_data() then
jbe@255 167 -- request.get_absolute_baseurl()
jbe@255 168 --end
jbe@255 169
jbe@255 170 end,
jbe@255 171
jbe@255 172 function(errobj)
jbe@255 173 return {
jbe@255 174 errobj = errobj,
jbe@255 175 stacktrace = string.gsub(
jbe@255 176 debug.traceback('', 2),
jbe@255 177 "^\r?\n?stack traceback:\r?\n?", ""
jbe@255 178 )
jbe@255 179 }
jbe@255 180 end
jbe@255 181 )
jbe@255 182
jbe@255 183 if not success then trace.error{} end
jbe@255 184
jbe@255 185 -- TODO: extend trace system to generally monitor execution time
jbe@255 186 -- trace.exectime{ real = extos.monotonic_hires_time(), cpu = os.clock() }
jbe@255 187
jbe@255 188 slot.select('trace', trace.render) -- render trace information
jbe@255 189
jbe@255 190 local redirect_data = request.get_redirect_data()
jbe@255 191
jbe@255 192 -- log error and switch to error layout, unless success
jbe@255 193 if not success then
jbe@255 194 local errobj = error_info.errobj
jbe@255 195 local stacktrace = error_info.stacktrace
jbe@255 196 if not request._status then
jbe@255 197 request._status = "500 Internal Server Error"
jbe@255 198 end
jbe@255 199 slot.set_layout('system_error')
jbe@255 200 slot.select('system_error', function()
jbe@255 201 if getmetatable(errobj) == mondelefant.errorobject_metatable then
jbe@255 202 slot.put(
jbe@255 203 "<p>Database error of class <b>",
jbe@255 204 encode.html(errobj.code),
jbe@255 205 "</b> occured:<br/><b>",
jbe@255 206 encode.html(errobj.message),
jbe@255 207 "</b></p>"
jbe@255 208 )
jbe@255 209 else
jbe@255 210 slot.put("<p><b>", encode.html(tostring(errobj)), "</b></p>")
jbe@255 211 end
jbe@255 212 slot.put("<p>Stack trace follows:<br/>")
jbe@255 213 slot.put(encode.html_newlines(encode.html(stacktrace)))
jbe@255 214 slot.put("</p>")
jbe@255 215 end)
jbe@255 216 elseif redirect_data then
jbe@255 217 local redirect_params = {}
jbe@255 218 for key, value in pairs(redirect_data.params) do
jbe@255 219 redirect_params[key] = value
jbe@255 220 end
jbe@255 221 local slot_dump = slot.dump_all()
jbe@255 222 if slot_dump ~= "" then
jbe@255 223 redirect_params.tempstore = tempstore.save(slot_dump)
jbe@255 224 end
jbe@255 225 http_request:send_status("303 See Other")
jbe@264 226 for i, header in ipairs(request._response_headers) do
jbe@264 227 http_request:send_header(header[1], header[2])
jbe@264 228 end
jbe@255 229 http_request:send_header(
jbe@255 230 "Location",
jbe@255 231 encode.url{
jbe@255 232 base = request.get_absolute_baseurl(),
jbe@255 233 module = redirect_data.module,
jbe@255 234 view = redirect_data.view,
jbe@255 235 id = redirect_data.id,
jbe@255 236 params = redirect_params,
jbe@255 237 anchor = redirect_data.anchor
jbe@255 238 }
jbe@255 239 )
jbe@255 240 http_request:finish()
jbe@255 241 end
jbe@255 242
jbe@255 243 if not success or not redirect_data then
jbe@255 244
jbe@255 245 http_request:send_status(request._status or "200 OK")
jbe@255 246 for i, header in ipairs(request._response_headers) do
jbe@255 247 http_request:send_header(header[1], header[2])
jbe@255 248 end
jbe@255 249 http_request:send_header("Content-Type", slot.get_content_type())
jbe@255 250 http_request:send_data(slot.render_layout())
jbe@255 251 http_request:finish()
jbe@255 252 end
jbe@255 253
jbe@215 254 end
jbe@258 255
jbe@258 256 --//--
jbe@258 257
jbe@258 258 --[[--
jbe@258 259 app -- table to store an application state
jbe@258 260
jbe@258 261 'app' is a global table for storing any application state data. It will be reset for every request.
jbe@258 262 --]]--
jbe@258 263
jbe@258 264 -- Initialized in request.handler(...).
jbe@258 265
jbe@258 266 --//--

Impressum / About Us