Merge pull request #7927 from zhongwencool/delete-unuse-plugin-record

fix: telemetry can't get active plugins list

apps/emqx/include/emqx.hrl

@@ -102,19 +102,6 @@
     dest :: node() | {binary(), node()} | emqx_session:sessionID()
 }).
 
-%%--------------------------------------------------------------------
-%% Plugin
-%%--------------------------------------------------------------------
-
--record(plugin, {
-    name :: atom(),
-    dir :: string() | undefined,
-    descr :: string(),
-    vendor :: string() | undefined,
-    active = false :: boolean(),
-    info = #{} :: map()
-}).
-
 %%--------------------------------------------------------------------
 %% Command
 %%--------------------------------------------------------------------

apps/emqx/src/emqx_types.erl

@@ -88,7 +88,6 @@
 ]).
 
 -export_type([
-    plugin/0,
     banned/0,
     command/0
 ]).
@@ -231,7 +230,6 @@
 -type route() :: #route{}.
 -type group() :: emqx_topic:group().
 -type route_entry() :: {topic(), node()} | {topic, group()}.
--type plugin() :: #plugin{}.
 -type command() :: #command{}.
 
 -type caps() :: emqx_mqtt_caps:caps().

apps/emqx_management/src/emqx_mgmt_cli.erl

@@ -759,11 +759,6 @@ print({emqx_topic, #route{topic = Topic, dest = {_, Node}}}) ->
     emqx_ctl:print("~ts -> ~ts~n", [Topic, Node]);
 print({emqx_topic, #route{topic = Topic, dest = Node}}) ->
     emqx_ctl:print("~ts -> ~ts~n", [Topic, Node]);
-print(#plugin{name = Name, descr = Descr, active = Active}) ->
-    emqx_ctl:print(
-        "Plugin(~ts, description=~ts, active=~ts)~n",
-        [Name, Descr, Active]
-    );
 print({emqx_suboption, {{Pid, Topic}, Options}}) when is_pid(Pid) ->
     emqx_ctl:print("~ts -> ~ts~n", [maps:get(subid, Options), Topic]).
 

apps/emqx_modules/src/emqx_telemetry.erl

@@ -278,11 +278,12 @@ nodes_uuid() ->
 
 active_plugins() ->
     lists:foldl(
-        fun(#plugin{name = Name, active = Active}, Acc) ->
+        fun
-            case Active of
+            (#{running_status := running} = Plugin, Acc) ->
-                true -> [Name | Acc];
+                #{<<"name">> := Name, <<"rel_vsn">> := Vsn} = Plugin,
-                false -> Acc
+                [iolist_to_binary([Name, "-", Vsn]) | Acc];
-            end
+            (_, Acc) ->
+                Acc
         end,
         [],
         emqx_plugins:list()