summaryrefslogtreecommitdiffhomepage
path: root/libs/lucittpd/luasrc/ttpd
diff options
context:
space:
mode:
authorJo-Philipp Wich <jow@openwrt.org>2009-06-16 19:30:22 +0000
committerJo-Philipp Wich <jow@openwrt.org>2009-06-16 19:30:22 +0000
commit65cde286cc146be7dea165c2cb34732cb8953a57 (patch)
tree9fc9a7629afb9789a29c0def6266a19b86f7a426 /libs/lucittpd/luasrc/ttpd
parent8c359115f9d515d358403897f34c69757adf7af6 (diff)
drop obsoleted lucittpd packages
Diffstat (limited to 'libs/lucittpd/luasrc/ttpd')
-rw-r--r--libs/lucittpd/luasrc/ttpd/handler/file.lua252
-rw-r--r--libs/lucittpd/luasrc/ttpd/module.lua121
-rw-r--r--libs/lucittpd/luasrc/ttpd/server.lua444
3 files changed, 0 insertions, 817 deletions
diff --git a/libs/lucittpd/luasrc/ttpd/handler/file.lua b/libs/lucittpd/luasrc/ttpd/handler/file.lua
deleted file mode 100644
index e1f707c628..0000000000
--- a/libs/lucittpd/luasrc/ttpd/handler/file.lua
+++ /dev/null
@@ -1,252 +0,0 @@
---[[
-
-HTTP server implementation for LuCI - file handler
-(c) 2008 Steven Barth <steven@midlink.org>
-(c) 2008 Freifunk Leipzig / Jo-Philipp Wich <xm@leipzig.freifunk.net>
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-$Id$
-
-]]--
-
-local ipairs, type, tonumber = ipairs, type, tonumber
-local io = require "io"
-local os = require "os"
-local fs = require "luci.fs"
-local util = require "luci.util"
-local ltn12 = require "luci.ltn12"
-local mod = require "luci.ttpd.module"
-local srv = require "luci.ttpd.server"
-local string = require "string"
-
-local prot = require "luci.http.protocol"
-local date = require "luci.http.protocol.date"
-local mime = require "luci.http.protocol.mime"
-local cond = require "luci.http.protocol.conditionals"
-
-module "luci.ttpd.handler.file"
-
-Simple = util.class(mod.Handler)
-Response = mod.Response
-
-function Simple.__init__(self, docroot, dirlist)
- mod.Handler.__init__(self)
- self.docroot = docroot
- self.dirlist = dirlist and true or false
-end
-
-function Simple.parse_range(self, request, size)
- if not request.headers.Range then
- return true
- end
-
- local from, to = request.headers.Range:match("bytes=([0-9]*)-([0-9]*)")
- if not (from or to) then
- return true
- end
-
- from, to = tonumber(from), tonumber(to)
- if not (from or to) then
- return true
- elseif not from then
- from, to = size - to, size - 1
- elseif not to then
- to = size - 1
- end
-
- -- Not satisfiable
- if from >= size then
- return false
- end
-
- -- Normalize
- if to >= size then
- to = size - 1
- end
-
- local range = "bytes " .. from .. "-" .. to .. "/" .. size
- return from, (1 + to - from), range
-end
-
-function Simple.getfile(self, uri)
- local file = self.docroot .. uri:gsub("%.%./+", "")
- local stat = fs.stat(file)
-
- return file, stat
-end
-
-function Simple.handle_get(self, request, sourcein, sinkerr)
- local file, stat = self:getfile( prot.urldecode( request.env.PATH_INFO, true ) )
-
- if stat then
- if stat.type == "regular" then
-
- -- Generate Entity Tag
- local etag = cond.mk_etag( stat )
-
- -- Check conditionals
- local ok, code, hdrs
-
- ok, code, hdrs = cond.if_modified_since( request, stat )
- if ok then
- ok, code, hdrs = cond.if_match( request, stat )
- if ok then
- ok, code, hdrs = cond.if_unmodified_since( request, stat )
- if ok then
- ok, code, hdrs = cond.if_none_match( request, stat )
- if ok then
- local f, err = io.open(file)
-
- if f then
- local code = 200
- local o, s, r = self:parse_range(request, stat.size)
-
- if not o then
- return self:failure(416, "Invalid Range")
- end
-
- local headers = {
- ["Last-Modified"] = date.to_http( stat.mtime ),
- ["Content-Type"] = mime.to_mime( file ),
- ["ETag"] = etag,
- ["Accept-Ranges"] = "bytes",
- }
-
- if o == true then
- o = 0
- s = stat.size
- else
- code = 206
- headers["Content-Range"] = r
- end
-
- headers["Content-Length"] = s
-
- -- Send Response
- return Response(code, headers),
- srv.IOResource(f, o, s)
- else
- return self:failure( 403, err:gsub("^.+: ", "") )
- end
- else
- return Response( code, hdrs or { } )
- end
- else
- return Response( code, hdrs or { } )
- end
- else
- return Response( code, hdrs or { } )
- end
- else
- return Response( code, hdrs or { } )
- end
-
- elseif stat.type == "directory" then
-
- local ruri = request.request_uri:gsub("/$","")
- local duri = prot.urldecode( ruri, true )
- local root = self.docroot:gsub("/$","")
-
- -- check for index files
- local index_candidates = {
- "index.html", "index.htm", "default.html", "default.htm",
- "index.txt", "default.txt"
- }
-
- -- try to find an index file and redirect to it
- for i, candidate in ipairs( index_candidates ) do
- local istat = fs.stat(
- root .. "/" .. duri .. "/" .. candidate
- )
-
- if istat ~= nil and istat.type == "regular" then
- return Response( 302, {
- ["Location"] = ruri .. "/" .. candidate
- } )
- end
- end
-
-
- local html = string.format(
- '<?xml version="1.0" encoding="ISO-8859-15"?>\n' ..
- '<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" ' ..
- '"http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">\n' ..
- '<html xmlns="http://www.w3.org/1999/xhtml" ' ..
- 'xml:lang="en" lang="en">\n' ..
- '<head>\n' ..
- '<title>Index of %s/</title>\n' ..
- '<style type="text/css"><!--\n' ..
- 'body { background-color:#fbb034; color:#ffffff } ' ..
- 'li { border-bottom:1px dotted #CCCCCC; padding:3px } ' ..
- 'small { font-size:60%%; color:#ffffff } ' ..
- 'p { margin:0 }' ..
- '\n--></style></head><body><h1>Index of %s/</h1><hr /><ul>',
- duri, duri
- )
-
- local entries = fs.dir( file )
-
- if type(entries) == "table" then
- for i, e in util.spairs(
- entries, function(a,b)
- if entries[a] == '..' then
- return true
- elseif entries[b] == '..' then
- return false
- else
- return ( entries[a] < entries[b] )
- end
- end
- ) do
- if e ~= '.' and ( e == '..' or e:sub(1,1) ~= '.' ) then
- local estat = fs.stat( file .. "/" .. e )
-
- if estat.type == "directory" then
- html = html .. string.format(
- '<li><p><a href="%s/%s/">%s/</a> ' ..
- '<small>(directory)</small><br />' ..
- '<small>Changed: %s</small></li>',
- ruri, prot.urlencode( e ), e,
- date.to_http( estat.mtime )
- )
- else
- html = html .. string.format(
- '<li><p><a href="%s/%s">%s</a> ' ..
- '<small>(%s)</small><br />' ..
- '<small>Size: %i Bytes | ' ..
- 'Changed: %s</small></li>',
- ruri, prot.urlencode( e ), e,
- mime.to_mime( e ),
- estat.size, date.to_http( estat.mtime )
- )
- end
- end
- end
-
- html = html .. '</ul><hr /></body></html>'
-
- return Response(
- 200, {
- ["Date"] = date.to_http( os.time() );
- ["Content-Type"] = "text/html; charset=ISO-8859-15";
- }
- ), ltn12.source.string(html)
- else
- return self:failure(403, "Permission denied")
- end
- else
- return self:failure(403, "Unable to transmit " .. stat.type .. " " .. file)
- end
- else
- return self:failure(404, "No such file: " .. file)
- end
-end
-
-function Simple.handle_head(self, ...)
- return (self:handle_get(...))
-end
diff --git a/libs/lucittpd/luasrc/ttpd/module.lua b/libs/lucittpd/luasrc/ttpd/module.lua
deleted file mode 100644
index 1a7c574733..0000000000
--- a/libs/lucittpd/luasrc/ttpd/module.lua
+++ /dev/null
@@ -1,121 +0,0 @@
---[[
-LuCI - Lua Configuration Interface
-
-Copyright 2008 Steven Barth <steven@midlink.org>
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-$Id$
-]]--
-
-local pcall, ipairs, tonumber, type, next = pcall, ipairs, tonumber, type, next
-local util = require "luci.util"
-local http = require "luci.http.protocol"
-local ltn12 = require "luci.ltn12"
-local table = require "table"
-
-module "luci.ttpd.module"
-
-
--- Server handler implementation
-Handler = util.class()
-
--- Constructor
-function Handler.__init__(self)
- self.handler = {}
- self.filters = {}
- self.modifiers = {}
-end
-
--- Add a filter
-function Handler.setfilter(self, filter, key)
- self.filters[(key) or (#self.filters+1)] = filter
-end
-
--- Add a modifier
-function Handler.setmodifier(self, modifier, key)
- self.modifiers[(pos) or (#self.modifiers+1)] = modifier
-end
-
--- Creates a failure reply
-function Handler.failure(self, code, message)
- local response = Response(code, { ["Content-Type"] = "text/plain" })
- local sourceout = ltn12.source.string(message)
-
- return response, sourceout
-end
-
--- Processes a request
-function Handler.process(self, request, sourcein, sinkerr)
- local stat, response, sourceout
-
- -- Detect request Method
- local hname = "handle_" .. request.request_method
- if self[hname] then
- local t = {
- processor = self[hname],
- handler = self,
- request = request,
- sourcein = sourcein,
- sinkerr = sinkerr
- }
-
- if next(self.modifiers) then
- for _, mod in util.kspairs(self.modifiers) do
- mod(t)
- end
- end
-
- -- Run the handler
- stat, response, sourceout = pcall(
- t.processor, t.handler, t.request, t.sourcein, t.sinkerr
- )
-
- -- Check for any errors
- if not stat then
- response, sourceout = self:failure(500, response)
- elseif next(self.filters) then
- local t = {
- response = response,
- sourceout = sourceout,
- sinkerr = t.sinkerr
- }
-
- for _, filter in util.kspairs(self.filters) do
- filter(t)
- end
-
- response = t.response
- sourceout = t.sourceout
- end
- else
- response, sourceout = self:failure(405, http.protocol.statusmsg[405])
- end
-
- -- Check data
- if not util.instanceof(response, Response) then
- response, sourceout = self:failure(500, "Core error: Invalid module response!")
- end
-
- return response, sourceout
-end
-
--- Handler Response
-Response = util.class()
-
-function Response.__init__(self, status, headers)
- self.status = tonumber(status) or 200
- self.headers = (type(headers) == "table") and headers or {}
-end
-
-function Response.addheader(self, key, value)
- self.headers[key] = value
-end
-
-function Response.setstatus(self, status)
- self.status = status
-end \ No newline at end of file
diff --git a/libs/lucittpd/luasrc/ttpd/server.lua b/libs/lucittpd/luasrc/ttpd/server.lua
deleted file mode 100644
index a2c7ffcb29..0000000000
--- a/libs/lucittpd/luasrc/ttpd/server.lua
+++ /dev/null
@@ -1,444 +0,0 @@
---[[
-LuCIttpd
-(c) 2008 Steven Barth <steven@midlink.org>
-(c) 2008 Jo-Philipp Wich <xm@leipzig.freifunk.net>
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-$Id$
-]]--
-
-local ipairs, pairs = ipairs, pairs
-local tostring, tonumber = tostring, tonumber
-local pcall, assert = pcall, assert
-
-local os = require "os"
-local io = require "io"
-local uci = require "luci.model.uci"
-local util = require "luci.util"
-local ltn12 = require "luci.ltn12"
-local proto = require "luci.http.protocol"
-local string = require "string"
-local date = require "luci.http.protocol.date"
-
-module "luci.ttpd.server"
-
-BUFSIZE = 4096
-VERSION = 0.91
-
-
--- File Resource
-IOResource = util.class()
-
-function IOResource.__init__(self, fd, offset, len)
- self.fd, self.offset, self.len = fd, offset, len
-end
-
-
-VHost = util.class()
-
-function VHost.__init__(self, handler)
- self.handler = handler
- self.dhandler = {}
-end
-
-function VHost.process(self, request, sourcein, sinkerr, ...)
- local handler = self.handler
-
- local uri = request.env.REQUEST_URI:match("^([^?]*)")
-
- -- SCRIPT_NAME
- request.env.SCRIPT_NAME = ""
-
- -- Call URI part
- request.env.PATH_INFO = uri
-
- for k, dhandler in pairs(self.dhandler) do
- if k == uri or k.."/" == uri:sub(1, #k+1) then
- handler = dhandler
- request.env.SCRIPT_NAME = k
- request.env.PATH_INFO = uri:sub(#k+1)
- break;
- end
- end
-
- if handler then
- return handler:process(request, sourcein, sinkerr, ...)
- end
-end
-
-function VHost.get_default_handler(self)
- return self.handler
-end
-
-function VHost.set_default_handler(self, handler)
- self.handler = handler
-end
-
-function VHost.get_handlers(self)
- return self.dhandler
-end
-
-function VHost.set_handler(self, match, handler)
- self.dhandler[match] = handler
-end
-
-
-
-Server = util.class()
-
-function Server.__init__(self, host)
- self.uci = uci.cursor()
- self.host = host
- self.vhosts = {}
-
- self.rbuf = ""
- self.wbuf = ""
-end
-
-function Server.get_default_vhost(self)
- return self.host
-end
-
-function Server.set_default_vhost(self, vhost)
- self.host = vhost
-end
-
-function Server.get_vhosts(self)
- return self.vhosts
-end
-
-function Server.set_vhost(self, name, vhost)
- self.vhosts[name] = vhost
-end
-
-function Server.flush(self)
- if #self.wbuf > 0 then
- self._write(self.wbuf)
- self.wbuf = ""
- end
-end
-
-function Server.read(self, len)
- while #self.rbuf < len do
- self.rbuf = self.rbuf .. self._read(len - #self.rbuf)
- end
-
- local chunk = self.rbuf:sub(1, len)
- self.rbuf = self.rbuf:sub(len + 1)
- return chunk
-end
-
-function Server.limitsource(self, limit)
- limit = limit or 0
-
- return function()
- if limit < 1 then
- return nil
- else
- local read = (limit > BUFSIZE) and BUFSIZE or limit
- limit = limit - read
- return self:read(read)
- end
- end
-end
-
--- Adapted from Luaposix
-function Server.receiveheaders(self)
- local line, name, value, err
- local headers = {}
- -- get first line
- line, err = self:readline()
- if err then return nil, err end
- -- headers go until a blank line is found
- while line do
- -- get field-name and value
- _, _, name, value = line:find("^(.-):%s*(.*)")
- if not (name and value) then return nil, "malformed reponse headers" end
- name = name:lower()
- -- get next line (value might be folded)
- line, err = self:readline()
- if err then return nil, err end
- -- unfold any folded values
- while line:find("^%s") do
- value = value .. line
- line = self:readline()
- if err then return nil, err end
- end
- -- save pair in table
- if headers[name] then headers[name] = headers[name] .. ", " .. value
- else headers[name] = value end
- end
- return headers
-end
-
-function Server.readchunk(self)
- -- get chunk size, skip extention
- local line, err = self:readline()
- if err then return nil, err end
- local size = tonumber(line:gsub(";.*", ""), 16)
- if not size then return nil, "invalid chunk size" end
- -- was it the last chunk?
- if size > 0 then
- -- if not, get chunk and skip terminating CRLF
- local chunk, err, part = self:read(size)
- if chunk then self:readline() end
- return chunk, err
- else
- -- if it was, read trailers into headers table
- headers, err = self:receiveheaders()
- if not headers then return nil, err end
- end
-end
-
-function Server.readline(self)
- if #self.rbuf < 1 then
- self.rbuf = self._read(BUFSIZE)
- end
-
- while true do
- local le = self.rbuf:find("\r\n", nil, true)
- if le then
- if le == 1 then -- EoH
- self.rbuf = self.rbuf:sub(le + 2)
- return nil
- else -- Header
- local line = self.rbuf:sub(1, le - 1)
- self.rbuf = self.rbuf:sub(le + 2)
- return line
- end
- else
- if #self.rbuf >= BUFSIZE then
- return nil, "Invalid Request"
- end
- self.rbuf = self.rbuf .. self._read(BUFSIZE-#self.rbuf)
- end
- end
-end
-
-function Server.sink(self)
- return function(chunk, err)
- if err then
- return nil, err
- elseif chunk then
- local stat, err = pcall(self.write, self, chunk)
- if stat then
- return stat
- else
- return nil, err
- end
- else
- return true
- end
- end
-end
-
-function Server.chunksink(self)
- return function(chunk, err)
- local stat, err = pcall(self.writechunk, self, chunk)
- if stat then
- return stat
- else
- return nil, err
- end
- end
-end
-
-function Server.writechunk(self, chunk, err)
- self:flush()
- if not chunk then return self._write("0\r\n\r\n") end
- local size = string.format("%X\r\n", #chunk)
- return self._write(size .. chunk .. "\r\n")
-end
-
-function Server.write(self, chunk)
- while #chunk > 0 do
- local missing = BUFSIZE - #self.wbuf
- self.wbuf = self.wbuf .. chunk:sub(1, missing)
- chunk = chunk:sub(missing + 1)
- if #self.wbuf == BUFSIZE then
- assert(self._write(self.wbuf))
- self.wbuf = ""
- end
- end
-end
-
-function Server.close(self)
- self:flush()
- self._close()
-end
-
-function Server.sendfile(self, fd, offset, len)
- self:flush()
- self._sendfile(fd, offset, len)
-end
-
-
-function Server.error(self, code, msg)
- hcode = tostring(code)
-
- self:write( "HTTP/1.0 " .. hcode .. " " ..
- proto.statusmsg[code] .. "\r\n" )
- self:write( "Connection: close\r\n" )
- self:write( "Content-Type: text/plain\r\n\r\n" )
-
- if msg then
- self:write( "HTTP-Error " .. code .. ": " .. msg .. "\r\n" )
- end
-end
-
-
-function Server.process(self, functions)
- util.update(self, functions)
-
- local sourcein = ltn12.source.empty()
- local sourcehdr = function() return self:readline() or "" end
- local sinkerr = ltn12.sink.file( io.stderr )
- local sinkout = self:sink()
-
- local close = false
- local stat, message, err
-
- repeat
- -- parse headers
- stat, message, err = pcall(proto.parse_message_header, sourcehdr)
-
- -- remote socket closed
- if not stat and message == 0 then
- break
- end
-
- -- remote timeout
- if not stat and message == 11 then
- --self:error(408)
- break
- end
-
- -- any other error
- if not stat or not message then
- self:error(400, err)
- break
- end
-
- -- keep-alive
- if message.http_version == 1.1 then
- close = (message.env.HTTP_CONNECTION == "close")
- else
- close = not message.env.HTTP_CONNECTION or message.env.HTTP_CONNECTION == "close"
- end
- -- Uncomment this to disable keep-alive
- close = not (self.uci:get("lucittpd", "lucittpd", "keepalive") == "1")
-
- if message.request_method == "get" or message.request_method == "head" then
- -- Be happy
-
- elseif message.request_method == "post" then
- -- If we have a HTTP/1.1 client and an Expect: 100-continue header then
- -- respond with HTTP 100 Continue message
- if message.http_version == 1.1 and message.headers['Expect'] and
- message.headers['Expect'] == '100-continue'
- then
- self:write("HTTP/1.1 100 Continue\r\n\r\n")
- end
-
- if message.headers['Transfer-Encoding'] and
- message.headers['Transfer-Encoding'] ~= "identity" then
- sourcein = function() return self:readchunk() end
- elseif message.env.CONTENT_LENGTH then
- sourcein = self:limitsource(
- tonumber(message.env.CONTENT_LENGTH)
- )
- else
- self:error( 411, proto.statusmsg[411] )
- break
- end
- else
- self:error( 405, proto.statusmsg[405] )
- break
-
- end
-
-
- local host = self.vhosts[message.env.HTTP_HOST] or self.host
- if not host then
- self:error( 500, "Unable to find matching host" )
- break;
- end
-
- local response, sourceout = host:process(
- message, sourcein, sinkerr,
- client, io.stderr
- )
- if not response then
- self:error( 500, "Error processing handler" )
- end
-
- -- Post process response
- if sourceout then
- if util.instanceof(sourceout, IOResource) then
- if not response.headers["Content-Length"] then
- response.headers["Content-Length"] = sourceout.len
- end
- end
- if not response.headers["Content-Length"] then
- if message.http_version == 1.1 then
- response.headers["Transfer-Encoding"] = "chunked"
- sinkout = self:chunksink()
- else
- close = true
- end
- end
- elseif message.request_method ~= "head" then
- response.headers["Content-Length"] = 0
- end
-
- if close then
- response.headers["Connection"] = "close"
- end
-
- response.headers["Date"] = date.to_http(os.time())
-
- local header =
- message.env.SERVER_PROTOCOL .. " " ..
- tostring(response.status) .. " " ..
- proto.statusmsg[response.status] .. "\r\n"
-
- header = header .. "Server: LuCIttpd/" .. tostring(VERSION) .. "\r\n"
-
-
- for k,v in pairs(response.headers) do
- header = header .. k .. ": " .. v .. "\r\n"
- end
-
- -- Output
- local stat, err = pcall(function()
- self:write(header .. "\r\n")
-
- if sourceout then
- if util.instanceof(sourceout, IOResource) then
- self:sendfile(sourceout.fd, sourceout.offset, sourceout.len)
- else
- ltn12.pump.all(sourceout, sinkout)
- end
- end
-
- self:flush()
- end)
-
- -- Write errors
- if not stat then
- if err == 107 then
- -- Remote end closed the socket, so do we
- elseif err then
- io.stderr:write("Error sending data: " .. err .. "\n")
- end
- break
- end
- until close
-
- self:close()
-end