From 94609e31e4886956b40a63c15621138444e89f35 Mon Sep 17 00:00:00 2001 From: JianBo He Date: Fri, 11 Feb 2022 11:01:59 +0800 Subject: [PATCH] feat(event): add `connected_at` into client_disconnected event port from v4.3: https://github.com/emqx/emqx/pull/6822 --- apps/emqx_modules/src/emqx_event_message.erl | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/apps/emqx_modules/src/emqx_event_message.erl b/apps/emqx_modules/src/emqx_event_message.erl index feda5d3e1..e02a5e676 100644 --- a/apps/emqx_modules/src/emqx_event_message.erl +++ b/apps/emqx_modules/src/emqx_event_message.erl @@ -109,8 +109,7 @@ on_client_connected(ClientInfo, ConnInfo) -> Payload = Payload0#{ keepalive => maps:get(keepalive, ConnInfo, 0), clean_start => maps:get(clean_start, ConnInfo, true), - expiry_interval => maps:get(expiry_interval, ConnInfo, 0), - connected_at => maps:get(connected_at, ConnInfo) + expiry_interval => maps:get(expiry_interval, ConnInfo, 0) }, publish_event_msg(<<"$event/client_connected">>, Payload). @@ -210,14 +209,17 @@ common_infos( sockport := SockPort }, _ConnInfo = #{proto_name := ProtoName, - proto_ver := ProtoVer + proto_ver := ProtoVer, + connected_at := ConnectedAt }) -> #{clientid => ClientId, username => Username, ipaddress => ntoa(PeerHost), sockport => SockPort, proto_name => ProtoName, - proto_ver => ProtoVer + proto_ver => ProtoVer, + connected_at => ConnectedAt, + ts => erlang:system_time(millisecond) }. make_msg(Topic, Payload) ->