fix(auth): remove emqx_connector from testcases of authz/authn

apps/emqx_authn/src/emqx_authn.app.src

@@ -4,7 +4,7 @@
     {vsn, "0.1.4"},
     {modules, []},
     {registered, [emqx_authn_sup, emqx_authn_registry]},
-    {applications, [kernel, stdlib, emqx_resource, ehttpc, epgsql, mysql, jose]},
+    {applications, [kernel, stdlib, emqx_resource, emqx_connector, ehttpc, epgsql, mysql, jose]},
     {mod, {emqx_authn_app, []}},
     {env, []},
     {licenses, ["Apache-2.0"]},

apps/emqx_authn/test/emqx_authn_mongo_SUITE.erl

@@ -50,7 +50,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?MONGO_HOST, ?MONGO_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             Config;
         false ->
             {skip, no_mongo}
@@ -61,7 +61,7 @@ end_per_suite(_Config) ->
         [authentication],
         ?GLOBAL
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_mongo_tls_SUITE.erl

@@ -46,7 +46,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?MONGO_HOST, ?MONGO_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             Config;
         false ->
             {skip, no_mongo}
@@ -57,7 +57,7 @@ end_per_suite(_Config) ->
         [authentication],
         ?GLOBAL
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_mysql_SUITE.erl

@@ -58,7 +58,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?MYSQL_HOST, ?MYSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             {ok, _} = emqx_resource:create_local(
                 ?MYSQL_RESOURCE,
                 ?RESOURCE_GROUP,
@@ -77,7 +77,7 @@ end_per_suite(_Config) ->
         ?GLOBAL
     ),
     ok = emqx_resource:remove_local(?MYSQL_RESOURCE),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_mysql_tls_SUITE.erl

@@ -49,7 +49,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?MYSQL_HOST, ?MYSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             Config;
         false ->
             {skip, no_mysql_tls}
@@ -60,7 +60,7 @@ end_per_suite(_Config) ->
         [authentication],
         ?GLOBAL
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_pgsql_SUITE.erl

@@ -59,7 +59,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?PGSQL_HOST, ?PGSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             {ok, _} = emqx_resource:create_local(
                 ?PGSQL_RESOURCE,
                 ?RESOURCE_GROUP,
@@ -78,7 +78,7 @@ end_per_suite(_Config) ->
         ?GLOBAL
     ),
     ok = emqx_resource:remove_local(?PGSQL_RESOURCE),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_pgsql_tls_SUITE.erl

@@ -49,7 +49,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?PGSQL_HOST, ?PGSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             Config;
         false ->
             {skip, no_pgsql_tls}
@@ -60,7 +60,7 @@ end_per_suite(_Config) ->
         [authentication],
         ?GLOBAL
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_redis_SUITE.erl

@@ -58,7 +58,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?REDIS_HOST, ?REDIS_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             {ok, _} = emqx_resource:create_local(
                 ?REDIS_RESOURCE,
                 ?RESOURCE_GROUP,
@@ -77,7 +77,7 @@ end_per_suite(_Config) ->
         ?GLOBAL
     ),
     ok = emqx_resource:remove_local(?REDIS_RESOURCE),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authn/test/emqx_authn_redis_tls_SUITE.erl

@@ -49,7 +49,7 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?REDIS_HOST, ?REDIS_TLS_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_authn]),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             Config;
         false ->
             {skip, no_redis}
@@ -60,7 +60,7 @@ end_per_suite(_Config) ->
         [authentication],
         ?GLOBAL
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authn]).
 
 %%------------------------------------------------------------------------------

apps/emqx_authz/test/emqx_authz_SUITE.erl

@@ -42,7 +42,7 @@ init_per_suite(Config) ->
     ),
 
     ok = emqx_common_test_helpers:start_apps(
-        [emqx_connector, emqx_conf, emqx_authz],
+        [emqx_conf, emqx_authz],
         fun set_special_configs/1
     ),
     Config.
@@ -57,7 +57,7 @@ end_per_suite(_Config) ->
         }
     ),
     ok = stop_apps([emqx_resource]),
-    emqx_common_test_helpers:stop_apps([emqx_connector, emqx_authz, emqx_conf]),
+    emqx_common_test_helpers:stop_apps([emqx_authz, emqx_conf]),
     meck:unload(emqx_resource),
     ok.
 

