mirror of
https://github.com/neovim/neovim.git
synced 2024-12-22 20:25:16 -07:00
0d56118d86
It appears that used msgpack library is not able to parse back message created
by msgpack_rpc_from_object() if nesting level is too high, so log_server_msg now
cares about msgpack_unpack_next() return value. Also error message from
server_notifications_spec.lua is not readable if something is wrong (though at
least now it does not crash when parsing deeply nested structures).
log_server_msg() in the test reports
[msgpack-rpc] nvim -> client(1) [error] "parse error"
70 lines
2.3 KiB
Lua
70 lines
2.3 KiB
Lua
-- Tests for nvim notifications
|
|
local helpers = require('test.functional.helpers')(after_each)
|
|
local eq, clear, eval, execute, nvim, next_message =
|
|
helpers.eq, helpers.clear, helpers.eval, helpers.execute, helpers.nvim,
|
|
helpers.next_message
|
|
local meths = helpers.meths
|
|
|
|
describe('notify', function()
|
|
local channel
|
|
|
|
before_each(function()
|
|
clear()
|
|
channel = nvim('get_api_info')[1]
|
|
end)
|
|
|
|
describe('passing a valid channel id', function()
|
|
it('sends the notification/args to the corresponding channel', function()
|
|
eval('rpcnotify('..channel..', "test-event", 1, 2, 3)')
|
|
eq({'notification', 'test-event', {1, 2, 3}}, next_message())
|
|
execute('au FileType lua call rpcnotify('..channel..', "lua!")')
|
|
execute('set filetype=lua')
|
|
eq({'notification', 'lua!', {}}, next_message())
|
|
end)
|
|
end)
|
|
|
|
describe('passing 0 as the channel id', function()
|
|
it('sends the notification/args to all subscribed channels', function()
|
|
nvim('subscribe', 'event2')
|
|
eval('rpcnotify(0, "event1", 1, 2, 3)')
|
|
eval('rpcnotify(0, "event2", 4, 5, 6)')
|
|
eval('rpcnotify(0, "event2", 7, 8, 9)')
|
|
eq({'notification', 'event2', {4, 5, 6}}, next_message())
|
|
eq({'notification', 'event2', {7, 8, 9}}, next_message())
|
|
nvim('unsubscribe', 'event2')
|
|
nvim('subscribe', 'event1')
|
|
eval('rpcnotify(0, "event2", 10, 11, 12)')
|
|
eval('rpcnotify(0, "event1", 13, 14, 15)')
|
|
eq({'notification', 'event1', {13, 14, 15}}, next_message())
|
|
end)
|
|
|
|
it('does not crash for deeply nested variable', function()
|
|
meths.set_var('l', {})
|
|
local nest_level = 1000
|
|
meths.command(('call map(range(%u), "extend(g:, {\'l\': [g:l]})")'):format(nest_level - 1))
|
|
eval('rpcnotify('..channel..', "event", g:l)')
|
|
local msg = next_message()
|
|
eq('notification', msg[1])
|
|
eq('event', msg[2])
|
|
local act_ret = msg[3]
|
|
local act_nest_level = 0
|
|
while act_ret do
|
|
if type(act_ret) == 'table' then
|
|
local cur_act_ret = nil
|
|
for k, v in pairs(act_ret) do
|
|
eq(1, k)
|
|
cur_act_ret = v
|
|
end
|
|
if cur_act_ret then
|
|
act_nest_level = act_nest_level + 1
|
|
end
|
|
act_ret = cur_act_ret
|
|
else
|
|
eq(nil, act_ret)
|
|
end
|
|
end
|
|
eq(nest_level, act_nest_level)
|
|
end)
|
|
end)
|
|
end)
|