diff options
Diffstat (limited to 'Build/source/texk/web2c/luatexdir/luasocket/src/ftp.lua')
-rw-r--r-- | Build/source/texk/web2c/luatexdir/luasocket/src/ftp.lua | 268 |
1 files changed, 0 insertions, 268 deletions
diff --git a/Build/source/texk/web2c/luatexdir/luasocket/src/ftp.lua b/Build/source/texk/web2c/luatexdir/luasocket/src/ftp.lua deleted file mode 100644 index 905dd989def..00000000000 --- a/Build/source/texk/web2c/luatexdir/luasocket/src/ftp.lua +++ /dev/null @@ -1,268 +0,0 @@ -local base = _G -local table = require("table") -local string = require("string") -local math = require("math") -local socket = socket or require("socket") -local url = socket.url or require("socket.url") -local tp = socket.tp or require("socket.tp") -local ltn12 = ltn12 or require("ltn12") -socket.ftp = {} -local _M = socket.ftp -module("socket.ftp") -_M.TIMEOUT = 60 -local PORT = 21 -_M.USER = "ftp" -_M.PASSWORD = "anonymous@anonymous.org" -local metat = { __index = {} } -function _M.open(server, port, create) - local tp = socket.try(tp.connect(server, port or PORT, _M.TIMEOUT, create)) - local f = base.setmetatable({ tp = tp }, metat) - -- make sure everything gets closed in an exception - f.try = socket.newtry(function() f:close() end) - return f -end -function metat.__index:portconnect() - self.try(self.server:settimeout(_M.TIMEOUT)) - self.data = self.try(self.server:accept()) - self.try(self.data:settimeout(_M.TIMEOUT)) -end -function metat.__index:pasvconnect() - self.data = self.try(socket.tcp()) - self.try(self.data:settimeout(_M.TIMEOUT)) - self.try(self.data:connect(self.pasvt.address, self.pasvt.port)) -end -function metat.__index:login(user, password) - self.try(self.tp:command("user", user or _M.USER)) - local code, reply = self.try(self.tp:check{"2..", 331}) - if code == 331 then - self.try(self.tp:command("pass", password or _M.PASSWORD)) - self.try(self.tp:check("2..")) - end - return 1 -end -function metat.__index:pasv() - self.try(self.tp:command("pasv")) - local code, reply = self.try(self.tp:check("2..")) - local pattern = "(%d+)%D(%d+)%D(%d+)%D(%d+)%D(%d+)%D(%d+)" - local a, b, c, d, p1, p2 = socket.skip(2, string.find(reply, pattern)) - self.try(a and b and c and d and p1 and p2, reply) - self.pasvt = { - address = string.format("%d.%d.%d.%d", a, b, c, d), - port = p1*256 + p2 - } - if self.server then - self.server:close() - self.server = nil - end - return self.pasvt.address, self.pasvt.port -end -function metat.__index:epsv() - self.try(self.tp:command("epsv")) - local code, reply = self.try(self.tp:check("229")) - local pattern = "%((.)(.-)%1(.-)%1(.-)%1%)" - local d, prt, address, port = string.match(reply, pattern) - self.try(port, "invalid epsv response") - self.pasvt = { - address = self.tp:getpeername(), - port = port - } - if self.server then - self.server:close() - self.server = nil - end - return self.pasvt.address, self.pasvt.port -end -function metat.__index:port(address, port) - self.pasvt = nil - if not address then - address, port = self.try(self.tp:getsockname()) - self.server = self.try(socket.bind(address, 0)) - address, port = self.try(self.server:getsockname()) - self.try(self.server:settimeout(_M.TIMEOUT)) - end - local pl = math.mod(port, 256) - local ph = (port - pl)/256 - local arg = string.gsub(string.format("%s,%d,%d", address, ph, pl), "%.", ",") - self.try(self.tp:command("port", arg)) - self.try(self.tp:check("2..")) - return 1 -end -function metat.__index:eprt(family, address, port) - self.pasvt = nil - if not address then - address, port = self.try(self.tp:getsockname()) - self.server = self.try(socket.bind(address, 0)) - address, port = self.try(self.server:getsockname()) - self.try(self.server:settimeout(_M.TIMEOUT)) - end - local arg = string.format("|%s|%s|%d|", family, address, port) - self.try(self.tp:command("eprt", arg)) - self.try(self.tp:check("2..")) - return 1 -end -function metat.__index:send(sendt) - self.try(self.pasvt or self.server, "need port or pasv first") - if self.pasvt then self:pasvconnect() end - local argument = sendt.argument or - url.unescape(string.gsub(sendt.path or "", "^[/\\]", "")) - if argument == "" then argument = nil end - local command = sendt.command or "stor" - self.try(self.tp:command(command, argument)) - local code, reply = self.try(self.tp:check{"2..", "1.."}) - if not self.pasvt then self:portconnect() end - local step = sendt.step or ltn12.pump.step - local readt = { self.tp } - local checkstep = function(src, snk) - local readyt = socket.select(readt, nil, 0) - if readyt[tp] then code = self.try(self.tp:check("2..")) end - return step(src, snk) - end - local sink = socket.sink("close-when-done", self.data) - self.try(ltn12.pump.all(sendt.source, sink, checkstep)) - if string.find(code, "1..") then self.try(self.tp:check("2..")) end - self.data:close() - local sent = socket.skip(1, self.data:getstats()) - self.data = nil - return sent -end -function metat.__index:receive(recvt) - self.try(self.pasvt or self.server, "need port or pasv first") - if self.pasvt then self:pasvconnect() end - local argument = recvt.argument or - url.unescape(string.gsub(recvt.path or "", "^[/\\]", "")) - if argument == "" then argument = nil end - local command = recvt.command or "retr" - self.try(self.tp:command(command, argument)) - local code,reply = self.try(self.tp:check{"1..", "2.."}) - if (code >= 200) and (code <= 299) then - recvt.sink(reply) - return 1 - end - if not self.pasvt then self:portconnect() end - local source = socket.source("until-closed", self.data) - local step = recvt.step or ltn12.pump.step - self.try(ltn12.pump.all(source, recvt.sink, step)) - if string.find(code, "1..") then self.try(self.tp:check("2..")) end - self.data:close() - self.data = nil - return 1 -end -function metat.__index:cwd(dir) - self.try(self.tp:command("cwd", dir)) - self.try(self.tp:check(250)) - return 1 -end -function metat.__index:type(type) - self.try(self.tp:command("type", type)) - self.try(self.tp:check(200)) - return 1 -end -function metat.__index:greet() - local code = self.try(self.tp:check{"1..", "2.."}) - if string.find(code, "1..") then self.try(self.tp:check("2..")) end - return 1 -end -function metat.__index:quit() - self.try(self.tp:command("quit")) - self.try(self.tp:check("2..")) - return 1 -end -function metat.__index:close() - if self.data then self.data:close() end - if self.server then self.server:close() end - return self.tp:close() -end -local function override(t) - if t.url then - local u = url.parse(t.url) - for i,v in base.pairs(t) do - u[i] = v - end - return u - else return t end -end -local function tput(putt) - putt = override(putt) - socket.try(putt.host, "missing hostname") - local f = _M.open(putt.host, putt.port, putt.create) - f:greet() - f:login(putt.user, putt.password) - if putt.type then f:type(putt.type) end - f:epsv() - local sent = f:send(putt) - f:quit() - f:close() - return sent -end -local default = { - path = "/", - scheme = "ftp" -} -local function genericform(u) - local t = socket.try(url.parse(u, default)) - socket.try(t.scheme == "ftp", "wrong scheme '" .. t.scheme .. "'") - socket.try(t.host, "missing hostname") - local pat = "^type=(.)$" - if t.params then - t.type = socket.skip(2, string.find(t.params, pat)) - socket.try(t.type == "a" or t.type == "i", - "invalid type '" .. t.type .. "'") - end - return t -end -_M.genericform = genericform -local function sput(u, body) - local putt = genericform(u) - putt.source = ltn12.source.string(body) - return tput(putt) -end -_M.put = socket.protect(function(putt, body) - if base.type(putt) == "string" then return sput(putt, body) - else return tput(putt) end -end) -local function tget(gett) - gett = override(gett) - socket.try(gett.host, "missing hostname") - local f = _M.open(gett.host, gett.port, gett.create) - f:greet() - f:login(gett.user, gett.password) - if gett.type then f:type(gett.type) end - f:epsv() - f:receive(gett) - f:quit() - return f:close() -end -local function sget(u) - local gett = genericform(u) - local t = {} - gett.sink = ltn12.sink.table(t) - tget(gett) - return table.concat(t) -end -_M.command = socket.protect(function(cmdt) - cmdt = override(cmdt) - socket.try(cmdt.host, "missing hostname") - socket.try(cmdt.command, "missing command") - local f = _M.open(cmdt.host, cmdt.port, cmdt.create) - f:greet() - f:login(cmdt.user, cmdt.password) - if type(cmdt.command) == "table" then - local argument = cmdt.argument or {} - local check = cmdt.check or {} - for i,cmd in ipairs(cmdt.command) do - f.try(f.tp:command(cmd, argument[i])) - if check[i] then f.try(f.tp:check(check[i])) end - end - else - f.try(f.tp:command(cmdt.command, cmdt.argument)) - if cmdt.check then f.try(f.tp:check(cmdt.check)) end - end - f:quit() - return f:close() -end) -_M.get = socket.protect(function(gett) - if base.type(gett) == "string" then return sget(gett) - else return tget(gett) end -end) -socket.ftp = _M -return _M |