apps/emqx_authz/test/emqx_authz_api_cache_SUITE.erl

@@ -47,7 +47,7 @@ end_per_suite(_Config) ->
             <<"sources">> => []
         }
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     emqx_common_test_helpers:stop_apps([emqx_dashboard, emqx_authz, emqx_conf, emqx_management]),
     ok.
 

apps/emqx_authz/test/emqx_authz_api_settings_SUITE.erl

@@ -45,7 +45,7 @@ end_per_suite(_Config) ->
             <<"sources">> => []
         }
     ),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     emqx_common_test_helpers:stop_apps([emqx_dashboard, emqx_authz, emqx_conf]),
     ok.
 

apps/emqx_authz/test/emqx_authz_api_sources_SUITE.erl

@@ -103,7 +103,7 @@ groups() ->
     [].
 
 init_per_suite(Config) ->
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     meck:new(emqx_resource, [non_strict, passthrough, no_history, no_link]),
     meck:expect(emqx_resource, create_local, fun(_, _, _, _) -> {ok, meck_data} end),
     meck:expect(emqx_resource, health_check, fun(St) -> {ok, St} end),
@@ -120,7 +120,7 @@ init_per_suite(Config) ->
         [emqx_conf, emqx_authz, emqx_dashboard],
         fun set_special_configs/1
     ),
-    ok = start_apps([emqx_resource, emqx_connector]),
+    ok = start_apps([emqx_resource]),
     Config.
 
 end_per_suite(_Config) ->
@@ -134,7 +134,7 @@ end_per_suite(_Config) ->
     ),
     %% resource and connector should be stop first,
     %% or authz_[mysql|pgsql|redis..]_SUITE would be failed
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     emqx_common_test_helpers:stop_apps([emqx_dashboard, emqx_authz, emqx_conf]),
     meck:unload(emqx_resource),
     ok.

apps/emqx_authz/test/emqx_authz_file_SUITE.erl

@@ -55,7 +55,7 @@ init_per_suite(Config) ->
 
 end_per_suite(_Config) ->
     ok = emqx_authz_test_lib:restore_authorizers(),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authz]).
 
 init_per_testcase(_TestCase, Config) ->

apps/emqx_authz/test/emqx_authz_http_SUITE.erl

@@ -39,17 +39,17 @@ all() ->
     emqx_common_test_helpers:all(?MODULE).
 
 init_per_suite(Config) ->
-    ok = stop_apps([emqx_resource, emqx_connector, cowboy]),
+    ok = stop_apps([emqx_resource, cowboy]),
     ok = emqx_common_test_helpers:start_apps(
         [emqx_conf, emqx_authz],
         fun set_special_configs/1
     ),
-    ok = start_apps([emqx_resource, emqx_connector, cowboy]),
+    ok = start_apps([emqx_resource, cowboy]),
     Config.
 
 end_per_suite(_Config) ->
     ok = emqx_authz_test_lib:restore_authorizers(),
-    ok = stop_apps([emqx_resource, emqx_connector, cowboy]),
+    ok = stop_apps([emqx_resource, cowboy]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authz]).
 
 set_special_configs(emqx_authz) ->

apps/emqx_authz/test/emqx_authz_mongodb_SUITE.erl

@@ -34,14 +34,14 @@ groups() ->
     [].
 
 init_per_suite(Config) ->
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     case emqx_common_test_helpers:is_tcp_server_available(?MONGO_HOST, ?MONGO_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps(
                 [emqx_conf, emqx_authz],
                 fun set_special_configs/1
             ),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             Config;
         false ->
             {skip, no_mongo}
@@ -49,7 +49,7 @@ init_per_suite(Config) ->
 
 end_per_suite(_Config) ->
     ok = emqx_authz_test_lib:restore_authorizers(),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authz]).
 
 set_special_configs(emqx_authz) ->

apps/emqx_authz/test/emqx_authz_mysql_SUITE.erl

@@ -33,14 +33,14 @@ groups() ->
     [].
 
 init_per_suite(Config) ->
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     case emqx_common_test_helpers:is_tcp_server_available(?MYSQL_HOST, ?MYSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps(
                 [emqx_conf, emqx_authz],
                 fun set_special_configs/1
             ),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             {ok, _} = emqx_resource:create_local(
                 ?MYSQL_RESOURCE,
                 ?RESOURCE_GROUP,
@@ -56,7 +56,7 @@ init_per_suite(Config) ->
 end_per_suite(_Config) ->
     ok = emqx_authz_test_lib:restore_authorizers(),
     ok = emqx_resource:remove_local(?MYSQL_RESOURCE),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authz]).
 
 init_per_testcase(_TestCase, Config) ->

