38 lines
1.2 KiB
Erlang
38 lines
1.2 KiB
Erlang
-module(emqx_rule_events_SUITE).
|
|
|
|
-compile(export_all).
|
|
-compile(nowarn_export_all).
|
|
|
|
-include_lib("eunit/include/eunit.hrl").
|
|
|
|
all() -> emqx_ct:all(?MODULE).
|
|
|
|
t_mod_hook_fun(_) ->
|
|
Funcs = emqx_rule_events:module_info(exports),
|
|
[?assert(lists:keymember(emqx_rule_events:hook_fun(Event), 1, Funcs)) ||
|
|
Event <- ['client.connected',
|
|
'client.disconnected',
|
|
'session.subscribed',
|
|
'session.unsubscribed',
|
|
'message.acked',
|
|
'message.dropped',
|
|
'message.delivered'
|
|
]].
|
|
|
|
t_printable_maps(_) ->
|
|
Headers = #{peerhost => {127,0,0,1},
|
|
peername => {{127,0,0,1}, 9980},
|
|
sockname => {{127,0,0,1}, 1883},
|
|
redispatch_to => {<<"group">>, <<"sub/topic/+">>},
|
|
shared_dispatch_ack => {self(), ref}
|
|
},
|
|
Converted = emqx_rule_events:printable_maps(Headers),
|
|
?assertMatch(
|
|
#{peerhost := <<"127.0.0.1">>,
|
|
peername := <<"127.0.0.1:9980">>,
|
|
sockname := <<"127.0.0.1:1883">>
|
|
}, Converted),
|
|
?assertNot(maps:is_key(redispatch_to, Converted)),
|
|
?assertNot(maps:is_key(shared_dispatch_ack, Converted)),
|
|
ok.
|