Skip to content
Snippets Groups Projects
Commit 05cdeb59 authored by Chris Sosnin's avatar Chris Sosnin Committed by Nikita Pettik
Browse files

test: introduce iproto_request helper function


It is needed for performing iproto tests in Lua.

Needed for #4769

Reviewed-by: default avatarVladislav Shpilevoy <v.shpilevoy@tarantool.org>
Reviewed-by: default avatarNikita Pettik <korablev@tarantool.org>
parent 7ec7ced6
No related branches found
No related tags found
No related merge requests found
#!/usr/bin/env tarantool
os = require('os')
local msgpack = require('msgpack')
box.cfg{
listen = os.getenv("LISTEN"),
memtx_memory = 107374182,
......@@ -38,4 +40,22 @@ function sorted(data)
return data
end
_G.protected_globals = {'cfg_filter', 'sorted'}
function iproto_request(socket, query_header, query_body)
local header = msgpack.encode(query_header)
local body = msgpack.encode(query_body)
local size = msgpack.encode(header:len() + body:len())
assert(socket:write(size .. header .. body) ~= nil,
'Failed to send request')
size = socket:read(5)
assert(size ~= nil, 'Failed to read response')
size = msgpack.decode(size)
local response = socket:read(size)
local header, header_len = msgpack.decode(response)
body = msgpack.decode(response:sub(header_len))
return {
['header'] = header,
['body'] = body,
}
end
_G.protected_globals = {'cfg_filter', 'sorted', 'iproto_request'}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment