scansion/serve.lua

local verse = require "verse";

local server = require "net.server";
local http_server = require "net.http.server";
local http = require "net.http";
local json = require "util.json";
local time = require "socket".gettime;

function handle_request()
	return "Hello world";
end

local function run(config, run_script)
	function handle_run_request(event)
		local request, response = event.request, event.response;

		local function log(type, data)
			local entry = { type = type, data = data, time = time() };
			local chunk = json.encode(entry) .. "\r\n";
			response.conn:write(("%x\r\n%s\r\n"):format(#chunk, chunk));
		end
	
		response.status_code = 201;
		response.headers.connection = "close";
		response.headers.transfer_encoding = "chunked";
		response.conn:send(table.concat(http_server.prepare_header(response)));

		local ok, ret = pcall(run_script, "web", event.request.body, log);
	
		if not ok then
			log("error", ret);
		end

		response.conn:write("0\r\n\r\n");
		response:done();
	
		return true;
	end
	
	http_server.add_host("localhost");
	http_server.set_default_host("localhost");
	http_server.add_handler("GET localhost/*", handle_request);
	http_server.add_handler("POST localhost/run", handle_run_request);
	http_server.add_handler("http-error", function (e)
		verse.log("error", "HTTP error: %s", e.code);
	end);
	--http_server.add_handler("GET localhost/stream/*", handle_stream_request);
	http_server.listen_on(config.port or 8007);
	verse.log("debug", "Ready")
	repeat until not verse.loop();
end

return {
	run = run;
}