fix: don't crash on broker_info()

This commit is contained in:
Stefan Strigler 2023-02-15 15:54:05 +01:00
parent f9895a33b6
commit 777ca72ad5
1 changed files with 7 additions and 1 deletions

View File

@ -190,9 +190,15 @@ lookup_broker(Node) ->
Broker. Broker.
broker_info() -> broker_info() ->
Info = maps:from_list([{K, iolist_to_binary(V)} || {K, V} <- emqx_sys:info()]), Info = lists:foldl(fun convert_broker_info/2, #{}, emqx_sys:info()),
Info#{node => node(), otp_release => otp_rel(), node_status => 'Running'}. Info#{node => node(), otp_release => otp_rel(), node_status => 'Running'}.
convert_broker_info({uptime, Uptime}, M) ->
M#{uptime => emqx_datetime:human_readable_duration_string(Uptime)};
convert_broker_info({K, V}, M) ->
M#{K => iolist_to_binary(V)}.
broker_info(Nodes) -> broker_info(Nodes) ->
emqx_rpc:unwrap_erpc(emqx_management_proto_v3:broker_info(Nodes)). emqx_rpc:unwrap_erpc(emqx_management_proto_v3:broker_info(Nodes)).