1 files changed, 84 insertions, 0 deletions
diff --git a/libs/httpd/luasrc/httpd.lua b/libs/httpd/luasrc/httpd.lua
new file mode 100644
index 000000000..773d3c873
--- /dev/null
+++ b/libs/httpd/luasrc/httpd.lua
@@ -0,0 +1,84 @@
+--[[
+LuCI - HTTPD
+]]--
+module("luci.httpd", package.seeall)
+require("luci.copas")
+require("luci.http.protocol")
+require("luci.sys")
+
+
+
+function run(config)
+	-- TODO: process config
+	local server = socket.bind("0.0.0.0", 8080)
+	copas.addserver(server, spawnworker)
+	
+	while true do
+		copas.step()
+	end
+end
+
+
+function spawnworker(socket)
+	socket = copas.wrap(socket)
+	local request = luci.http.protocol.parse_message_header(socket)
+	request.input = socket -- TODO: replace with streamreader
+	request.error = io.stderr
+	
+	
+	local output = socket -- TODO: replace with streamwriter
+	
+	-- TODO: detect matching handler
+	local h = luci.httpd.FileHandler.SimpleHandler(luci.sys.libpath() .. "/httpd/httest")
+	h:process(request, output)
+end
+
+
+Response = luci.util.class()
+function Response.__init__(self, sourceout, headers, status)
+	self.sourceout = sourceout or function() end
+	self.headers   = headers or {}
+	self.status    = status or 200
+end
+
+function Response.addheader(self, key, value)
+	self.headers[key] = value
+end
+
+function Response.setstatus(self, status)
+	self.status = status
+end
+
+function Response.setsource(self, source)
+	self.sourceout = source
+end
+
+
+Handler = luci.util.class()
+function Handler.__init__(self)
+	self.filter = {}
+end
+
+function Handler.addfilter(self, filter)
+	table.insert(self.filter, filter)
+end
+
+function Handler.process(self, request, output)
+	-- TODO: Process input filters
+
+	local response = self:handle(request)
+	
+	-- TODO: Process output filters
+	
+	output:send("HTTP/1.0 " .. response.status .. " BLA\r\n")
+	for k, v in pairs(response.headers) do
+		output:send(k .. ": " .. v .. "\r\n")
+	end
+	
+	output:send("\r\n")
+
+	for chunk in response.sourceout do
+		output:send(chunk)
+	end
+end
+