diff options
Diffstat (limited to 'ThirdParty/tolua_runtime/luasocket/luasocket_scripts.c')
| -rw-r--r-- | ThirdParty/tolua_runtime/luasocket/luasocket_scripts.c | 2195 |
1 files changed, 2195 insertions, 0 deletions
diff --git a/ThirdParty/tolua_runtime/luasocket/luasocket_scripts.c b/ThirdParty/tolua_runtime/luasocket/luasocket_scripts.c new file mode 100644 index 0000000..f5aabb7 --- /dev/null +++ b/ThirdParty/tolua_runtime/luasocket/luasocket_scripts.c @@ -0,0 +1,2195 @@ + +/* 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" +"-- <url> ::= <scheme>://<authority>/<path>;<params>?<query>#<fragment>\n" +"-- <authority> ::= <userinfo>@<host>:<port>\n" +"-- <userinfo> ::= <user>[:<password>]\n" +"-- <path> :: = {<segment>/}<segment>\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 {/<path>} is considered part of <path>\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); +} |