65 lines
1.5 KiB
Lua
65 lines
1.5 KiB
Lua
local json = require 'json'
|
|
local inspect = require 'inspect'
|
|
local pcall = pcall
|
|
local tonumber = tonumber
|
|
|
|
---@class jsonrpc
|
|
local m = {}
|
|
m.type = 'jsonrpc'
|
|
|
|
function m.encode(pack)
|
|
pack.jsonrpc = '2.0'
|
|
local content = json.encode(pack)
|
|
local buf = ('Content-Length: %d\r\n\r\n%s'):format(#content, content)
|
|
return buf
|
|
end
|
|
|
|
local function readProtoHead(reader)
|
|
local head = {}
|
|
while true do
|
|
local line = reader 'L'
|
|
if line == nil then
|
|
-- 说明管道已经关闭了
|
|
return nil, 'Disconnected!'
|
|
end
|
|
if line == '\r\n' then
|
|
break
|
|
end
|
|
local k, v = line:match '^([^:]+)%s*%:%s*(.+)\r\n$'
|
|
if not k then
|
|
return nil, 'Proto header error: ' .. line
|
|
end
|
|
if k == 'Content-Length' then
|
|
v = tonumber(v)
|
|
end
|
|
head[k] = v
|
|
end
|
|
return head
|
|
end
|
|
|
|
function m.decode(reader)
|
|
local head, err = readProtoHead(reader)
|
|
if not head then
|
|
return nil, err
|
|
end
|
|
local len = head['Content-Length']
|
|
if not len then
|
|
return nil, 'Proto header error: ' .. inspect(head)
|
|
end
|
|
local content = reader(len)
|
|
if not content then
|
|
return nil, 'Proto read error'
|
|
end
|
|
---@type any
|
|
local null = json.null
|
|
json.null = nil
|
|
local suc, res = pcall(json.decode, content)
|
|
json.null = null
|
|
if not suc then
|
|
return nil, 'Proto parse error: ' .. res
|
|
end
|
|
return res
|
|
end
|
|
|
|
return m
|