diff --git a/apps/emqx_rule_engine/src/emqx_rule_events.erl b/apps/emqx_rule_engine/src/emqx_rule_events.erl index 26c4656d4..3b242089f 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_events.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_events.erl @@ -455,7 +455,8 @@ eventmsg_check_authn_complete( _ClientInfo = #{ clientid := ClientId, username := Username, - peerhost := PeerHost + peerhost := PeerHost, + peerport := PeerPort }, #{is_anonymous := IsAnonymous} = Result ) -> @@ -465,7 +466,7 @@ eventmsg_check_authn_complete( #{ clientid => ClientId, username => Username, - peerhost => ntoa(PeerHost), + peername => ntoa({PeerHost, PeerPort}), is_anonymous => IsAnonymous, is_superuser => IsSuperuser }, @@ -1077,7 +1078,7 @@ columns_with_exam('client.check_authn_complete') -> {<<"event">>, 'client.check_authz_complete'}, {<<"clientid">>, <<"c_emqx">>}, {<<"username">>, <<"u_emqx">>}, - {<<"peerhost">>, <<"192.168.0.10">>}, + {<<"peername">>, <<"192.168.0.10:56431">>}, {<<"is_superuser">>, true}, {<<"is_anonymous">>, false}, {<<"timestamp">>, erlang:system_time(millisecond)}, diff --git a/changes/ce/feat-12983.en.md b/changes/ce/feat-12983.en.md new file mode 100644 index 000000000..b531bfa89 --- /dev/null +++ b/changes/ce/feat-12983.en.md @@ -0,0 +1 @@ +Add new rule engine event `$events/client_check_authn_complete` for authentication completion event.