diff --git a/external/lua/luasocket/luasocket_scripts.c b/external/lua/luasocket/luasocket_scripts.c deleted file mode 100644 index a9b15453cb..0000000000 --- a/external/lua/luasocket/luasocket_scripts.c +++ /dev/null @@ -1,2195 +0,0 @@ - -/* luasocket_scripts.c */ - -#include "lua.h" -#include "lauxlib.h" -#include "luasocket_scripts.h" - -/* ltn12 */ -static const char *lua_m_ltn12 = -"-----------------------------------------------------------------------------\n" -"-- LTN12 - Filters, sources, sinks and pumps.\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module\n" -"-----------------------------------------------------------------------------\n" -"local string = require(\"string\")\n" -"local table = require(\"table\")\n" -"local base = _G\n" -"local _M = {}\n" -"if module then -- heuristic for exporting a global package table\n" -" ltn12 = _M\n" -"end\n" -"local filter,source,sink,pump = {},{},{},{}\n" -"\n" -"_M.filter = filter\n" -"_M.source = source\n" -"_M.sink = sink\n" -"_M.pump = pump\n" -"\n" -"-- 2048 seems to be better in windows...\n" -"_M.BLOCKSIZE = 2048\n" -"_M._VERSION = \"LTN12 1.0.3\"\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Filter stuff\n" -"-----------------------------------------------------------------------------\n" -"-- returns a high level filter that cycles a low-level filter\n" -"function filter.cycle(low, ctx, extra)\n" -" base.assert(low)\n" -" return function(chunk)\n" -" local ret\n" -" ret, ctx = low(ctx, chunk, extra)\n" -" return ret\n" -" end\n" -"end\n" -"\n" -"-- chains a bunch of filters together\n" -"-- (thanks to Wim Couwenberg)\n" -"function filter.chain(...)\n" -" local arg = {...}\n" -" local n = select('#',...)\n" -" local top, index = 1, 1\n" -" local retry = \"\"\n" -" return function(chunk)\n" -" retry = chunk and retry\n" -" while true do\n" -" if index == top then\n" -" chunk = arg[index](chunk)\n" -" if chunk == \"\" or top == n then return chunk\n" -" elseif chunk then index = index + 1\n" -" else\n" -" top = top+1\n" -" index = top\n" -" end\n" -" else\n" -" chunk = arg[index](chunk or \"\")\n" -" if chunk == \"\" then\n" -" index = index - 1\n" -" chunk = retry\n" -" elseif chunk then\n" -" if index == n then return chunk\n" -" else index = index + 1 end\n" -" else base.error(\"filter returned inappropriate nil\") end\n" -" end\n" -" end\n" -" end\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Source stuff\n" -"-----------------------------------------------------------------------------\n" -"-- create an empty source\n" -"local function empty()\n" -" return nil\n" -"end\n" -"\n" -"function source.empty()\n" -" return empty\n" -"end\n" -"\n" -"-- returns a source that just outputs an error\n" -"function source.error(err)\n" -" return function()\n" -" return nil, err\n" -" end\n" -"end\n" -"\n" -"-- creates a file source\n" -"function source.file(handle, io_err)\n" -" if handle then\n" -" return function()\n" -" local chunk = handle:read(_M.BLOCKSIZE)\n" -" if not chunk then handle:close() end\n" -" return chunk\n" -" end\n" -" else return source.error(io_err or \"unable to open file\") end\n" -"end\n" -"\n" -"-- turns a fancy source into a simple source\n" -"function source.simplify(src)\n" -" base.assert(src)\n" -" return function()\n" -" local chunk, err_or_new = src()\n" -" src = err_or_new or src\n" -" if not chunk then return nil, err_or_new\n" -" else return chunk end\n" -" end\n" -"end\n" -"\n" -"-- creates string source\n" -"function source.string(s)\n" -" if s then\n" -" local i = 1\n" -" return function()\n" -" local chunk = string.sub(s, i, i+_M.BLOCKSIZE-1)\n" -" i = i + _M.BLOCKSIZE\n" -" if chunk ~= \"\" then return chunk\n" -" else return nil end\n" -" end\n" -" else return source.empty() end\n" -"end\n" -"\n" -"-- creates rewindable source\n" -"function source.rewind(src)\n" -" base.assert(src)\n" -" local t = {}\n" -" return function(chunk)\n" -" if not chunk then\n" -" chunk = table.remove(t)\n" -" if not chunk then return src()\n" -" else return chunk end\n" -" else\n" -" table.insert(t, chunk)\n" -" end\n" -" end\n" -"end\n" -"\n" -"function source.chain(src, f)\n" -" base.assert(src and f)\n" -" local last_in, last_out = \"\", \"\"\n" -" local state = \"feeding\"\n" -" local err\n" -" return function()\n" -" if not last_out then\n" -" base.error('source is empty!', 2)\n" -" end\n" -" while true do\n" -" if state == \"feeding\" then\n" -" last_in, err = src()\n" -" if err then return nil, err end\n" -" last_out = f(last_in)\n" -" if not last_out then\n" -" if last_in then\n" -" base.error('filter returned inappropriate nil')\n" -" else\n" -" return nil\n" -" end\n" -" elseif last_out ~= \"\" then\n" -" state = \"eating\"\n" -" if last_in then last_in = \"\" end\n" -" return last_out\n" -" end\n" -" else\n" -" last_out = f(last_in)\n" -" if last_out == \"\" then\n" -" if last_in == \"\" then\n" -" state = \"feeding\"\n" -" else\n" -" base.error('filter returned \"\"')\n" -" end\n" -" elseif not last_out then\n" -" if last_in then\n" -" base.error('filter returned inappropriate nil')\n" -" else\n" -" return nil\n" -" end\n" -" else\n" -" return last_out\n" -" end\n" -" end\n" -" end\n" -" end\n" -"end\n" -"\n" -"-- creates a source that produces contents of several sources, one after the\n" -"-- other, as if they were concatenated\n" -"-- (thanks to Wim Couwenberg)\n" -"function source.cat(...)\n" -" local arg = {...}\n" -" local src = table.remove(arg, 1)\n" -" return function()\n" -" while src do\n" -" local chunk, err = src()\n" -" if chunk then return chunk end\n" -" if err then return nil, err end\n" -" src = table.remove(arg, 1)\n" -" end\n" -" end\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Sink stuff\n" -"-----------------------------------------------------------------------------\n" -"-- creates a sink that stores into a table\n" -"function sink.table(t)\n" -" t = t or {}\n" -" local f = function(chunk, err)\n" -" if chunk then table.insert(t, chunk) end\n" -" return 1\n" -" end\n" -" return f, t\n" -"end\n" -"\n" -"-- turns a fancy sink into a simple sink\n" -"function sink.simplify(snk)\n" -" base.assert(snk)\n" -" return function(chunk, err)\n" -" local ret, err_or_new = snk(chunk, err)\n" -" if not ret then return nil, err_or_new end\n" -" snk = err_or_new or snk\n" -" return 1\n" -" end\n" -"end\n" -"\n" -"-- creates a file sink\n" -"function sink.file(handle, io_err)\n" -" if handle then\n" -" return function(chunk, err)\n" -" if not chunk then\n" -" handle:close()\n" -" return 1\n" -" else return handle:write(chunk) end\n" -" end\n" -" else return sink.error(io_err or \"unable to open file\") end\n" -"end\n" -"\n" -"-- creates a sink that discards data\n" -"local function null()\n" -" return 1\n" -"end\n" -"\n" -"function sink.null()\n" -" return null\n" -"end\n" -"\n" -"-- creates a sink that just returns an error\n" -"function sink.error(err)\n" -" return function()\n" -" return nil, err\n" -" end\n" -"end\n" -"\n" -"-- chains a sink with a filter\n" -"function sink.chain(f, snk)\n" -" base.assert(f and snk)\n" -" return function(chunk, err)\n" -" if chunk ~= \"\" then\n" -" local filtered = f(chunk)\n" -" local done = chunk and \"\"\n" -" while true do\n" -" local ret, snkerr = snk(filtered, err)\n" -" if not ret then return nil, snkerr end\n" -" if filtered == done then return 1 end\n" -" filtered = f(done)\n" -" end\n" -" else return 1 end\n" -" end\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Pump stuff\n" -"-----------------------------------------------------------------------------\n" -"-- pumps one chunk from the source to the sink\n" -"function pump.step(src, snk)\n" -" local chunk, src_err = src()\n" -" local ret, snk_err = snk(chunk, src_err)\n" -" if chunk and ret then return 1\n" -" else return nil, src_err or snk_err end\n" -"end\n" -"\n" -"-- pumps all data from a source to a sink, using a step function\n" -"function pump.all(src, snk, step)\n" -" base.assert(src and snk)\n" -" step = step or pump.step\n" -" while true do\n" -" local ret, err = step(src, snk)\n" -" if not ret then\n" -" if err then return nil, err\n" -" else return 1 end\n" -" end\n" -" end\n" -"end\n" -"\n" -"return _M\n" -"\n"; - -/* mime */ -static const char *lua_m_mime = -"-----------------------------------------------------------------------------\n" -"-- MIME support for the Lua language.\n" -"-- Author: Diego Nehab\n" -"-- Conforming to RFCs 2045-2049\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module and import dependencies\n" -"-----------------------------------------------------------------------------\n" -"local base = _G\n" -"local ltn12 = require(\"ltn12\")\n" -"local mime = require(\"mime.core\")\n" -"local io = require(\"io\")\n" -"local string = require(\"string\")\n" -"local _M = mime\n" -"\n" -"-- encode, decode and wrap algorithm tables\n" -"local encodet, decodet, wrapt = {},{},{}\n" -"\n" -"_M.encodet = encodet\n" -"_M.decodet = decodet\n" -"_M.wrapt = wrapt \n" -"\n" -"-- creates a function that chooses a filter by name from a given table\n" -"local function choose(table)\n" -" return function(name, opt1, opt2)\n" -" if base.type(name) ~= \"string\" then\n" -" name, opt1, opt2 = \"default\", name, opt1\n" -" end\n" -" local f = table[name or \"nil\"]\n" -" if not f then \n" -" base.error(\"unknown key (\" .. base.tostring(name) .. \")\", 3)\n" -" else return f(opt1, opt2) end\n" -" end\n" -"end\n" -"\n" -"-- define the encoding filters\n" -"encodet['base64'] = function()\n" -" return ltn12.filter.cycle(_M.b64, \"\")\n" -"end\n" -"\n" -"encodet['quoted-printable'] = function(mode)\n" -" return ltn12.filter.cycle(_M.qp, \"\",\n" -" (mode == \"binary\") and \"=0D=0A\" or \"\r\n\")\n" -"end\n" -"\n" -"-- define the decoding filters\n" -"decodet['base64'] = function()\n" -" return ltn12.filter.cycle(_M.unb64, \"\")\n" -"end\n" -"\n" -"decodet['quoted-printable'] = function()\n" -" return ltn12.filter.cycle(_M.unqp, \"\")\n" -"end\n" -"\n" -"local function format(chunk)\n" -" if chunk then\n" -" if chunk == \"\" then return \"''\"\n" -" else return string.len(chunk) end\n" -" else return \"nil\" end\n" -"end\n" -"\n" -"-- define the line-wrap filters\n" -"wrapt['text'] = function(length)\n" -" length = length or 76\n" -" return ltn12.filter.cycle(_M.wrp, length, length)\n" -"end\n" -"wrapt['base64'] = wrapt['text']\n" -"wrapt['default'] = wrapt['text']\n" -"\n" -"wrapt['quoted-printable'] = function()\n" -" return ltn12.filter.cycle(_M.qpwrp, 76, 76)\n" -"end\n" -"\n" -"-- function that choose the encoding, decoding or wrap algorithm\n" -"_M.encode = choose(encodet)\n" -"_M.decode = choose(decodet)\n" -"_M.wrap = choose(wrapt)\n" -"\n" -"-- define the end-of-line normalization filter\n" -"function _M.normalize(marker)\n" -" return ltn12.filter.cycle(_M.eol, 0, marker)\n" -"end\n" -"\n" -"-- high level stuffing filter\n" -"function _M.stuff()\n" -" return ltn12.filter.cycle(_M.dot, 2)\n" -"end\n" -"\n" -"return _M\n"; - -/* socket.ftp */ -static const char *lua_m_socket_ftp = -"-----------------------------------------------------------------------------\n" -"-- FTP support for the Lua language\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module and import dependencies\n" -"-----------------------------------------------------------------------------\n" -"local base = _G\n" -"local table = require(\"table\")\n" -"local string = require(\"string\")\n" -"local math = require(\"math\")\n" -"local socket = require(\"socket.socket\")\n" -"local url = require(\"socket.url\")\n" -"local tp = require(\"socket.tp\")\n" -"local ltn12 = require(\"ltn12\")\n" -"socket.ftp = {}\n" -"local _M = socket.ftp\n" -"-----------------------------------------------------------------------------\n" -"-- Program constants\n" -"-----------------------------------------------------------------------------\n" -"-- timeout in seconds before the program gives up on a connection\n" -"_M.TIMEOUT = 60\n" -"-- default port for ftp service\n" -"_M.PORT = 21\n" -"-- this is the default anonymous password. used when no password is\n" -"-- provided in url. should be changed to your e-mail.\n" -"_M.USER = \"ftp\"\n" -"_M.PASSWORD = \"anonymous@anonymous.org\"\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Low level FTP API\n" -"-----------------------------------------------------------------------------\n" -"local metat = { __index = {} }\n" -"\n" -"function _M.open(server, port, create)\n" -" local tp = socket.try(tp.connect(server, port or _M.PORT, _M.TIMEOUT, create))\n" -" local f = base.setmetatable({ tp = tp }, metat)\n" -" -- make sure everything gets closed in an exception\n" -" f.try = socket.newtry(function() f:close() end)\n" -" return f\n" -"end\n" -"\n" -"function metat.__index:portconnect()\n" -" self.try(self.server:settimeout(_M.TIMEOUT))\n" -" self.data = self.try(self.server:accept())\n" -" self.try(self.data:settimeout(_M.TIMEOUT))\n" -"end\n" -"\n" -"function metat.__index:pasvconnect()\n" -" self.data = self.try(socket.tcp())\n" -" self.try(self.data:settimeout(_M.TIMEOUT))\n" -" self.try(self.data:connect(self.pasvt.ip, self.pasvt.port))\n" -"end\n" -"\n" -"function metat.__index:login(user, password)\n" -" self.try(self.tp:command(\"user\", user or _M.USER))\n" -" local code, reply = self.try(self.tp:check{\"2..\", 331})\n" -" if code == 331 then\n" -" self.try(self.tp:command(\"pass\", password or _M.PASSWORD))\n" -" self.try(self.tp:check(\"2..\"))\n" -" end\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:pasv()\n" -" self.try(self.tp:command(\"pasv\"))\n" -" local code, reply = self.try(self.tp:check(\"2..\"))\n" -" local pattern = \"(%d+)%D(%d+)%D(%d+)%D(%d+)%D(%d+)%D(%d+)\"\n" -" local a, b, c, d, p1, p2 = socket.skip(2, string.find(reply, pattern))\n" -" self.try(a and b and c and d and p1 and p2, reply)\n" -" self.pasvt = {\n" -" ip = string.format(\"%d.%d.%d.%d\", a, b, c, d),\n" -" port = p1*256 + p2\n" -" }\n" -" if self.server then\n" -" self.server:close()\n" -" self.server = nil\n" -" end\n" -" return self.pasvt.ip, self.pasvt.port\n" -"end\n" -"\n" -"function metat.__index:port(ip, port)\n" -" self.pasvt = nil\n" -" if not ip then\n" -" ip, port = self.try(self.tp:getcontrol():getsockname())\n" -" self.server = self.try(socket.bind(ip, 0))\n" -" ip, port = self.try(self.server:getsockname())\n" -" self.try(self.server:settimeout(_M.TIMEOUT))\n" -" end\n" -" local pl = math.mod(port, 256)\n" -" local ph = (port - pl)/256\n" -" local arg = string.gsub(string.format(\"%s,%d,%d\", ip, ph, pl), \"%.\", \",\")\n" -" self.try(self.tp:command(\"port\", arg))\n" -" self.try(self.tp:check(\"2..\"))\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:send(sendt)\n" -" self.try(self.pasvt or self.server, \"need port or pasv first\")\n" -" -- if there is a pasvt table, we already sent a PASV command\n" -" -- we just get the data connection into self.data\n" -" if self.pasvt then self:pasvconnect() end\n" -" -- get the transfer argument and command\n" -" local argument = sendt.argument or\n" -" url.unescape(string.gsub(sendt.path or \"\", \"^[/\\]\", \"\"))\n" -" if argument == \"\" then argument = nil end\n" -" local command = sendt.command or \"stor\"\n" -" -- send the transfer command and check the reply\n" -" self.try(self.tp:command(command, argument))\n" -" local code, reply = self.try(self.tp:check{\"2..\", \"1..\"})\n" -" -- if there is not a a pasvt table, then there is a server\n" -" -- and we already sent a PORT command\n" -" if not self.pasvt then self:portconnect() end\n" -" -- get the sink, source and step for the transfer\n" -" local step = sendt.step or ltn12.pump.step\n" -" local readt = {self.tp.c}\n" -" local checkstep = function(src, snk)\n" -" -- check status in control connection while downloading\n" -" local readyt = socket.select(readt, nil, 0)\n" -" if readyt[tp] then code = self.try(self.tp:check(\"2..\")) end\n" -" return step(src, snk)\n" -" end\n" -" local sink = socket.sink(\"close-when-done\", self.data)\n" -" -- transfer all data and check error\n" -" self.try(ltn12.pump.all(sendt.source, sink, checkstep))\n" -" if string.find(code, \"1..\") then self.try(self.tp:check(\"2..\")) end\n" -" -- done with data connection\n" -" self.data:close()\n" -" -- find out how many bytes were sent\n" -" local sent = socket.skip(1, self.data:getstats())\n" -" self.data = nil\n" -" return sent\n" -"end\n" -"\n" -"function metat.__index:receive(recvt)\n" -" self.try(self.pasvt or self.server, \"need port or pasv first\")\n" -" if self.pasvt then self:pasvconnect() end\n" -" local argument = recvt.argument or\n" -" url.unescape(string.gsub(recvt.path or \"\", \"^[/\\]\", \"\"))\n" -" if argument == \"\" then argument = nil end\n" -" local command = recvt.command or \"retr\"\n" -" self.try(self.tp:command(command, argument))\n" -" local code,reply = self.try(self.tp:check{\"1..\", \"2..\"})\n" -" if (code >= 200) and (code <= 299) then\n" -" recvt.sink(reply)\n" -" return 1\n" -" end\n" -" if not self.pasvt then self:portconnect() end\n" -" local source = socket.source(\"until-closed\", self.data)\n" -" local step = recvt.step or ltn12.pump.step\n" -" self.try(ltn12.pump.all(source, recvt.sink, step))\n" -" if string.find(code, \"1..\") then self.try(self.tp:check(\"2..\")) end\n" -" self.data:close()\n" -" self.data = nil\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:cwd(dir)\n" -" self.try(self.tp:command(\"cwd\", dir))\n" -" self.try(self.tp:check(250))\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:type(type)\n" -" self.try(self.tp:command(\"type\", type))\n" -" self.try(self.tp:check(200))\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:greet()\n" -" local code = self.try(self.tp:check{\"1..\", \"2..\"})\n" -" if string.find(code, \"1..\") then self.try(self.tp:check(\"2..\")) end\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:quit()\n" -" self.try(self.tp:command(\"quit\"))\n" -" self.try(self.tp:check(\"2..\"))\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:close()\n" -" if self.data then self.data:close() end\n" -" if self.server then self.server:close() end\n" -" return self.tp:close()\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- High level FTP API\n" -"-----------------------------------------------------------------------------\n" -"local function override(t)\n" -" if t.url then\n" -" local u = url.parse(t.url)\n" -" for i,v in base.pairs(t) do\n" -" u[i] = v\n" -" end\n" -" return u\n" -" else return t end\n" -"end\n" -"\n" -"local function tput(putt)\n" -" putt = override(putt)\n" -" socket.try(putt.host, \"missing hostname\")\n" -" local f = _M.open(putt.host, putt.port, putt.create)\n" -" f:greet()\n" -" f:login(putt.user, putt.password)\n" -" if putt.type then f:type(putt.type) end\n" -" f:pasv()\n" -" local sent = f:send(putt)\n" -" f:quit()\n" -" f:close()\n" -" return sent\n" -"end\n" -"\n" -"local default = {\n" -" path = \"/\",\n" -" scheme = \"ftp\"\n" -"}\n" -"\n" -"local function parse(u)\n" -" local t = socket.try(url.parse(u, default))\n" -" socket.try(t.scheme == \"ftp\", \"wrong scheme '\" .. t.scheme .. \"'\")\n" -" socket.try(t.host, \"missing hostname\")\n" -" local pat = \"^type=(.)$\"\n" -" if t.params then\n" -" t.type = socket.skip(2, string.find(t.params, pat))\n" -" socket.try(t.type == \"a\" or t.type == \"i\",\n" -" \"invalid type '\" .. t.type .. \"'\")\n" -" end\n" -" return t\n" -"end\n" -"\n" -"local function sput(u, body)\n" -" local putt = parse(u)\n" -" putt.source = ltn12.source.string(body)\n" -" return tput(putt)\n" -"end\n" -"\n" -"_M.put = socket.protect(function(putt, body)\n" -" if base.type(putt) == \"string\" then return sput(putt, body)\n" -" else return tput(putt) end\n" -"end)\n" -"\n" -"local function tget(gett)\n" -" gett = override(gett)\n" -" socket.try(gett.host, \"missing hostname\")\n" -" local f = _M.open(gett.host, gett.port, gett.create)\n" -" f:greet()\n" -" f:login(gett.user, gett.password)\n" -" if gett.type then f:type(gett.type) end\n" -" f:pasv()\n" -" f:receive(gett)\n" -" f:quit()\n" -" return f:close()\n" -"end\n" -"\n" -"local function sget(u)\n" -" local gett = parse(u)\n" -" local t = {}\n" -" gett.sink = ltn12.sink.table(t)\n" -" tget(gett)\n" -" return table.concat(t)\n" -"end\n" -"\n" -"_M.command = socket.protect(function(cmdt)\n" -" cmdt = override(cmdt)\n" -" socket.try(cmdt.host, \"missing hostname\")\n" -" socket.try(cmdt.command, \"missing command\")\n" -" local f = open(cmdt.host, cmdt.port, cmdt.create)\n" -" f:greet()\n" -" f:login(cmdt.user, cmdt.password)\n" -" f.try(f.tp:command(cmdt.command, cmdt.argument))\n" -" if cmdt.check then f.try(f.tp:check(cmdt.check)) end\n" -" f:quit()\n" -" return f:close()\n" -"end)\n" -"\n" -"_M.get = socket.protect(function(gett)\n" -" if base.type(gett) == \"string\" then return sget(gett)\n" -" else return tget(gett) end\n" -"end)\n" -"\n" -"return _M\n" -"\n"; - -/* socket.headers */ -static const char *lua_m_socket_headers = -"-----------------------------------------------------------------------------\n" -"-- Canonic header field capitalization\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"local socket = require(\"socket.socket\")\n" -"socket.headers = {}\n" -"local _M = socket.headers\n" -"\n" -"_M.canonic = {\n" -" [\"accept\"] = \"Accept\",\n" -" [\"accept-charset\"] = \"Accept-Charset\",\n" -" [\"accept-encoding\"] = \"Accept-Encoding\",\n" -" [\"accept-language\"] = \"Accept-Language\",\n" -" [\"accept-ranges\"] = \"Accept-Ranges\",\n" -" [\"action\"] = \"Action\",\n" -" [\"alternate-recipient\"] = \"Alternate-Recipient\",\n" -" [\"age\"] = \"Age\",\n" -" [\"allow\"] = \"Allow\",\n" -" [\"arrival-date\"] = \"Arrival-Date\",\n" -" [\"authorization\"] = \"Authorization\",\n" -" [\"bcc\"] = \"Bcc\",\n" -" [\"cache-control\"] = \"Cache-Control\",\n" -" [\"cc\"] = \"Cc\",\n" -" [\"comments\"] = \"Comments\",\n" -" [\"connection\"] = \"Connection\",\n" -" [\"content-description\"] = \"Content-Description\",\n" -" [\"content-disposition\"] = \"Content-Disposition\",\n" -" [\"content-encoding\"] = \"Content-Encoding\",\n" -" [\"content-id\"] = \"Content-ID\",\n" -" [\"content-language\"] = \"Content-Language\",\n" -" [\"content-length\"] = \"Content-Length\",\n" -" [\"content-location\"] = \"Content-Location\",\n" -" [\"content-md5\"] = \"Content-MD5\",\n" -" [\"content-range\"] = \"Content-Range\",\n" -" [\"content-transfer-encoding\"] = \"Content-Transfer-Encoding\",\n" -" [\"content-type\"] = \"Content-Type\",\n" -" [\"cookie\"] = \"Cookie\",\n" -" [\"date\"] = \"Date\",\n" -" [\"diagnostic-code\"] = \"Diagnostic-Code\",\n" -" [\"dsn-gateway\"] = \"DSN-Gateway\",\n" -" [\"etag\"] = \"ETag\",\n" -" [\"expect\"] = \"Expect\",\n" -" [\"expires\"] = \"Expires\",\n" -" [\"final-log-id\"] = \"Final-Log-ID\",\n" -" [\"final-recipient\"] = \"Final-Recipient\",\n" -" [\"from\"] = \"From\",\n" -" [\"host\"] = \"Host\",\n" -" [\"if-match\"] = \"If-Match\",\n" -" [\"if-modified-since\"] = \"If-Modified-Since\",\n" -" [\"if-none-match\"] = \"If-None-Match\",\n" -" [\"if-range\"] = \"If-Range\",\n" -" [\"if-unmodified-since\"] = \"If-Unmodified-Since\",\n" -" [\"in-reply-to\"] = \"In-Reply-To\",\n" -" [\"keywords\"] = \"Keywords\",\n" -" [\"last-attempt-date\"] = \"Last-Attempt-Date\",\n" -" [\"last-modified\"] = \"Last-Modified\",\n" -" [\"location\"] = \"Location\",\n" -" [\"max-forwards\"] = \"Max-Forwards\",\n" -" [\"message-id\"] = \"Message-ID\",\n" -" [\"mime-version\"] = \"MIME-Version\",\n" -" [\"original-envelope-id\"] = \"Original-Envelope-ID\",\n" -" [\"original-recipient\"] = \"Original-Recipient\",\n" -" [\"pragma\"] = \"Pragma\",\n" -" [\"proxy-authenticate\"] = \"Proxy-Authenticate\",\n" -" [\"proxy-authorization\"] = \"Proxy-Authorization\",\n" -" [\"range\"] = \"Range\",\n" -" [\"received\"] = \"Received\",\n" -" [\"received-from-mta\"] = \"Received-From-MTA\",\n" -" [\"references\"] = \"References\",\n" -" [\"referer\"] = \"Referer\",\n" -" [\"remote-mta\"] = \"Remote-MTA\",\n" -" [\"reply-to\"] = \"Reply-To\",\n" -" [\"reporting-mta\"] = \"Reporting-MTA\",\n" -" [\"resent-bcc\"] = \"Resent-Bcc\",\n" -" [\"resent-cc\"] = \"Resent-Cc\",\n" -" [\"resent-date\"] = \"Resent-Date\",\n" -" [\"resent-from\"] = \"Resent-From\",\n" -" [\"resent-message-id\"] = \"Resent-Message-ID\",\n" -" [\"resent-reply-to\"] = \"Resent-Reply-To\",\n" -" [\"resent-sender\"] = \"Resent-Sender\",\n" -" [\"resent-to\"] = \"Resent-To\",\n" -" [\"retry-after\"] = \"Retry-After\",\n" -" [\"return-path\"] = \"Return-Path\",\n" -" [\"sender\"] = \"Sender\",\n" -" [\"server\"] = \"Server\",\n" -" [\"smtp-remote-recipient\"] = \"SMTP-Remote-Recipient\",\n" -" [\"status\"] = \"Status\",\n" -" [\"subject\"] = \"Subject\",\n" -" [\"te\"] = \"TE\",\n" -" [\"to\"] = \"To\",\n" -" [\"trailer\"] = \"Trailer\",\n" -" [\"transfer-encoding\"] = \"Transfer-Encoding\",\n" -" [\"upgrade\"] = \"Upgrade\",\n" -" [\"user-agent\"] = \"User-Agent\",\n" -" [\"vary\"] = \"Vary\",\n" -" [\"via\"] = \"Via\",\n" -" [\"warning\"] = \"Warning\",\n" -" [\"will-retry-until\"] = \"Will-Retry-Until\",\n" -" [\"www-authenticate\"] = \"WWW-Authenticate\",\n" -" [\"x-mailer\"] = \"X-Mailer\",\n" -"}\n" -"\n" -"return _M\n" -"\n"; - -/* socket.http */ -static const char *lua_m_socket_http = -"-----------------------------------------------------------------------------\n" -"-- HTTP/1.1 client support for the Lua language.\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module and import dependencies\n" -"-------------------------------------------------------------------------------\n" -"local socket = require(\"socket.socket\")\n" -"local url = require(\"socket.url\")\n" -"local ltn12 = require(\"socket.ltn12\")\n" -"local mime = require(\"socket.mime\")\n" -"local string = require(\"string\")\n" -"local headers = require(\"socket.headers\")\n" -"local base = _G\n" -"local table = require(\"table\")\n" -"socket.http = {}\n" -"local _M = socket.http\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Program constants\n" -"-----------------------------------------------------------------------------\n" -"-- connection timeout in seconds\n" -"TIMEOUT = 60\n" -"-- default port for document retrieval\n" -"_M.PORT = 80\n" -"-- user agent field sent in request\n" -"_M.USERAGENT = socket._VERSION\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Reads MIME headers from a connection, unfolding where needed\n" -"-----------------------------------------------------------------------------\n" -"local function receiveheaders(sock, headers)\n" -" local line, name, value, err\n" -" headers = headers or {}\n" -" -- get first line\n" -" line, err = sock:receive()\n" -" if err then return nil, err end\n" -" -- headers go until a blank line is found\n" -" while line ~= \"\" do\n" -" -- get field-name and value\n" -" name, value = socket.skip(2, string.find(line, \"^(.-):%s*(.*)\"))\n" -" if not (name and value) then return nil, \"malformed reponse headers\" end\n" -" name = string.lower(name)\n" -" -- get next line (value might be folded)\n" -" line, err = sock:receive()\n" -" if err then return nil, err end\n" -" -- unfold any folded values\n" -" while string.find(line, \"^%s\") do\n" -" value = value .. line\n" -" line = sock:receive()\n" -" if err then return nil, err end\n" -" end\n" -" -- save pair in table\n" -" if headers[name] then headers[name] = headers[name] .. \", \" .. value\n" -" else headers[name] = value end\n" -" end\n" -" return headers\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Extra sources and sinks\n" -"-----------------------------------------------------------------------------\n" -"socket.sourcet[\"http-chunked\"] = function(sock, headers)\n" -" return base.setmetatable({\n" -" getfd = function() return sock:getfd() end,\n" -" dirty = function() return sock:dirty() end\n" -" }, {\n" -" __call = function()\n" -" -- get chunk size, skip extention\n" -" local line, err = sock:receive()\n" -" if err then return nil, err end\n" -" local size = base.tonumber(string.gsub(line, \";.*\", \"\"), 16)\n" -" if not size then return nil, \"invalid chunk size\" end\n" -" -- was it the last chunk?\n" -" if size > 0 then\n" -" -- if not, get chunk and skip terminating CRLF\n" -" local chunk, err, part = sock:receive(size)\n" -" if chunk then sock:receive() end\n" -" return chunk, err\n" -" else\n" -" -- if it was, read trailers into headers table\n" -" headers, err = receiveheaders(sock, headers)\n" -" if not headers then return nil, err end\n" -" end\n" -" end\n" -" })\n" -"end\n" -"\n" -"socket.sinkt[\"http-chunked\"] = function(sock)\n" -" return base.setmetatable({\n" -" getfd = function() return sock:getfd() end,\n" -" dirty = function() return sock:dirty() end\n" -" }, {\n" -" __call = function(self, chunk, err)\n" -" if not chunk then return sock:send(\"0\r\n\r\n\") end\n" -" local size = string.format(\"%X\r\n\", string.len(chunk))\n" -" return sock:send(size .. chunk .. \"\r\n\")\n" -" end\n" -" })\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Low level HTTP API\n" -"-----------------------------------------------------------------------------\n" -"local metat = { __index = {} }\n" -"\n" -"function _M.open(host, port, create)\n" -" -- create socket with user connect function, or with default\n" -" local c = socket.try((create or socket.tcp)())\n" -" local h = base.setmetatable({ c = c }, metat)\n" -" -- create finalized try\n" -" h.try = socket.newtry(function() h:close() end)\n" -" -- set timeout before connecting\n" -" h.try(c:settimeout(_M.TIMEOUT))\n" -" h.try(c:connect(host, port or _M.PORT))\n" -" -- here everything worked\n" -" return h\n" -"end\n" -"\n" -"function metat.__index:sendrequestline(method, uri)\n" -" local reqline = string.format(\"%s %s HTTP/1.1\r\n\", method or \"GET\", uri)\n" -" return self.try(self.c:send(reqline))\n" -"end\n" -"\n" -"function metat.__index:sendheaders(tosend)\n" -" local canonic = headers.canonic\n" -" local h = \"\r\n\"\n" -" for f, v in base.pairs(tosend) do\n" -" h = (canonic[f] or f) .. \": \" .. v .. \"\r\n\" .. h\n" -" end\n" -" self.try(self.c:send(h))\n" -" return 1\n" -"end\n" -"\n" -"function metat.__index:sendbody(headers, source, step)\n" -" source = source or ltn12.source.empty()\n" -" step = step or ltn12.pump.step\n" -" -- if we don't know the size in advance, send chunked and hope for the best\n" -" local mode = \"http-chunked\"\n" -" if headers[\"content-length\"] then mode = \"keep-open\" end\n" -" return self.try(ltn12.pump.all(source, socket.sink(mode, self.c), step))\n" -"end\n" -"\n" -"function metat.__index:receivestatusline()\n" -" local status = self.try(self.c:receive(5))\n" -" -- identify HTTP/0.9 responses, which do not contain a status line\n" -" -- this is just a heuristic, but is what the RFC recommends\n" -" if status ~= \"HTTP/\" then return nil, status end\n" -" -- otherwise proceed reading a status line\n" -" status = self.try(self.c:receive(\"*l\", status))\n" -" local code = socket.skip(2, string.find(status, \"HTTP/%d*%.%d* (%d%d%d)\"))\n" -" return self.try(base.tonumber(code), status)\n" -"end\n" -"\n" -"function metat.__index:receiveheaders()\n" -" return self.try(receiveheaders(self.c))\n" -"end\n" -"\n" -"function metat.__index:receivebody(headers, sink, step)\n" -" sink = sink or ltn12.sink.null()\n" -" step = step or ltn12.pump.step\n" -" local length = base.tonumber(headers[\"content-length\"])\n" -" local t = headers[\"transfer-encoding\"] -- shortcut\n" -" local mode = \"default\" -- connection close\n" -" if t and t ~= \"identity\" then mode = \"http-chunked\"\n" -" elseif base.tonumber(headers[\"content-length\"]) then mode = \"by-length\" end\n" -" return self.try(ltn12.pump.all(socket.source(mode, self.c, length),\n" -" sink, step))\n" -"end\n" -"\n" -"function metat.__index:receive09body(status, sink, step)\n" -" local source = ltn12.source.rewind(socket.source(\"until-closed\", self.c))\n" -" source(status)\n" -" return self.try(ltn12.pump.all(source, sink, step))\n" -"end\n" -"\n" -"function metat.__index:close()\n" -" return self.c:close()\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- High level HTTP API\n" -"-----------------------------------------------------------------------------\n" -"local function adjusturi(reqt)\n" -" local u = reqt\n" -" -- if there is a proxy, we need the full url. otherwise, just a part.\n" -" if not reqt.proxy and not PROXY then\n" -" u = {\n" -" path = socket.try(reqt.path, \"invalid path 'nil'\"),\n" -" params = reqt.params,\n" -" query = reqt.query,\n" -" fragment = reqt.fragment\n" -" }\n" -" end\n" -" return url.build(u)\n" -"end\n" -"\n" -"local function adjustproxy(reqt)\n" -" local proxy = reqt.proxy or PROXY\n" -" if proxy then\n" -" proxy = url.parse(proxy)\n" -" return proxy.host, proxy.port or 3128\n" -" else\n" -" return reqt.host, reqt.port\n" -" end\n" -"end\n" -"\n" -"local function adjustheaders(reqt)\n" -" -- default headers\n" -" local lower = {\n" -" [\"user-agent\"] = _M.USERAGENT,\n" -" [\"host\"] = reqt.host,\n" -" [\"connection\"] = \"close, TE\",\n" -" [\"te\"] = \"trailers\"\n" -" }\n" -" -- if we have authentication information, pass it along\n" -" if reqt.user and reqt.password then\n" -" lower[\"authorization\"] =\n" -" \"Basic \" .. (mime.b64(reqt.user .. \":\" .. reqt.password))\n" -" end\n" -" -- override with user headers\n" -" for i,v in base.pairs(reqt.headers or lower) do\n" -" lower[string.lower(i)] = v\n" -" end\n" -" return lower\n" -"end\n" -"\n" -"-- default url parts\n" -"local default = {\n" -" host = \"\",\n" -" port = _M.PORT,\n" -" path =\"/\",\n" -" scheme = \"http\"\n" -"}\n" -"\n" -"local function adjustrequest(reqt)\n" -" -- parse url if provided\n" -" local nreqt = reqt.url and url.parse(reqt.url, default) or {}\n" -" -- explicit components override url\n" -" for i,v in base.pairs(reqt) do nreqt[i] = v end\n" -" if nreqt.port == \"\" then nreqt.port = 80 end\n" -" socket.try(nreqt.host and nreqt.host ~= \"\",\n" -" \"invalid host '\" .. base.tostring(nreqt.host) .. \"'\")\n" -" -- compute uri if user hasn't overriden\n" -" nreqt.uri = reqt.uri or adjusturi(nreqt)\n" -" -- ajust host and port if there is a proxy\n" -" nreqt.host, nreqt.port = adjustproxy(nreqt)\n" -" -- adjust headers in request\n" -" nreqt.headers = adjustheaders(nreqt)\n" -" return nreqt\n" -"end\n" -"\n" -"local function shouldredirect(reqt, code, headers)\n" -" return headers.location and\n" -" string.gsub(headers.location, \"%s\", \"\") ~= \"\" and\n" -" (reqt.redirect ~= false) and\n" -" (code == 301 or code == 302 or code == 303 or code == 307) and\n" -" (not reqt.method or reqt.method == \"GET\" or reqt.method == \"HEAD\")\n" -" and (not reqt.nredirects or reqt.nredirects < 5)\n" -"end\n" -"\n" -"local function shouldreceivebody(reqt, code)\n" -" if reqt.method == \"HEAD\" then return nil end\n" -" if code == 204 or code == 304 then return nil end\n" -" if code >= 100 and code < 200 then return nil end\n" -" return 1\n" -"end\n" -"\n" -"-- forward declarations\n" -"local trequest, tredirect\n" -"\n" -"--[[local]] function tredirect(reqt, location)\n" -" local result, code, headers, status = trequest {\n" -" -- the RFC says the redirect URL has to be absolute, but some\n" -" -- servers do not respect that\n" -" url = url.absolute(reqt.url, location),\n" -" source = reqt.source,\n" -" sink = reqt.sink,\n" -" headers = reqt.headers,\n" -" proxy = reqt.proxy,\n" -" nredirects = (reqt.nredirects or 0) + 1,\n" -" create = reqt.create\n" -" }\n" -" -- pass location header back as a hint we redirected\n" -" headers = headers or {}\n" -" headers.location = headers.location or location\n" -" return result, code, headers, status\n" -"end\n" -"\n" -"--[[local]] function trequest(reqt)\n" -" -- we loop until we get what we want, or\n" -" -- until we are sure there is no way to get it\n" -" local nreqt = adjustrequest(reqt)\n" -" local h = _M.open(nreqt.host, nreqt.port, nreqt.create)\n" -" -- send request line and headers\n" -" h:sendrequestline(nreqt.method, nreqt.uri)\n" -" h:sendheaders(nreqt.headers)\n" -" -- if there is a body, send it\n" -" if nreqt.source then\n" -" h:sendbody(nreqt.headers, nreqt.source, nreqt.step)\n" -" end\n" -" local code, status = h:receivestatusline()\n" -" -- if it is an HTTP/0.9 server, simply get the body and we are done\n" -" if not code then\n" -" h:receive09body(status, nreqt.sink, nreqt.step)\n" -" return 1, 200\n" -" end\n" -" local headers\n" -" -- ignore any 100-continue messages\n" -" while code == 100 do\n" -" headers = h:receiveheaders()\n" -" code, status = h:receivestatusline()\n" -" end\n" -" headers = h:receiveheaders()\n" -" -- at this point we should have a honest reply from the server\n" -" -- we can't redirect if we already used the source, so we report the error\n" -" if shouldredirect(nreqt, code, headers) and not nreqt.source then\n" -" h:close()\n" -" return tredirect(reqt, headers.location)\n" -" end\n" -" -- here we are finally done\n" -" if shouldreceivebody(nreqt, code) then\n" -" h:receivebody(headers, nreqt.sink, nreqt.step)\n" -" end\n" -" h:close()\n" -" return 1, code, headers, status\n" -"end\n" -"\n" -"local function srequest(u, b)\n" -" local t = {}\n" -" local reqt = {\n" -" url = u,\n" -" sink = ltn12.sink.table(t)\n" -" }\n" -" if b then\n" -" reqt.source = ltn12.source.string(b)\n" -" reqt.headers = {\n" -" [\"content-length\"] = string.len(b),\n" -" [\"content-type\"] = \"application/x-www-form-urlencoded\"\n" -" }\n" -" reqt.method = \"POST\"\n" -" end\n" -" local code, headers, status = socket.skip(1, trequest(reqt))\n" -" return table.concat(t), code, headers, status\n" -"end\n" -"\n" -"_M.request = socket.protect(function(reqt, body)\n" -" if base.type(reqt) == \"string\" then return srequest(reqt, body)\n" -" else return trequest(reqt) end\n" -"end)\n" -"\n" -"return _M\n" -"\n"; - -/* socket.mbox */ -static const char *lua_m_socket_mbox = -"local _M = {}\n" -"\n" -"if module then\n" -" mbox = _M\n" -"end \n" -"\n" -"function _M.split_message(message_s)\n" -" local message = {}\n" -" message_s = string.gsub(message_s, \"\r\n\", \"\n\")\n" -" string.gsub(message_s, \"^(.-\n)\n\", function (h) message.headers = h end)\n" -" string.gsub(message_s, \"^.-\n\n(.*)\", function (b) message.body = b end)\n" -" if not message.body then\n" -" string.gsub(message_s, \"^\n(.*)\", function (b) message.body = b end)\n" -" end\n" -" if not message.headers and not message.body then\n" -" message.headers = message_s\n" -" end\n" -" return message.headers or \"\", message.body or \"\"\n" -"end\n" -"\n" -"function _M.split_headers(headers_s)\n" -" local headers = {}\n" -" headers_s = string.gsub(headers_s, \"\r\n\", \"\n\")\n" -" headers_s = string.gsub(headers_s, \"\n[ ]+\", \" \")\n" -" string.gsub(\"\n\" .. headers_s, \"\n([^\n]+)\", function (h) table.insert(headers, h) end)\n" -" return headers\n" -"end\n" -"\n" -"function _M.parse_header(header_s)\n" -" header_s = string.gsub(header_s, \"\n[ ]+\", \" \")\n" -" header_s = string.gsub(header_s, \"\n+\", \"\")\n" -" local _, __, name, value = string.find(header_s, \"([^%s:]-):%s*(.*)\")\n" -" return name, value\n" -"end\n" -"\n" -"function _M.parse_headers(headers_s)\n" -" local headers_t = _M.split_headers(headers_s)\n" -" local headers = {}\n" -" for i = 1, #headers_t do\n" -" local name, value = _M.parse_header(headers_t[i])\n" -" if name then\n" -" name = string.lower(name)\n" -" if headers[name] then\n" -" headers[name] = headers[name] .. \", \" .. value\n" -" else headers[name] = value end\n" -" end\n" -" end\n" -" return headers\n" -"end\n" -"\n" -"function _M.parse_from(from)\n" -" local _, __, name, address = string.find(from, \"^%s*(.-)%s*%<(.-)%>\")\n" -" if not address then\n" -" _, __, address = string.find(from, \"%s*(.+)%s*\")\n" -" end\n" -" name = name or \"\"\n" -" address = address or \"\"\n" -" if name == \"\" then name = address end\n" -" name = string.gsub(name, '\"', \"\")\n" -" return name, address\n" -"end\n" -"\n" -"function _M.split_mbox(mbox_s)\n" -" mbox = {}\n" -" mbox_s = string.gsub(mbox_s, \"\r\n\", \"\n\") ..\"\n\nFrom \n\"\n" -" local nj, i, j = 1, 1, 1\n" -" while 1 do\n" -" i, nj = string.find(mbox_s, \"\n\nFrom .-\n\", j)\n" -" if not i then break end\n" -" local message = string.sub(mbox_s, j, i-1)\n" -" table.insert(mbox, message)\n" -" j = nj+1\n" -" end\n" -" return mbox\n" -"end\n" -"\n" -"function _M.parse(mbox_s)\n" -" local mbox = _M.split_mbox(mbox_s)\n" -" for i = 1, #mbox do\n" -" mbox[i] = _M.parse_message(mbox[i])\n" -" end\n" -" return mbox\n" -"end\n" -"\n" -"function _M.parse_message(message_s)\n" -" local message = {}\n" -" message.headers, message.body = _M.split_message(message_s)\n" -" message.headers = _M.parse_headers(message.headers)\n" -" return message\n" -"end\n" -"\n" -"return _M\n" -"\n"; - -/* socket.smtp */ -static const char *lua_m_socket_smtp = -"-----------------------------------------------------------------------------\n" -"-- SMTP client support for the Lua language.\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module and import dependencies\n" -"-----------------------------------------------------------------------------\n" -"local base = _G\n" -"local coroutine = require(\"coroutine\")\n" -"local string = require(\"string\")\n" -"local math = require(\"math\")\n" -"local os = require(\"os\")\n" -"local socket = require(\"socket.socket\")\n" -"local tp = require(\"socket.tp\")\n" -"local ltn12 = require(\"socket.ltn12\")\n" -"local headers = require(\"socket.headers\")\n" -"local mime = require(\"socket.mime\")\n" -"\n" -"socket.smtp = {}\n" -"local _M = socket.smtp\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Program constants\n" -"-----------------------------------------------------------------------------\n" -"-- timeout for connection\n" -"_M.TIMEOUT = 60\n" -"-- default server used to send e-mails\n" -"_M.SERVER = \"localhost\"\n" -"-- default port\n" -"_M.PORT = 25\n" -"-- domain used in HELO command and default sendmail\n" -"-- If we are under a CGI, try to get from environment\n" -"_M.DOMAIN = os.getenv(\"SERVER_NAME\") or \"localhost\"\n" -"-- default time zone (means we don't know)\n" -"_M.ZONE = \"-0000\"\n" -"\n" -"---------------------------------------------------------------------------\n" -"-- Low level SMTP API\n" -"-----------------------------------------------------------------------------\n" -"local metat = { __index = {} }\n" -"\n" -"function metat.__index:greet(domain)\n" -" self.try(self.tp:check(\"2..\"))\n" -" self.try(self.tp:command(\"EHLO\", domain or _M.DOMAIN))\n" -" return socket.skip(1, self.try(self.tp:check(\"2..\")))\n" -"end\n" -"\n" -"function metat.__index:mail(from)\n" -" self.try(self.tp:command(\"MAIL\", \"FROM:\" .. from))\n" -" return self.try(self.tp:check(\"2..\"))\n" -"end\n" -"\n" -"function metat.__index:rcpt(to)\n" -" self.try(self.tp:command(\"RCPT\", \"TO:\" .. to))\n" -" return self.try(self.tp:check(\"2..\"))\n" -"end\n" -"\n" -"function metat.__index:data(src, step)\n" -" self.try(self.tp:command(\"DATA\"))\n" -" self.try(self.tp:check(\"3..\"))\n" -" self.try(self.tp:source(src, step))\n" -" self.try(self.tp:send(\"\r\n.\r\n\"))\n" -" return self.try(self.tp:check(\"2..\"))\n" -"end\n" -"\n" -"function metat.__index:quit()\n" -" self.try(self.tp:command(\"QUIT\"))\n" -" return self.try(self.tp:check(\"2..\"))\n" -"end\n" -"\n" -"function metat.__index:close()\n" -" return self.tp:close()\n" -"end\n" -"\n" -"function metat.__index:login(user, password)\n" -" self.try(self.tp:command(\"AUTH\", \"LOGIN\"))\n" -" self.try(self.tp:check(\"3..\"))\n" -" self.try(self.tp:send(mime.b64(user) .. \"\r\n\"))\n" -" self.try(self.tp:check(\"3..\"))\n" -" self.try(self.tp:send(mime.b64(password) .. \"\r\n\"))\n" -" return self.try(self.tp:check(\"2..\"))\n" -"end\n" -"\n" -"function metat.__index:plain(user, password)\n" -" local auth = \"PLAIN \" .. mime.b64(\"\0\" .. user .. \"\0\" .. password)\n" -" self.try(self.tp:command(\"AUTH\", auth))\n" -" return self.try(self.tp:check(\"2..\"))\n" -"end\n" -"\n" -"function metat.__index:auth(user, password, ext)\n" -" if not user or not password then return 1 end\n" -" if string.find(ext, \"AUTH[^\n]+LOGIN\") then\n" -" return self:login(user, password)\n" -" elseif string.find(ext, \"AUTH[^\n]+PLAIN\") then\n" -" return self:plain(user, password)\n" -" else\n" -" self.try(nil, \"authentication not supported\")\n" -" end\n" -"end\n" -"\n" -"-- send message or throw an exception\n" -"function metat.__index:send(mailt)\n" -" self:mail(mailt.from)\n" -" if base.type(mailt.rcpt) == \"table\" then\n" -" for i,v in base.ipairs(mailt.rcpt) do\n" -" self:rcpt(v)\n" -" end\n" -" else\n" -" self:rcpt(mailt.rcpt)\n" -" end\n" -" self:data(ltn12.source.chain(mailt.source, mime.stuff()), mailt.step)\n" -"end\n" -"\n" -"function _M.open(server, port, create)\n" -" local tp = socket.try(tp.connect(server or _M.SERVER, port or _M.PORT,\n" -" _M.TIMEOUT, create))\n" -" local s = base.setmetatable({tp = tp}, metat)\n" -" -- make sure tp is closed if we get an exception\n" -" s.try = socket.newtry(function()\n" -" s:close()\n" -" end)\n" -" return s\n" -"end\n" -"\n" -"-- convert headers to lowercase\n" -"local function lower_headers(headers)\n" -" local lower = {}\n" -" for i,v in base.pairs(headers or lower) do\n" -" lower[string.lower(i)] = v\n" -" end\n" -" return lower\n" -"end\n" -"\n" -"---------------------------------------------------------------------------\n" -"-- Multipart message source\n" -"-----------------------------------------------------------------------------\n" -"-- returns a hopefully unique mime boundary\n" -"local seqno = 0\n" -"local function newboundary()\n" -" seqno = seqno + 1\n" -" return string.format('%s%05d==%05u', os.date('%d%m%Y%H%M%S'),\n" -" math.random(0, 99999), seqno)\n" -"end\n" -"\n" -"-- send_message forward declaration\n" -"local send_message\n" -"\n" -"-- yield the headers all at once, it's faster\n" -"local function send_headers(tosend)\n" -" local canonic = headers.canonic\n" -" local h = \"\r\n\"\n" -" for f,v in base.pairs(tosend) do\n" -" h = (canonic[f] or f) .. ': ' .. v .. \"\r\n\" .. h\n" -" end\n" -" coroutine.yield(h)\n" -"end\n" -"\n" -"-- yield multipart message body from a multipart message table\n" -"local function send_multipart(mesgt)\n" -" -- make sure we have our boundary and send headers\n" -" local bd = newboundary()\n" -" local headers = lower_headers(mesgt.headers or {})\n" -" headers['content-type'] = headers['content-type'] or 'multipart/mixed'\n" -" headers['content-type'] = headers['content-type'] ..\n" -" '; boundary=\"' .. bd .. '\"'\n" -" send_headers(headers)\n" -" -- send preamble\n" -" if mesgt.body.preamble then\n" -" coroutine.yield(mesgt.body.preamble)\n" -" coroutine.yield(\"\r\n\")\n" -" end\n" -" -- send each part separated by a boundary\n" -" for i, m in base.ipairs(mesgt.body) do\n" -" coroutine.yield(\"\r\n--\" .. bd .. \"\r\n\")\n" -" send_message(m)\n" -" end\n" -" -- send last boundary\n" -" coroutine.yield(\"\r\n--\" .. bd .. \"--\r\n\r\n\")\n" -" -- send epilogue\n" -" if mesgt.body.epilogue then\n" -" coroutine.yield(mesgt.body.epilogue)\n" -" coroutine.yield(\"\r\n\")\n" -" end\n" -"end\n" -"\n" -"-- yield message body from a source\n" -"local function send_source(mesgt)\n" -" -- make sure we have a content-type\n" -" local headers = lower_headers(mesgt.headers or {})\n" -" headers['content-type'] = headers['content-type'] or\n" -" 'text/plain; charset=\"iso-8859-1\"'\n" -" send_headers(headers)\n" -" -- send body from source\n" -" while true do\n" -" local chunk, err = mesgt.body()\n" -" if err then coroutine.yield(nil, err)\n" -" elseif chunk then coroutine.yield(chunk)\n" -" else break end\n" -" end\n" -"end\n" -"\n" -"-- yield message body from a string\n" -"local function send_string(mesgt)\n" -" -- make sure we have a content-type\n" -" local headers = lower_headers(mesgt.headers or {})\n" -" headers['content-type'] = headers['content-type'] or\n" -" 'text/plain; charset=\"iso-8859-1\"'\n" -" send_headers(headers)\n" -" -- send body from string\n" -" coroutine.yield(mesgt.body)\n" -"end\n" -"\n" -"-- message source\n" -"function send_message(mesgt)\n" -" if base.type(mesgt.body) == \"table\" then send_multipart(mesgt)\n" -" elseif base.type(mesgt.body) == \"function\" then send_source(mesgt)\n" -" else send_string(mesgt) end\n" -"end\n" -"\n" -"-- set defaul headers\n" -"local function adjust_headers(mesgt)\n" -" local lower = lower_headers(mesgt.headers)\n" -" lower[\"date\"] = lower[\"date\"] or\n" -" os.date(\"!%a, %d %b %Y %H:%M:%S \") .. (mesgt.zone or _M.ZONE)\n" -" lower[\"x-mailer\"] = lower[\"x-mailer\"] or socket._VERSION\n" -" -- this can't be overriden\n" -" lower[\"mime-version\"] = \"1.0\"\n" -" return lower\n" -"end\n" -"\n" -"function _M.message(mesgt)\n" -" mesgt.headers = adjust_headers(mesgt)\n" -" -- create and return message source\n" -" local co = coroutine.create(function() send_message(mesgt) end)\n" -" return function()\n" -" local ret, a, b = coroutine.resume(co)\n" -" if ret then return a, b\n" -" else return nil, a end\n" -" end\n" -"end\n" -"\n" -"---------------------------------------------------------------------------\n" -"-- High level SMTP API\n" -"-----------------------------------------------------------------------------\n" -"_M.send = socket.protect(function(mailt)\n" -" local s = _M.open(mailt.server, mailt.port, mailt.create)\n" -" local ext = s:greet(mailt.domain)\n" -" s:auth(mailt.user, mailt.password, ext)\n" -" s:send(mailt)\n" -" s:quit()\n" -" return s:close()\n" -"end)\n" -"\n" -"return _M\n" -"\n"; - -/* socket.tp */ -static const char *lua_m_socket_tp = -"-----------------------------------------------------------------------------\n" -"-- Unified SMTP/FTP subsystem\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module and import dependencies\n" -"-----------------------------------------------------------------------------\n" -"local base = _G\n" -"local string = require(\"string\")\n" -"local socket = require(\"socket.socket\")\n" -"local ltn12 = require(\"socket.ltn12\")\n" -"\n" -"socket.tp = {}\n" -"local _M = socket.tp\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Program constants\n" -"-----------------------------------------------------------------------------\n" -"_M.TIMEOUT = 60\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Implementation\n" -"-----------------------------------------------------------------------------\n" -"-- gets server reply (works for SMTP and FTP)\n" -"local function get_reply(c)\n" -" local code, current, sep\n" -" local line, err = c:receive()\n" -" local reply = line\n" -" if err then return nil, err end\n" -" code, sep = socket.skip(2, string.find(line, \"^(%d%d%d)(.?)\"))\n" -" if not code then return nil, \"invalid server reply\" end\n" -" if sep == \"-\" then -- reply is multiline\n" -" repeat\n" -" line, err = c:receive()\n" -" if err then return nil, err end\n" -" current, sep = socket.skip(2, string.find(line, \"^(%d%d%d)(.?)\"))\n" -" reply = reply .. \"\n\" .. line\n" -" -- reply ends with same code\n" -" until code == current and sep == \" \"\n" -" end\n" -" return code, reply\n" -"end\n" -"\n" -"-- metatable for sock object\n" -"local metat = { __index = {} }\n" -"\n" -"function metat.__index:check(ok)\n" -" local code, reply = get_reply(self.c)\n" -" if not code then return nil, reply end\n" -" if base.type(ok) ~= \"function\" then\n" -" if base.type(ok) == \"table\" then\n" -" for i, v in base.ipairs(ok) do\n" -" if string.find(code, v) then\n" -" return base.tonumber(code), reply\n" -" end\n" -" end\n" -" return nil, reply\n" -" else\n" -" if string.find(code, ok) then return base.tonumber(code), reply\n" -" else return nil, reply end\n" -" end\n" -" else return ok(base.tonumber(code), reply) end\n" -"end\n" -"\n" -"function metat.__index:command(cmd, arg)\n" -" cmd = string.upper(cmd)\n" -" if arg then\n" -" return self.c:send(cmd .. \" \" .. arg.. \"\r\n\")\n" -" else\n" -" return self.c:send(cmd .. \"\r\n\")\n" -" end\n" -"end\n" -"\n" -"function metat.__index:sink(snk, pat)\n" -" local chunk, err = c:receive(pat)\n" -" return snk(chunk, err)\n" -"end\n" -"\n" -"function metat.__index:send(data)\n" -" return self.c:send(data)\n" -"end\n" -"\n" -"function metat.__index:receive(pat)\n" -" return self.c:receive(pat)\n" -"end\n" -"\n" -"function metat.__index:getfd()\n" -" return self.c:getfd()\n" -"end\n" -"\n" -"function metat.__index:dirty()\n" -" return self.c:dirty()\n" -"end\n" -"\n" -"function metat.__index:getcontrol()\n" -" return self.c\n" -"end\n" -"\n" -"function metat.__index:source(source, step)\n" -" local sink = socket.sink(\"keep-open\", self.c)\n" -" local ret, err = ltn12.pump.all(source, sink, step or ltn12.pump.step)\n" -" return ret, err\n" -"end\n" -"\n" -"-- closes the underlying c\n" -"function metat.__index:close()\n" -" self.c:close()\n" -" return 1\n" -"end\n" -"\n" -"-- connect with server and return c object\n" -"function _M.connect(host, port, timeout, create)\n" -" local c, e = (create or socket.tcp)()\n" -" if not c then return nil, e end\n" -" c:settimeout(timeout or _M.TIMEOUT)\n" -" local r, e = c:connect(host, port)\n" -" if not r then\n" -" c:close()\n" -" return nil, e\n" -" end\n" -" return base.setmetatable({c = c}, metat)\n" -"end\n" -"\n" -"return _M\n" -"\n"; - -/* socket.url */ -static const char *lua_m_socket_url = -"-----------------------------------------------------------------------------\n" -"-- URI parsing, composition and relative URL resolution\n" -"-- LuaSocket toolkit.\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module\n" -"-----------------------------------------------------------------------------\n" -"local string = require(\"string\")\n" -"local base = _G\n" -"local table = require(\"table\")\n" -"local socket = require(\"socket.socket\")\n" -"\n" -"socket.url = {}\n" -"local _M = socket.url\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Module version\n" -"-----------------------------------------------------------------------------\n" -"_M._VERSION = \"URL 1.0.3\"\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Encodes a string into its escaped hexadecimal representation\n" -"-- Input\n" -"-- s: binary string to be encoded\n" -"-- Returns\n" -"-- escaped representation of string binary\n" -"-----------------------------------------------------------------------------\n" -"function _M.escape(s)\n" -" return (string.gsub(s, \"([^A-Za-z0-9_])\", function(c)\n" -" return string.format(\"%%%02x\", string.byte(c))\n" -" end))\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Protects a path segment, to prevent it from interfering with the\n" -"-- url parsing.\n" -"-- Input\n" -"-- s: binary string to be encoded\n" -"-- Returns\n" -"-- escaped representation of string binary\n" -"-----------------------------------------------------------------------------\n" -"local function make_set(t)\n" -" local s = {}\n" -" for i,v in base.ipairs(t) do\n" -" s[t[i]] = 1\n" -" end\n" -" return s\n" -"end\n" -"\n" -"-- these are allowed withing a path segment, along with alphanum\n" -"-- other characters must be escaped\n" -"local segment_set = make_set {\n" -" \"-\", \"_\", \".\", \"!\", \"~\", \"*\", \"'\", \"(\",\n" -" \")\", \":\", \"@\", \"&\", \"=\", \"+\", \"$\", \",\",\n" -"}\n" -"\n" -"local function protect_segment(s)\n" -" return string.gsub(s, \"([^A-Za-z0-9_])\", function (c)\n" -" if segment_set[c] then return c\n" -" else return string.format(\"%%%02x\", string.byte(c)) end\n" -" end)\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Encodes a string into its escaped hexadecimal representation\n" -"-- Input\n" -"-- s: binary string to be encoded\n" -"-- Returns\n" -"-- escaped representation of string binary\n" -"-----------------------------------------------------------------------------\n" -"function _M.unescape(s)\n" -" return (string.gsub(s, \"%%(%x%x)\", function(hex)\n" -" return string.char(base.tonumber(hex, 16))\n" -" end))\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Builds a path from a base path and a relative path\n" -"-- Input\n" -"-- base_path\n" -"-- relative_path\n" -"-- Returns\n" -"-- corresponding absolute path\n" -"-----------------------------------------------------------------------------\n" -"local function absolute_path(base_path, relative_path)\n" -" if string.sub(relative_path, 1, 1) == \"/\" then return relative_path end\n" -" local path = string.gsub(base_path, \"[^/]*$\", \"\")\n" -" path = path .. relative_path\n" -" path = string.gsub(path, \"([^/]*%./)\", function (s)\n" -" if s ~= \"./\" then return s else return \"\" end\n" -" end)\n" -" path = string.gsub(path, \"/%.$\", \"/\")\n" -" local reduced\n" -" while reduced ~= path do\n" -" reduced = path\n" -" path = string.gsub(reduced, \"([^/]*/%.%./)\", function (s)\n" -" if s ~= \"../../\" then return \"\" else return s end\n" -" end)\n" -" end\n" -" path = string.gsub(reduced, \"([^/]*/%.%.)$\", function (s)\n" -" if s ~= \"../..\" then return \"\" else return s end\n" -" end)\n" -" return path\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Parses a url and returns a table with all its parts according to RFC 2396\n" -"-- The following grammar describes the names given to the URL parts\n" -"-- ::= :///;?#\n" -"-- ::= @:\n" -"-- ::= [:]\n" -"-- :: = {/}\n" -"-- Input\n" -"-- url: uniform resource locator of request\n" -"-- default: table with default values for each field\n" -"-- Returns\n" -"-- table with the following fields, where RFC naming conventions have\n" -"-- been preserved:\n" -"-- scheme, authority, userinfo, user, password, host, port,\n" -"-- path, params, query, fragment\n" -"-- Obs:\n" -"-- the leading '/' in {/} is considered part of \n" -"-----------------------------------------------------------------------------\n" -"function _M.parse(url, default)\n" -" -- initialize default parameters\n" -" local parsed = {}\n" -" for i,v in base.pairs(default or parsed) do parsed[i] = v end\n" -" -- empty url is parsed to nil\n" -" if not url or url == \"\" then return nil, \"invalid url\" end\n" -" -- remove whitespace\n" -" -- url = string.gsub(url, \"%s\", \"\")\n" -" -- get fragment\n" -" url = string.gsub(url, \"#(.*)$\", function(f)\n" -" parsed.fragment = f\n" -" return \"\"\n" -" end)\n" -" -- get scheme\n" -" url = string.gsub(url, \"^([%w][%w%+%-%.]*)%:\",\n" -" function(s) parsed.scheme = s; return \"\" end)\n" -" -- get authority\n" -" url = string.gsub(url, \"^//([^/]*)\", function(n)\n" -" parsed.authority = n\n" -" return \"\"\n" -" end)\n" -" -- get query string\n" -" url = string.gsub(url, \"%?(.*)\", function(q)\n" -" parsed.query = q\n" -" return \"\"\n" -" end)\n" -" -- get params\n" -" url = string.gsub(url, \"%;(.*)\", function(p)\n" -" parsed.params = p\n" -" return \"\"\n" -" end)\n" -" -- path is whatever was left\n" -" if url ~= \"\" then parsed.path = url end\n" -" local authority = parsed.authority\n" -" if not authority then return parsed end\n" -" authority = string.gsub(authority,\"^([^@]*)@\",\n" -" function(u) parsed.userinfo = u; return \"\" end)\n" -" authority = string.gsub(authority, \":([^:%]]*)$\",\n" -" function(p) parsed.port = p; return \"\" end)\n" -" if authority ~= \"\" then\n" -" -- IPv6?\n" -" parsed.host = string.match(authority, \"^%[(.+)%]$\") or authority\n" -" end\n" -" local userinfo = parsed.userinfo\n" -" if not userinfo then return parsed end\n" -" userinfo = string.gsub(userinfo, \":([^:]*)$\",\n" -" function(p) parsed.password = p; return \"\" end)\n" -" parsed.user = userinfo\n" -" return parsed\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Rebuilds a parsed URL from its components.\n" -"-- Components are protected if any reserved or unallowed characters are found\n" -"-- Input\n" -"-- parsed: parsed URL, as returned by parse\n" -"-- Returns\n" -"-- a stringing with the corresponding URL\n" -"-----------------------------------------------------------------------------\n" -"function _M.build(parsed)\n" -" local ppath = _M.parse_path(parsed.path or \"\")\n" -" local url = _M.build_path(ppath)\n" -" if parsed.params then url = url .. \";\" .. parsed.params end\n" -" if parsed.query then url = url .. \"?\" .. parsed.query end\n" -" local authority = parsed.authority\n" -" if parsed.host then\n" -" authority = parsed.host\n" -" if string.find(authority, \":\") then -- IPv6?\n" -" authority = \"[\" .. authority .. \"]\"\n" -" end\n" -" if parsed.port then authority = authority .. \":\" .. parsed.port end\n" -" local userinfo = parsed.userinfo\n" -" if parsed.user then\n" -" userinfo = parsed.user\n" -" if parsed.password then\n" -" userinfo = userinfo .. \":\" .. parsed.password\n" -" end\n" -" end\n" -" if userinfo then authority = userinfo .. \"@\" .. authority end\n" -" end\n" -" if authority then url = \"//\" .. authority .. url end\n" -" if parsed.scheme then url = parsed.scheme .. \":\" .. url end\n" -" if parsed.fragment then url = url .. \"#\" .. parsed.fragment end\n" -" -- url = string.gsub(url, \"%s\", \"\")\n" -" return url\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Builds a absolute URL from a base and a relative URL according to RFC 2396\n" -"-- Input\n" -"-- base_url\n" -"-- relative_url\n" -"-- Returns\n" -"-- corresponding absolute url\n" -"-----------------------------------------------------------------------------\n" -"function _M.absolute(base_url, relative_url)\n" -" if base.type(base_url) == \"table\" then\n" -" base_parsed = base_url\n" -" base_url = _M.build(base_parsed)\n" -" else\n" -" base_parsed = _M.parse(base_url)\n" -" end\n" -" local relative_parsed = _M.parse(relative_url)\n" -" if not base_parsed then return relative_url\n" -" elseif not relative_parsed then return base_url\n" -" elseif relative_parsed.scheme then return relative_url\n" -" else\n" -" relative_parsed.scheme = base_parsed.scheme\n" -" if not relative_parsed.authority then\n" -" relative_parsed.authority = base_parsed.authority\n" -" if not relative_parsed.path then\n" -" relative_parsed.path = base_parsed.path\n" -" if not relative_parsed.params then\n" -" relative_parsed.params = base_parsed.params\n" -" if not relative_parsed.query then\n" -" relative_parsed.query = base_parsed.query\n" -" end\n" -" end\n" -" else\n" -" relative_parsed.path = absolute_path(base_parsed.path or \"\",\n" -" relative_parsed.path)\n" -" end\n" -" end\n" -" return _M.build(relative_parsed)\n" -" end\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Breaks a path into its segments, unescaping the segments\n" -"-- Input\n" -"-- path\n" -"-- Returns\n" -"-- segment: a table with one entry per segment\n" -"-----------------------------------------------------------------------------\n" -"function _M.parse_path(path)\n" -" local parsed = {}\n" -" path = path or \"\"\n" -" --path = string.gsub(path, \"%s\", \"\")\n" -" string.gsub(path, \"([^/]+)\", function (s) table.insert(parsed, s) end)\n" -" for i = 1, #parsed do\n" -" parsed[i] = _M.unescape(parsed[i])\n" -" end\n" -" if string.sub(path, 1, 1) == \"/\" then parsed.is_absolute = 1 end\n" -" if string.sub(path, -1, -1) == \"/\" then parsed.is_directory = 1 end\n" -" return parsed\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Builds a path component from its segments, escaping protected characters.\n" -"-- Input\n" -"-- parsed: path segments\n" -"-- unsafe: if true, segments are not protected before path is built\n" -"-- Returns\n" -"-- path: corresponding path stringing\n" -"-----------------------------------------------------------------------------\n" -"function _M.build_path(parsed, unsafe)\n" -" local path = \"\"\n" -" local n = #parsed\n" -" if unsafe then\n" -" for i = 1, n-1 do\n" -" path = path .. parsed[i]\n" -" path = path .. \"/\"\n" -" end\n" -" if n > 0 then\n" -" path = path .. parsed[n]\n" -" if parsed.is_directory then path = path .. \"/\" end\n" -" end\n" -" else\n" -" for i = 1, n-1 do\n" -" path = path .. protect_segment(parsed[i])\n" -" path = path .. \"/\"\n" -" end\n" -" if n > 0 then\n" -" path = path .. protect_segment(parsed[n])\n" -" if parsed.is_directory then path = path .. \"/\" end\n" -" end\n" -" end\n" -" if parsed.is_absolute then path = \"/\" .. path end\n" -" return path\n" -"end\n" -"\n" -"return _M\n" -"\n"; - -/* socket */ -static const char *lua_m_socket = -"-----------------------------------------------------------------------------\n" -"-- LuaSocket helper module\n" -"-- Author: Diego Nehab\n" -"-----------------------------------------------------------------------------\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Declare module and import dependencies\n" -"-----------------------------------------------------------------------------\n" -"local base = _G\n" -"local string = require(\"string\")\n" -"local math = require(\"math\")\n" -"local socket = require(\"socket.core\")\n" -"\n" -"local _M = socket\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Exported auxiliar functions\n" -"-----------------------------------------------------------------------------\n" -"function _M.connect4(address, port, laddress, lport)\n" -" return socket.connect(address, port, laddress, lport, \"inet\")\n" -"end\n" -"\n" -"function _M.connect6(address, port, laddress, lport)\n" -" return socket.connect(address, port, laddress, lport, \"inet6\")\n" -"end\n" -"\n" -"function _M.bind(host, port, backlog)\n" -" if host == \"*\" then host = \"0.0.0.0\" end\n" -" local addrinfo, err = socket.dns.getaddrinfo(host);\n" -" if not addrinfo then return nil, err end\n" -" local sock, res\n" -" err = \"no info on address\"\n" -" for i, alt in base.ipairs(addrinfo) do\n" -" if alt.family == \"inet\" then\n" -" sock, err = socket.tcp()\n" -" else\n" -" sock, err = socket.tcp6()\n" -" end\n" -" if not sock then return nil, err end\n" -" sock:setoption(\"reuseaddr\", true)\n" -" res, err = sock:bind(alt.addr, port)\n" -" if not res then \n" -" sock:close()\n" -" else \n" -" res, err = sock:listen(backlog)\n" -" if not res then \n" -" sock:close()\n" -" else\n" -" return sock\n" -" end\n" -" end \n" -" end\n" -" return nil, err\n" -"end\n" -"\n" -"_M.try = _M.newtry()\n" -"\n" -"function _M.choose(table)\n" -" return function(name, opt1, opt2)\n" -" if base.type(name) ~= \"string\" then\n" -" name, opt1, opt2 = \"default\", name, opt1\n" -" end\n" -" local f = table[name or \"nil\"]\n" -" if not f then base.error(\"unknown key (\".. base.tostring(name) ..\")\", 3)\n" -" else return f(opt1, opt2) end\n" -" end\n" -"end\n" -"\n" -"-----------------------------------------------------------------------------\n" -"-- Socket sources and sinks, conforming to LTN12\n" -"-----------------------------------------------------------------------------\n" -"-- create namespaces inside LuaSocket namespace\n" -"local sourcet, sinkt = {}, {}\n" -"_M.sourcet = sourcet\n" -"_M.sinkt = sinkt\n" -"\n" -"_M.BLOCKSIZE = 2048\n" -"\n" -"sinkt[\"close-when-done\"] = function(sock)\n" -" return base.setmetatable({\n" -" getfd = function() return sock:getfd() end,\n" -" dirty = function() return sock:dirty() end\n" -" }, {\n" -" __call = function(self, chunk, err)\n" -" if not chunk then\n" -" sock:close()\n" -" return 1\n" -" else return sock:send(chunk) end\n" -" end\n" -" })\n" -"end\n" -"\n" -"sinkt[\"keep-open\"] = function(sock)\n" -" return base.setmetatable({\n" -" getfd = function() return sock:getfd() end,\n" -" dirty = function() return sock:dirty() end\n" -" }, {\n" -" __call = function(self, chunk, err)\n" -" if chunk then return sock:send(chunk)\n" -" else return 1 end\n" -" end\n" -" })\n" -"end\n" -"\n" -"sinkt[\"default\"] = sinkt[\"keep-open\"]\n" -"\n" -"_M.sink = _M.choose(sinkt)\n" -"\n" -"sourcet[\"by-length\"] = function(sock, length)\n" -" return base.setmetatable({\n" -" getfd = function() return sock:getfd() end,\n" -" dirty = function() return sock:dirty() end\n" -" }, {\n" -" __call = function()\n" -" if length <= 0 then return nil end\n" -" local size = math.min(socket.BLOCKSIZE, length)\n" -" local chunk, err = sock:receive(size)\n" -" if err then return nil, err end\n" -" length = length - string.len(chunk)\n" -" return chunk\n" -" end\n" -" })\n" -"end\n" -"\n" -"sourcet[\"until-closed\"] = function(sock)\n" -" local done\n" -" return base.setmetatable({\n" -" getfd = function() return sock:getfd() end,\n" -" dirty = function() return sock:dirty() end\n" -" }, {\n" -" __call = function()\n" -" if done then return nil end\n" -" local chunk, err, partial = sock:receive(socket.BLOCKSIZE)\n" -" if not err then return chunk\n" -" elseif err == \"closed\" then\n" -" sock:close()\n" -" done = 1\n" -" return partial\n" -" else return nil, err end\n" -" end\n" -" })\n" -"end\n" -"\n" -"\n" -"sourcet[\"default\"] = sourcet[\"until-closed\"]\n" -"\n" -"_M.source = _M.choose(sourcet)\n" -"\n" -"return _M\n" -"\n"; - - - -int luaopen_lua_m_ltn12(lua_State *L) { - luaL_loadstring(L, lua_m_ltn12); - return 1; -} - - -int luaopen_lua_m_mime(lua_State *L) { - luaL_loadstring(L, lua_m_mime); - return 1; -} - - -int luaopen_lua_m_socket_ftp(lua_State *L) { - luaL_loadstring(L, lua_m_socket_ftp); - return 1; -} - - -int luaopen_lua_m_socket_headers(lua_State *L) { - luaL_loadstring(L, lua_m_socket_headers); - return 1; -} - - -int luaopen_lua_m_socket_http(lua_State *L) { - luaL_loadstring(L, lua_m_socket_http); - return 1; -} - - -int luaopen_lua_m_socket_mbox(lua_State *L) { - luaL_loadstring(L, lua_m_socket_mbox); - return 1; -} - - -int luaopen_lua_m_socket_smtp(lua_State *L) { - luaL_loadstring(L, lua_m_socket_smtp); - return 1; -} - - -int luaopen_lua_m_socket_tp(lua_State *L) { - luaL_loadstring(L, lua_m_socket_tp); - return 1; -} - - -int luaopen_lua_m_socket_url(lua_State *L) { - luaL_loadstring(L, lua_m_socket_url); - return 1; -} - - -int luaopen_lua_m_socket(lua_State *L) { - luaL_loadstring(L, lua_m_socket); - return 1; -} - - -static luaL_Reg luasocket_scripts_modules[] = { - {"ltn12", luaopen_lua_m_ltn12}, - {"mime", luaopen_lua_m_mime}, - {"socket.ftp", luaopen_lua_m_socket_ftp}, - {"socket.headers", luaopen_lua_m_socket_headers}, - {"socket.http", luaopen_lua_m_socket_http}, - {"socket.mbox", luaopen_lua_m_socket_mbox}, - {"socket.smtp", luaopen_lua_m_socket_smtp}, - {"socket.tp", luaopen_lua_m_socket_tp}, - {"socket.url", luaopen_lua_m_socket_url}, - {"socket", luaopen_lua_m_socket}, - {NULL, NULL} -}; - -void luaopen_luasocket_scripts(lua_State* L) -{ - luaL_Reg* lib = luasocket_scripts_modules; - lua_getglobal(L, "package"); - lua_getfield(L, -1, "preload"); - for (; lib->func; lib++) - { - lib->func(L); - lua_setfield(L, -2, lib->name); - } - lua_pop(L, 2); -} diff --git a/external/lua/luasocket/luasocket_scripts.h b/external/lua/luasocket/luasocket_scripts.h deleted file mode 100644 index 463d9f9792..0000000000 --- a/external/lua/luasocket/luasocket_scripts.h +++ /dev/null @@ -1,32 +0,0 @@ - -/* luasocket_scripts.h.h */ - -#ifndef __LUA_MODULES_7381EB5AEEAEA2DF0F25EF8827143F4A_H_ -#define __LUA_MODULES_7381EB5AEEAEA2DF0F25EF8827143F4A_H_ - -#if __cplusplus -extern "C" { -#endif - -#include "lua.h" - -void luaopen_luasocket_scripts(lua_State* L); - -/* -int luaopen_lua_m_ltn12(lua_State* L); -int luaopen_lua_m_mime(lua_State* L); -int luaopen_lua_m_socket_ftp(lua_State* L); -int luaopen_lua_m_socket_headers(lua_State* L); -int luaopen_lua_m_socket_http(lua_State* L); -int luaopen_lua_m_socket_mbox(lua_State* L); -int luaopen_lua_m_socket_smtp(lua_State* L); -int luaopen_lua_m_socket_tp(lua_State* L); -int luaopen_lua_m_socket_url(lua_State* L); -int luaopen_lua_m_socket(lua_State* L); -*/ - -#if __cplusplus -} -#endif - -#endif /* __LUA_MODULES_7381EB5AEEAEA2DF0F25EF8827143F4A_H_ */