apps/emqx_authz/test/emqx_authz_postgresql_SUITE.erl

@@ -33,14 +33,14 @@ groups() ->
     [].
 
 init_per_suite(Config) ->
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     case emqx_common_test_helpers:is_tcp_server_available(?PGSQL_HOST, ?PGSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps(
                 [emqx_conf, emqx_authz],
                 fun set_special_configs/1
             ),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             {ok, _} = emqx_resource:create_local(
                 ?PGSQL_RESOURCE,
                 ?RESOURCE_GROUP,
@@ -56,7 +56,7 @@ init_per_suite(Config) ->
 end_per_suite(_Config) ->
     ok = emqx_authz_test_lib:restore_authorizers(),
     ok = emqx_resource:remove_local(?PGSQL_RESOURCE),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authz]).
 
 init_per_testcase(_TestCase, Config) ->

apps/emqx_authz/test/emqx_authz_redis_SUITE.erl

@@ -34,14 +34,14 @@ groups() ->
     [].
 
 init_per_suite(Config) ->
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     case emqx_common_test_helpers:is_tcp_server_available(?REDIS_HOST, ?REDIS_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps(
                 [emqx_conf, emqx_authz],
                 fun set_special_configs/1
             ),
-            ok = start_apps([emqx_resource, emqx_connector]),
+            ok = start_apps([emqx_resource]),
             {ok, _} = emqx_resource:create_local(
                 ?REDIS_RESOURCE,
                 ?RESOURCE_GROUP,
@@ -57,7 +57,7 @@ init_per_suite(Config) ->
 end_per_suite(_Config) ->
     ok = emqx_authz_test_lib:restore_authorizers(),
     ok = emqx_resource:remove_local(?REDIS_RESOURCE),
-    ok = stop_apps([emqx_resource, emqx_connector]),
+    ok = stop_apps([emqx_resource]),
     ok = emqx_common_test_helpers:stop_apps([emqx_authz]).
 
 init_per_testcase(_TestCase, Config) ->

apps/emqx_bridge/i18n/emqx_bridge_mqtt_schema.conf

@@ -1,4 +1,14 @@
 emqx_bridge_mqtt_schema {
+    config {
+        desc {
+                en: """The config for MQTT Bridges."""
+                zh: """MQTT Bridge 的配置。"""
+        }
+        label: {
+                en: "Config"
+                zh: "配置"
+        }
+    }
     desc_type {
                    desc {
                          en: """The bridge type."""

apps/emqx_bridge/src/schema/emqx_bridge_mqtt_schema.erl

@@ -25,6 +25,8 @@ fields("put") ->
 fields("get") ->
     emqx_bridge_schema:metrics_status_fields() ++ fields("config").
 
+desc("config") ->
+    ?DESC("config");
 desc(_) ->
     undefined.
 

apps/emqx_connector/i18n/emqx_connector_mqtt_schema.conf

@@ -71,8 +71,8 @@ is configured, then both the data got from the rule and the MQTT messages that m
 
     egress_local {
         desc {
-                en: """The configs about receiving messages from ben."""
+                en: """The configs about receiving messages from local broker."""
-                zh: """收取本地 Broker 消息相关的配置。"""
+                zh: """如何从本地 Broker 接收消息相关的配置。"""
         }
         label: {
                 en: "Local Configs"

apps/emqx_connector/src/mqtt/emqx_connector_mqtt_schema.erl

@@ -40,15 +40,21 @@ roots() ->
 fields("config") ->
     fields("server_configs") ++
         [
-            {ingress,
+            {"ingress",
                 mk(
                     hoconsc:union([none, ref(?MODULE, "ingress")]),
-                    #{default => undefined}
+                    #{
+                        default => undefined,
+                        desc => ?DESC("ingress_desc")
+                    }
                 )},
-            {egress,
+            {"egress",
                 mk(
                     hoconsc:union([none, ref(?MODULE, "egress")]),
-                    #{default => undefined}
+                    #{
+                        default => undefined,
+                        desc => ?DESC("egress_desc")
+                    }
                 )}
         ];
 fields("server_configs") ->

apps/emqx_connector/test/emqx_connector_mongo_SUITE.erl

@@ -36,7 +36,8 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?MONGO_HOST, ?MONGO_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_conf]),
-            ok = emqx_connector_test_helpers:start_apps([emqx_resource, emqx_connector]),
+            ok = emqx_connector_test_helpers:start_apps([emqx_resource]),
+            {ok, _} = application:ensure_all_started(emqx_connector),
             Config;
         false ->
             {skip, no_mongo}
@@ -44,7 +45,8 @@ init_per_suite(Config) ->
 
 end_per_suite(_Config) ->
     ok = emqx_common_test_helpers:stop_apps([emqx_conf]),
-    ok = emqx_connector_test_helpers:stop_apps([emqx_resource, emqx_connector]).
+    ok = emqx_connector_test_helpers:stop_apps([emqx_resource]),
+    _ = application:stop(emqx_connector).
 
 init_per_testcase(_, Config) ->
     Config.

apps/emqx_connector/test/emqx_connector_mqtt_worker_tests.erl

@@ -45,22 +45,6 @@ send(SendFun, Batch) when is_function(SendFun, 2) ->
 
 stop(_Pid) -> ok.
 
-%% bridge worker should retry connecting remote node indefinitely
-% reconnect_test() ->
-%     emqx_metrics:start_link(),
-%     emqx_connector_mqtt_worker:register_metrics(),
-%     Ref = make_ref(),
-%     Config = make_config(Ref, self(), {error, test}),
-%     {ok, Pid} = emqx_connector_mqtt_worker:start_link(?BRIDGE_NAME, Config),
-%     %% assert name registered
-%     ?assertEqual(Pid, whereis(?BRIDGE_REG_NAME)),
-%     ?WAIT({connection_start_attempt, Ref}, 1000),
-%     %% expect same message again
-%     ?WAIT({connection_start_attempt, Ref}, 1000),
-%     ok = emqx_connector_mqtt_worker:stop(?BRIDGE_REG_NAME),
-%     emqx_metrics:stop(),
-%     ok.
-
 %% connect first, disconnect, then connect again
 disturbance_test() ->
     meck:new(emqx_connector_mqtt_mod, [passthrough, no_history]),
@@ -69,7 +53,6 @@ disturbance_test() ->
     meck:expect(emqx_connector_mqtt_mod, stop, 1, fun(Pid) -> stop(Pid) end),
     try
         emqx_metrics:start_link(),
-        emqx_connector_mqtt_worker:register_metrics(),
         Ref = make_ref(),
         TestPid = self(),
         Config = make_config(Ref, TestPid, {ok, #{client_pid => TestPid}}),
@@ -84,36 +67,6 @@ disturbance_test() ->
         meck:unload(emqx_connector_mqtt_mod)
     end.
 
-% % %% buffer should continue taking in messages when disconnected
-% buffer_when_disconnected_test_() ->
-%     {timeout, 10000, fun test_buffer_when_disconnected/0}.
-
-% test_buffer_when_disconnected() ->
-%     Ref = make_ref(),
-%     Nums = lists:seq(1, 100),
-%     Sender = spawn_link(fun() -> receive {bridge, Pid} -> sender_loop(Pid, Nums, _Interval = 5) end end),
-%     SenderMref = monitor(process, Sender),
-%     Receiver = spawn_link(fun() -> receive {bridge, Pid} -> receiver_loop(Pid, Nums, _Interval = 1) end end),
-%     ReceiverMref = monitor(process, Receiver),
-%     SendFun = fun(Batch) ->
-%                       BatchRef = make_ref(),
-%                       Receiver ! {batch, BatchRef, Batch},
-%                       {ok, BatchRef}
-%               end,
-%     Config0 = make_config(Ref, false, {ok, #{client_pid => undefined}}),
-%     Config = Config0#{reconnect_delay_ms => 100},
-%     emqx_metrics:start_link(),
-%     emqx_connector_mqtt_worker:register_metrics(),
-%     {ok, Pid} = emqx_connector_mqtt_worker:start_link(?BRIDGE_NAME, Config),
-%     Sender ! {bridge, Pid},
-%     Receiver ! {bridge, Pid},
-%     ?assertEqual(Pid, whereis(?BRIDGE_REG_NAME)),
-%     Pid ! {disconnected, Ref, test},
-%     ?WAIT({'DOWN', SenderMref, process, Sender, normal}, 5000),
-%     ?WAIT({'DOWN', ReceiverMref, process, Receiver, normal}, 1000),
-%     ok = emqx_connector_mqtt_worker:stop(?BRIDGE_REG_NAME),
-%     emqx_metrics:stop().
-
 manual_start_stop_test() ->
     meck:new(emqx_connector_mqtt_mod, [passthrough, no_history]),
     meck:expect(emqx_connector_mqtt_mod, start, 1, fun(Conf) -> start(Conf) end),
@@ -121,7 +74,6 @@ manual_start_stop_test() ->
     meck:expect(emqx_connector_mqtt_mod, stop, 1, fun(Pid) -> stop(Pid) end),
     try
         emqx_metrics:start_link(),
-        emqx_connector_mqtt_worker:register_metrics(),
         Ref = make_ref(),
         TestPid = self(),
         BridgeName = manual_start_stop,

apps/emqx_connector/test/emqx_connector_mysql_SUITE.erl

@@ -36,7 +36,8 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?MYSQL_HOST, ?MYSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_conf]),
-            ok = emqx_connector_test_helpers:start_apps([emqx_resource, emqx_connector]),
+            ok = emqx_connector_test_helpers:start_apps([emqx_resource]),
+            {ok, _} = application:ensure_all_started(emqx_connector),
             Config;
         false ->
             {skip, no_mysql}
@@ -44,7 +45,8 @@ init_per_suite(Config) ->
 
 end_per_suite(_Config) ->
     ok = emqx_common_test_helpers:stop_apps([emqx_conf]),
-    ok = emqx_connector_test_helpers:stop_apps([emqx_resource, emqx_connector]).
+    ok = emqx_connector_test_helpers:stop_apps([emqx_resource]),
+    _ = application:stop(emqx_connector).
 
 init_per_testcase(_, Config) ->
     Config.

apps/emqx_connector/test/emqx_connector_pgsql_SUITE.erl

@@ -36,7 +36,8 @@ init_per_suite(Config) ->
     case emqx_common_test_helpers:is_tcp_server_available(?PGSQL_HOST, ?PGSQL_DEFAULT_PORT) of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_conf]),
-            ok = emqx_connector_test_helpers:start_apps([emqx_resource, emqx_connector]),
+            ok = emqx_connector_test_helpers:start_apps([emqx_resource]),
+            {ok, _} = application:ensure_all_started(emqx_connector),
             Config;
         false ->
             {skip, no_pgsql}
@@ -44,7 +45,8 @@ init_per_suite(Config) ->
 
 end_per_suite(_Config) ->
     ok = emqx_common_test_helpers:stop_apps([emqx_conf]),
-    ok = emqx_connector_test_helpers:stop_apps([emqx_resource, emqx_connector]).
+    ok = emqx_connector_test_helpers:stop_apps([emqx_resource]),
+    _ = application:stop(emqx_connector).
 
 init_per_testcase(_, Config) ->
     Config.

apps/emqx_connector/test/emqx_connector_redis_SUITE.erl

@@ -46,14 +46,16 @@ init_per_suite(Config) ->
     of
         true ->
             ok = emqx_common_test_helpers:start_apps([emqx_conf]),
-            ok = emqx_connector_test_helpers:start_apps([emqx_resource, emqx_connector]),
+            ok = emqx_connector_test_helpers:start_apps([emqx_resource]),
+            {ok, _} = application:ensure_all_started(emqx_connector),
             Config;
         false ->
             {skip, no_redis}
     end.
 
 end_per_suite(_Config) ->
-    ok = emqx_common_test_helpers:stop_apps([emqx_resource, emqx_connector]).
+    ok = emqx_common_test_helpers:stop_apps([emqx_resource]),
+    _ = application:stop(emqx_connector).
 
 init_per_testcase(_, Config) ->
     Config.

apps/emqx_machine/test/emqx_machine_SUITE.erl

@@ -47,7 +47,6 @@ init_per_suite(Config) ->
         emqx_prometheus,
         emqx_modules,
         emqx_dashboard,
-        emqx_connector,
         emqx_gateway,
         emqx_statsd,
         emqx_resource,