yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(event): add `connected_at` into client_disconnected event 

port from v4.3: https://github.com/emqx/emqx/pull/6822
This commit is contained in:
JianBo He 2022-02-11 11:01:59 +08:00
parent 97e22cc6a8
commit 94609e31e4
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/emqx_modules/src/emqx_event_message.erl
View File

@ -109,8 +109,7 @@ on_client_connected(ClientInfo, ConnInfo) ->
Payload = Payload0#{ Payload = Payload0#{
keepalive => maps:get(keepalive, ConnInfo, 0), keepalive => maps:get(keepalive, ConnInfo, 0),
clean_start => maps:get(clean_start, ConnInfo, true), clean_start => maps:get(clean_start, ConnInfo, true),
expiry_interval => maps:get(expiry_interval, ConnInfo, 0), expiry_interval => maps:get(expiry_interval, ConnInfo, 0)
connected_at => maps:get(connected_at, ConnInfo)
}, },
publish_event_msg(<<"$event/client_connected">>, Payload). publish_event_msg(<<"$event/client_connected">>, Payload).
@ -210,14 +209,17 @@ common_infos(
sockport := SockPort sockport := SockPort
}, },
_ConnInfo = #{proto_name := ProtoName, _ConnInfo = #{proto_name := ProtoName,
proto_ver := ProtoVer proto_ver := ProtoVer,
connected_at := ConnectedAt
}) -> }) ->
#{clientid => ClientId, #{clientid => ClientId,
username => Username, username => Username,
ipaddress => ntoa(PeerHost), ipaddress => ntoa(PeerHost),
sockport => SockPort, sockport => SockPort,
proto_name => ProtoName, proto_name => ProtoName,
proto_ver => ProtoVer proto_ver => ProtoVer,
connected_at => ConnectedAt,
ts => erlang:system_time(millisecond)
}. }.
make_msg(Topic, Payload) -> make_msg(Topic, Payload) ->