45 lines
1.2 KiB
Erlang
45 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_common_test_helpers: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.
|