prosody: net/http/server.lua@d53142e90cd0 (annotated)

4631 fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	1
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	2	local t_insert, t_remove, t_concat = table.insert, table.remove, table.concat;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	3	local parser_new = require "net.http.parser".new;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	4	local events = require "util.events".new();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	5	local addserver = require "net.server".addserver;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	6	local log = require "util.logger".init("http.server");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	7	local os_date = os.date;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	8	local pairs = pairs;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	9	local s_upper = string.upper;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	10	local setmetatable = setmetatable;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	11	local xpcall = xpcall;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	12	local debug = debug;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	13	local tostring = tostring;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	14	local codes = require "net.http.codes";
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	15	local _G = _G;
4659 d53142e90cd0 net.http.server: Fix legacy net.httpserver fallback (httpserver is no longer a global). Waqas Hussain <waqas20@gmail.com> parents: 4634 diff changeset	16	local legacy_httpserver = require "net.httpserver";
4631 fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	17
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	18	local _M = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	19
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	20	local sessions = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	21	local handlers = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	22
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	23	local listener = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	24
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	25	local handle_request;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	26	local _1, _2, _3;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	27	local function _handle_request() return handle_request(_1, _2, _3); end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	28	local function _traceback_handler(err) log("error", "Traceback[http]: %s: %s", tostring(err), debug.traceback()); end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	29
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	30	function listener.onconnect(conn)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	31	local secure = conn:ssl() and true or nil;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	32	local pending = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	33	local waiting = false;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	34	local function process_next(last_response)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	35	--if waiting then log("debug", "can't process_next, waiting"); return; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	36	if sessions[conn] and #pending > 0 then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	37	local request = t_remove(pending);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	38	--log("debug", "process_next: %s", request.path);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	39	waiting = true;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	40	--handle_request(conn, request, process_next);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	41	_1, _2, _3 = conn, request, process_next;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	42	if not xpcall(_handle_request, _traceback_handler) then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	43	conn:write("HTTP/1.0 503 Internal Server Error\r\n\r\nAn error occured during the processing of this request.");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	44	conn:close();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	45	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	46	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	47	--log("debug", "ready for more");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	48	waiting = false;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	49	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	50	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	51	local function success_cb(request)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	52	--log("debug", "success_cb: %s", request.path);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	53	request.secure = secure;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	54	t_insert(pending, request);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	55	if not waiting then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	56	process_next();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	57	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	58	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	59	local function error_cb(err)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	60	log("debug", "error_cb: %s", err or "<nil>");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	61	-- FIXME don't close immediately, wait until we process current stuff
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	62	-- FIXME if err, send off a bad-request response
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	63	sessions[conn] = nil;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	64	conn:close();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	65	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	66	sessions[conn] = parser_new(success_cb, error_cb);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	67	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	68
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	69	function listener.ondisconnect(conn)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	70	sessions[conn] = nil;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	71	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	72
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	73	function listener.onincoming(conn, data)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	74	sessions[conn]:feed(data);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	75	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	76
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	77	local headerfix = setmetatable({}, {
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	78	__index = function(t, k)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	79	local v = "\r\n"..k:gsub("_", "-"):gsub("%f[%w].", s_upper)..": ";
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	80	t[k] = v;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	81	return v;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	82	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	83	});
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	84
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	85	function _M.hijack_response(response, listener)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	86	error("TODO");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	87	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	88	function handle_request(conn, request, finish_cb)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	89	--log("debug", "handler: %s", request.path);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	90	local headers = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	91	for k,v in pairs(request.headers) do headers[k:gsub("-", "_")] = v; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	92	request.headers = headers;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	93	request.conn = conn;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	94
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	95	local date_header = os_date('!%a, %d %b %Y %H:%M:%S GMT'); -- FIXME use
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	96	local conn_header = request.headers.connection;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	97	local keep_alive = conn_header == "Keep-Alive" or (request.httpversion == "1.1" and conn_header ~= "close");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	98
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	99	local response = {
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	100	request = request;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	101	status_code = 200;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	102	headers = { date = date_header, connection = (keep_alive and "Keep-Alive" or "close") };
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	103	conn = conn;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	104	send = _M.send_response;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	105	finish_cb = finish_cb;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	106	};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	107
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	108	if not request.headers.host then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	109	response.status_code = 400;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	110	response.headers.content_type = "text/html";
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	111	response:send("<html><head>400 Bad Request</head><body>400 Bad Request: No Host header.</body></html>");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	112	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	113	-- TODO call handler
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	114	--response.headers.content_type = "text/plain";
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	115	--response:send("host="..(request.headers.host or "").."\npath="..request.path.."\n"..(request.body or ""));
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	116	local host = request.headers.host;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	117	if host then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	118	host = host:match("[^:]*"):lower();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	119	local event = request.method.." "..host..request.path:match("[^?]*");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	120	local payload = { request = request, response = response };
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	121	--[[repeat
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	122	if events.fire_event(event, payload) ~= nil then return; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	123	event = (event:sub(-1) == "/") and event:sub(1, -1) or event:gsub("[^/]*$", "");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	124	if event:sub(-1) == "/" then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	125	event = event:sub(1, -1);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	126	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	127	event = event:gsub("[^/]*$", "");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	128	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	129	until not event:find("/", 1, true);]]
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	130	--log("debug", "Event: %s", event);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	131	if events.fire_event(event, payload) ~= nil then return; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	132	-- TODO try adding/stripping / at the end, but this needs to work via an HTTP redirect
4634 8e582afc214d net.http.server: Fire global HTTP event when no specific handlers available. Waqas Hussain <waqas20@gmail.com> parents: 4633 diff changeset	133	if events.fire_event("*", payload) ~= nil then return; end
4631 fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	134	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	135
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	136	-- if handler not called, fallback to legacy httpserver handlers
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	137	_M.legacy_handler(request, response);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	138	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	139	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	140	function _M.send_response(response, body)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	141	local status_line = "HTTP/"..response.request.httpversion.." "..(response.status or codes[response.status_code]);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	142	local headers = response.headers;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	143	body = body or "";
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	144	headers.content_length = #body;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	145
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	146	local output = { status_line };
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	147	for k,v in pairs(headers) do
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	148	t_insert(output, headerfix[k]..v);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	149	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	150	t_insert(output, "\r\n\r\n");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	151	t_insert(output, body);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	152
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	153	response.conn:write(t_concat(output));
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	154	if headers.connection == "Keep-Alive" then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	155	response:finish_cb();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	156	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	157	response.conn:close();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	158	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	159	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	160	function _M.legacy_handler(request, response)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	161	log("debug", "Invoking legacy handler");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	162	local base = request.path:match("^/([^/?]+)");
4659 d53142e90cd0 net.http.server: Fix legacy net.httpserver fallback (httpserver is no longer a global). Waqas Hussain <waqas20@gmail.com> parents: 4634 diff changeset	163	local legacy_server = legacy_httpserver and legacy_httpserver.new.http_servers[5280];
4631 fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	164	local handler = legacy_server and legacy_server.handlers[base];
4659 d53142e90cd0 net.http.server: Fix legacy net.httpserver fallback (httpserver is no longer a global). Waqas Hussain <waqas20@gmail.com> parents: 4634 diff changeset	165	if not handler then handler = legacy_httpserver and legacy_httpserver.set_default_handler.default_handler; end
4631 fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	166	if handler then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	167	-- add legacy properties to request object
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	168	request.url = { path = request.path };
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	169	request.handler = response.conn;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	170	request.id = tostring{}:match("%x+$");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	171	local headers = {};
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	172	for k,v in pairs(request.headers) do
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	173	headers[k:gsub("_", "-")] = v;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	174	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	175	request.headers = headers;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	176	function request:send(resp)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	177	if self.destroyed then return; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	178	if resp.body or resp.headers then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	179	if resp.headers then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	180	for k,v in pairs(resp.headers) do response.headers[k] = v; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	181	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	182	response:send(resp.body)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	183	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	184	response:send(resp)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	185	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	186	self.sent = true;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	187	self:destroy();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	188	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	189	function request:destroy()
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	190	if self.destroyed then return; end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	191	if not self.sent then return self:send(""); end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	192	self.destroyed = true;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	193	if self.on_destroy then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	194	log("debug", "Request has destroy callback");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	195	self:on_destroy();
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	196	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	197	log("debug", "Request has no destroy callback");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	198	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	199	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	200	local r = handler(request.method, request.body, request);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	201	if r ~= true then
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	202	request:send(r);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	203	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	204	else
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	205	log("debug", "No handler found");
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	206	response.status_code = 404;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	207	response.headers.content_type = "text/html";
4633 92e1a538f8b0 net.http.server: Missing <title/> in 404 Not Found response. Waqas Hussain <waqas20@gmail.com> parents: 4631 diff changeset	208	response:send("<html><head><title>404 Not Found</title></head><body>404 Not Found: No such page.</body></html>");
4631 fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	209	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	210	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	211
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	212	function _M.add_handler(event, handler, priority)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	213	events.add_handler(event, handler, priority);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	214	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	215	function _M.remove_handler(event, handler)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	216	events.remove_handler(event, handler);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	217	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	218
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	219	function _M.listen_on(port, interface, ssl)
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	220	addserver(interface or "", port, listener, "a", ssl);
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	221	end
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	222
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	223	_M.listener = listener;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	224	_M.codes = codes;
fc5d3b053454 net.http.{server\|codes\|parser}: Initial commit. Waqas Hussain <waqas20@gmail.com> parents: diff changeset	225	return _M;

author	Waqas Hussain <waqas20@gmail.com>
	Sun, 22 Apr 2012 23:44:21 +0500
changeset 4659	d53142e90cd0
parent 4634	8e582afc214d
child 4668	cce0c739b0d7
permissions	-rw-r--r--