From 112705729167e14878aba614631cde3d98f59ddb Mon Sep 17 00:00:00 2001
From: k32 <10274441+k32@users.noreply.github.com>
Date: Fri, 28 Jan 2022 13:39:27 +0100
Subject: [PATCH] fix(emqx_mgmt): Fix network graph

---
 apps/emqx_management/src/emqx_mgmt.erl           | 7 ++++---
 apps/emqx_management/src/emqx_mgmt_api_nodes.erl | 3 ++-
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/apps/emqx_management/src/emqx_mgmt.erl b/apps/emqx_management/src/emqx_mgmt.erl
index 20701b937..16728bc36 100644
--- a/apps/emqx_management/src/emqx_mgmt.erl
+++ b/apps/emqx_management/src/emqx_mgmt.erl
@@ -134,8 +134,8 @@ return(_Response) ->
 %%--------------------------------------------------------------------
 
 list_nodes() ->
-    Running = mnesia:system_info(running_db_nodes),
-    Stopped = mnesia:system_info(db_nodes) -- Running,
+    Running = mria_mnesia:cluster_nodes(running),
+    Stopped = mria_mnesia:cluster_nodes(stopped),
     DownNodes = lists:map(fun stopped_node_info/1, Stopped),
     [{Node, node_info(Node)} || Node <- Running] ++ DownNodes.
 
@@ -157,7 +157,8 @@ node_info() ->
           connections       => ets:info(emqx_channel, size),
           node_status       => 'Running',
           uptime            => proplists:get_value(uptime, BrokerInfo),
-          version           => iolist_to_binary(proplists:get_value(version, BrokerInfo))
+          version           => iolist_to_binary(proplists:get_value(version, BrokerInfo)),
+          role              => mria_rlog:role()
          }.
 
 node_info(Node) ->
diff --git a/apps/emqx_management/src/emqx_mgmt_api_nodes.erl b/apps/emqx_management/src/emqx_mgmt_api_nodes.erl
index 765150525..6d39e427e 100644
--- a/apps/emqx_management/src/emqx_mgmt_api_nodes.erl
+++ b/apps/emqx_management/src/emqx_mgmt_api_nodes.erl
@@ -60,7 +60,8 @@ properties() ->
         {version, string, <<"EMQ X Broker version">>},
         {sys_path, string, <<"EMQ X system file location">>},
         {log_path, string, <<"EMQ X log file location">>},
-        {config_path, string, <<"EMQ X config file location">>}
+        {config_path, string, <<"EMQ X config file location">>},
+        {role, string, <<"Node role">>}
     ]).
 
 parameters() ->