mirror of
				https://github.com/neovim/neovim.git
				synced 2025-10-26 12:27:24 +00:00 
			
		
		
		
	 65fb622000
			
		
	
	65fb622000
	
	
	
		
			
			Hope this will make people using feed_command less likely: this hides bugs. Already found at least two: 1. msgpackparse() will show internal error: hash_add() in case of duplicate keys, though it will still work correctly. Currently silenced. 2. ttimeoutlen was spelled incorrectly, resulting in option not being set when expected. Test was still functioning somehow though. Currently fixed.
		
			
				
	
	
		
			69 lines
		
	
	
		
			2.3 KiB
		
	
	
	
		
			Lua
		
	
	
	
	
	
			
		
		
	
	
			69 lines
		
	
	
		
			2.3 KiB
		
	
	
	
		
			Lua
		
	
	
	
	
	
| 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)
 |