You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
77 lines
2.6 KiB
Lua
77 lines
2.6 KiB
Lua
1 year ago
|
-- Copyright 2003-2010 Kepler Project
|
||
|
|
-- Copyright 2014-2018 Sandor Balazsi <sandor.balazsi@gmail.com>
|
||
|
|
-- XML-RPC over SCGI.
|
||
|
|
|
||
|
|
local error, tonumber, tostring, unpack = error, tonumber, tostring, unpack
|
||
|
|
|
||
|
|
local socket= require"socket"
|
||
|
|
local string= require"string"
|
||
|
|
local xmlrpc= require"xmlrpc"
|
||
|
|
|
||
|
|
module("xmlrpc.scgi")
|
||
|
|
|
||
|
|
---------------------------------------------------------------------
|
||
|
|
-- Call a remote method.
|
||
|
|
-- @param addr String with the address of the SCGI server.
|
||
|
|
-- @param port The port of the SCGI server.
|
||
|
|
-- @param method String with the name of the method to be called.
|
||
|
|
-- @return Table with the response(could be a `fault' or a `params'
|
||
|
|
-- XML-RPC element).
|
||
|
|
---------------------------------------------------------------------
|
||
|
|
function call(addr, port, method, ...)
|
||
|
|
local request_body = xmlrpc.clEncode(method, ...)
|
||
|
|
local sock = socket.connect(addr, port)
|
||
|
|
if sock == nil then
|
||
|
|
return false, "socket connect failed"
|
||
|
|
end
|
||
|
|
sock:send(netstring(request_body))
|
||
|
|
local err, code, headers, body = receive(sock)
|
||
|
|
|
||
|
|
if tonumber(code) == 200 then
|
||
|
|
return xmlrpc.clDecode(body)
|
||
|
|
else
|
||
|
|
error(tostring(err or code))
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
---------------------------------------------------------------------
|
||
|
|
-- Encode message as netstring
|
||
|
|
-- @param request_body String with the message
|
||
|
|
-- @return String with the encoded message
|
||
|
|
---------------------------------------------------------------------
|
||
|
|
function netstring(request_body)
|
||
|
|
local null = "\0"
|
||
|
|
local content_length = "CONTENT_LENGTH" .. null .. string.len(request_body) .. null
|
||
|
|
local scgi_enable = "SCGI" .. null .. "1" .. null
|
||
|
|
local request_method = "REQUEST_METHOD" .. null .. "POST" .. null
|
||
|
|
local server_protocol = "SERVER_PROTOCOL" .. null .. "HTTP/1.1" .. null
|
||
|
|
local header = content_length .. scgi_enable .. request_method .. server_protocol
|
||
|
|
return string.len(header) .. ":" .. header .. "," .. request_body
|
||
|
|
end
|
||
|
|
|
||
|
|
---------------------------------------------------------------------
|
||
|
|
-- Receive and parse socket response
|
||
|
|
-- @param sock Socket instance
|
||
|
|
-- @return Headers, body and error codes
|
||
|
|
---------------------------------------------------------------------
|
||
|
|
function receive(sock)
|
||
|
|
local line, body, err
|
||
|
|
local headers = {}
|
||
|
|
|
||
|
|
line, err = sock:receive()
|
||
|
|
if err then return err, "500" end
|
||
|
|
while line ~= "" do
|
||
|
|
local name, value = socket.skip(2, string.find(line, "^(.-):%s*(.*)"))
|
||
|
|
if not(name and value) then return "malformed reponse header: " .. line, "500" end
|
||
|
|
headers[string.lower(name)] = value
|
||
|
|
|
||
|
|
line, err = sock:receive()
|
||
|
|
if err then return err, "500" end
|
||
|
|
end
|
||
|
|
|
||
|
|
body = sock:receive(headers["content-length"])
|
||
|
|
local code = socket.skip(2, string.find(headers["status"], "^(%d%d%d)"))
|
||
|
|
return err, code, headers, body
|
||
|
|
end
|
||
|
|
|