Merge pull request #7947 from emqx/fix_flaky_tests

fix: fix tests for connector so they do not fail

apps/emqx_connector/test/emqx_connector_SUITE.erl

@@ -23,6 +23,15 @@
 -include_lib("common_test/include/ct.hrl").
 
 -define(BRIDGE_CONF_DEFAULT, <<"bridges: {}">>).
+-define(MQTT_CONNECTOR(Username), #{
+    <<"server">> => <<"127.0.0.1:1883">>,
+    <<"username">> => Username,
+    <<"password">> => <<"">>,
+    <<"proto_ver">> => <<"v4">>,
+    <<"ssl">> => #{<<"enable">> => false}
+}).
+-define(CONNECTOR_TYPE, <<"mqtt">>).
+-define(CONNECTOR_NAME, <<"test_connector">>).
 
 all() ->
     emqx_common_test_helpers:all(?MODULE).
@@ -55,6 +64,7 @@ end_per_suite(_Config) ->
     ok.
 
 init_per_testcase(_, Config) ->
+    {ok, _} = emqx_cluster_rpc:start_link(),
     Config.
 end_per_testcase(_, _Config) ->
     ok.
@@ -72,11 +82,12 @@ t_parse_connector_id_error(_) ->
         {invalid_connector_id, <<"foobar">>}, emqx_connector:parse_connector_id(<<"foobar">>)
     ).
 
-t_update_error(_) ->
-    ?assertException(exit, {noproc, _}, emqx_connector:update(<<"foo:bar">>, #{})).
+t_update_connector_does_not_exist(_) ->
+    Config = ?MQTT_CONNECTOR(<<"user1">>),
+    ?assertMatch({ok, _Config}, emqx_connector:update(?CONNECTOR_TYPE, ?CONNECTOR_NAME, Config)).
 
-t_delete_error(_) ->
-    ?assertException(exit, {noproc, _}, emqx_connector:delete(<<"foo:bar">>)).
+t_delete_connector_does_not_exist(_) ->
+    ?assertEqual({ok, #{post_config_update => #{}}}, emqx_connector:delete(<<"foo:bar">>)).
 
 t_connector_id_using_list(_) ->
     <<"foo:bar">> = emqx_connector:connector_id("foo", "bar").