local helpers = require('test.functional.helpers')(after_each) local eq, clear, eval, command, nvim, next_message = helpers.eq, helpers.clear, helpers.eval, helpers.command, 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()) command('au FileType lua call rpcnotify('..channel..', "lua!")') command('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)