mirror of
				https://github.com/neovim/neovim.git
				synced 2025-10-26 12:27:24 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			69 lines
		
	
	
		
			2.3 KiB
		
	
	
	
		
			Lua
		
	
	
	
	
	
			
		
		
	
	
			69 lines
		
	
	
		
			2.3 KiB
		
	
	
	
		
			Lua
		
	
	
	
	
	
| 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)
 | 
