webmcp

annotate framework/env/request/handler.lua @ 270:aedd13009ddc

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