mirror of
https://git.shadowkat.net/izaya/OC-PsychOS2.git
synced 2024-11-13 00:27:00 -05:00
added an FRequest client and server
This commit is contained in:
parent
8ca414e312
commit
dc03ad94bc
40
exec/fget.lua
Normal file
40
exec/fget.lua
Normal file
@ -0,0 +1,40 @@
|
||||
local minitel = require "minitel"
|
||||
|
||||
local tA = {...}
|
||||
|
||||
local function parseURL(url)
|
||||
local proto,addr = url:match("(.-)://(.+)")
|
||||
addr = addr or url
|
||||
local hp, path = addr:match("(.-)(/.*)")
|
||||
hp, path = hp or addr, path or "/"
|
||||
local host, port = hp:match("(.+):(.+)")
|
||||
host = host or hp
|
||||
return proto, host, port, path
|
||||
end
|
||||
|
||||
local proto, host, port, path = parseURL(tA[1])
|
||||
proto,port = proto or "fget", port or 70
|
||||
local fname, rtype = tA[2] or "-", tA[3] or "t"
|
||||
|
||||
local sock = minitel.open(host,port)
|
||||
local f = nil
|
||||
if fname ~= "-" then
|
||||
f = io.open(fname,"w")
|
||||
if not f then error("couldn't open file for writing") end
|
||||
else
|
||||
f = io.open(os.getenv("t"))
|
||||
f.close = function() end
|
||||
end
|
||||
if not sock then error("couldn't open connection to host") end
|
||||
sock:write(string.format("%s%s\n",rtype,path))
|
||||
local rtype, buf = "", ""
|
||||
repeat
|
||||
coroutine.yield()
|
||||
rtype = sock:read(1)
|
||||
until rtype ~= ""
|
||||
repeat
|
||||
coroutine.yield()
|
||||
buf = sock:read("*a")
|
||||
f:write(buf)
|
||||
until sock.state == "closed" and buf == ""
|
||||
f:close()
|
78
service/fserv.lua
Normal file
78
service/fserv.lua
Normal file
@ -0,0 +1,78 @@
|
||||
local minitel = require "minitel"
|
||||
local serial = require "serialization"
|
||||
|
||||
local cfg = {["path"]="/boot/srv/frequest",["port"]=70}
|
||||
|
||||
f=io.open("/boot/cfg/fserv.cfg","rb")
|
||||
if f then
|
||||
local ncfg = serial.unserialize(f:read("*a"))
|
||||
f:close()
|
||||
for k,v in pairs(ncfg) do
|
||||
cfg[k] = v
|
||||
end
|
||||
end
|
||||
|
||||
local function fileHandler(socket,rtype,path)
|
||||
syslog(string.format("[%s:%d] %s %s",socket.addr,socket.port,rtype,path),syslog.info,"fserv")
|
||||
if rtype == "t" then
|
||||
if fs.exists(path) and fs.isDirectory(path) then
|
||||
socket:write("d")
|
||||
for _,file in ipairs(fs.list(path)) do
|
||||
socket:write(file.."\n")
|
||||
end
|
||||
elseif fs.exists(path) and not fs.isDirectory(path) then
|
||||
local f,err = io.open(path,"rb")
|
||||
if f then
|
||||
socket:write("y")
|
||||
while true do
|
||||
local c = f:read(4096)
|
||||
if not c or c == "" then break end
|
||||
socket:write(c)
|
||||
end
|
||||
else
|
||||
socket:write("fFailed to open file: "..err)
|
||||
end
|
||||
else
|
||||
socket:write("nFile not found")
|
||||
end
|
||||
elseif rtype == "s" then
|
||||
if fs.exists(path) then
|
||||
local ftype = "f"
|
||||
if fs.isDirectory(path) then
|
||||
ftype = "d"
|
||||
end
|
||||
socket:write(string.format("y%s\n%d",ftype,fs.size(path)))
|
||||
else
|
||||
socket:write("nFile not found.")
|
||||
end
|
||||
else
|
||||
socket:write("fUnknown request type")
|
||||
end
|
||||
socket:close()
|
||||
end
|
||||
local function httpHandler(socket,rtype,path)
|
||||
socket:write("fHTTP requests are not yet implemented.")
|
||||
socket:close()
|
||||
end
|
||||
|
||||
local function socketHandler(socket)
|
||||
return function()
|
||||
local line = nil
|
||||
repeat
|
||||
coroutine.yield()
|
||||
line = socket:read()
|
||||
until line
|
||||
local rtype, path = line:match("(.)(.+)")
|
||||
if path:sub(1,6) == "/http/" or path:sub(1,5) == "http/" then
|
||||
httpHandler(socket,rtype,path)
|
||||
else
|
||||
path = (cfg.path .. "/" .. path:gsub("../","")):gsub("/+","/")
|
||||
fileHandler(socket,rtype,path)
|
||||
end
|
||||
socket:close()
|
||||
end
|
||||
end
|
||||
|
||||
while true do
|
||||
os.spawn(socketHandler(minitel.listen(70)))
|
||||
end
|
Loading…
Reference in New Issue
Block a user