test(bridge_v1): delete repeat probe_bridge_api code

apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl

@@ -392,18 +392,7 @@ probe_bridge_api(Config) ->
     TypeBin = ?BRIDGE_TYPE_BIN,
     Name = ?config(consumer_name, Config),
     ConsumerConfig = ?config(consumer_config, Config),
-    Params = ConsumerConfig#{<<"type">> => TypeBin, <<"name">> => Name},
+    emqx_bridge_testlib:probe_bridge_api(TypeBin, Name, ConsumerConfig).
-    Path = emqx_mgmt_api_test_util:api_path(["bridges_probe"]),
-    AuthHeader = emqx_mgmt_api_test_util:auth_header_(),
-    Opts = #{return_all => true},
-    ct:pal("probing bridge (via http): ~p", [Params]),
-    Res =
-        case emqx_mgmt_api_test_util:request_api(post, Path, "", AuthHeader, Params, Opts) of
-            {ok, {{_, 204, _}, _Headers, _Body0} = Res0} -> {ok, Res0};
-            Error -> Error
-        end,
-    ct:pal("bridge probe result: ~p", [Res]),
-    Res.
 
 start_and_subscribe_mqtt(Config) ->
     TopicMapping = ?config(topic_mapping, Config),

apps/emqx_bridge_http/test/emqx_bridge_http_SUITE.erl

@@ -789,15 +789,4 @@ remove_message_id(MessageIDs, IDBin) ->
     maps:without([ID], MessageIDs).
 
 probe_bridge_api(BridgeConfig) ->
-    Params = BridgeConfig#{<<"type">> => ?BRIDGE_TYPE, <<"name">> => ?BRIDGE_NAME},
+    emqx_bridge_testlib:probe_bridge_api(?BRIDGE_TYPE, ?BRIDGE_NAME, BridgeConfig).
-    Path = emqx_mgmt_api_test_util:api_path(["bridges_probe"]),
-    AuthHeader = emqx_mgmt_api_test_util:auth_header_(),
-    Opts = #{return_all => true},
-    ct:pal("probing bridge (via http): ~p", [Params]),
-    Res =
-        case emqx_mgmt_api_test_util:request_api(post, Path, "", AuthHeader, Params, Opts) of
-            {ok, {{_, 204, _}, _Headers, _Body0} = Res0} -> {ok, Res0};
-            Error -> Error
-        end,
-    ct:pal("bridge probe result: ~p", [Res]),
-    Res.

apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl

@@ -743,18 +743,7 @@ probe_bridge_api(Config) ->
     TypeBin = ?BRIDGE_TYPE_BIN,
     Name = ?config(kafka_name, Config),
     KafkaConfig = ?config(kafka_config, Config),
-    Params = KafkaConfig#{<<"type">> => TypeBin, <<"name">> => Name},
+    emqx_bridge_testlib:probe_bridge_api(TypeBin, Name, KafkaConfig).
-    Path = emqx_mgmt_api_test_util:api_path(["bridges_probe"]),
-    AuthHeader = emqx_mgmt_api_test_util:auth_header_(),
-    Opts = #{return_all => true},
-    ct:pal("probing bridge (via http): ~p", [Params]),
-    Res =
-        case emqx_mgmt_api_test_util:request_api(post, Path, "", AuthHeader, Params, Opts) of
-            {ok, {{_, 204, _}, _Headers, _Body0} = Res0} -> {ok, Res0};
-            Error -> Error
-        end,
-    ct:pal("bridge probe result: ~p", [Res]),
-    Res.
 
 send_message(Config, Payload) ->
     Name = ?config(kafka_name, Config),

apps/emqx_bridge_mongodb/test/emqx_bridge_mongodb_SUITE.erl

@@ -414,18 +414,7 @@ probe_bridge_api(Config, Overrides) ->
     TypeBin = mongo_type_bin(?config(mongo_type, Config)),
     MongoConfig0 = ?config(mongo_config, Config),
     MongoConfig = emqx_utils_maps:deep_merge(MongoConfig0, Overrides),
-    Params = MongoConfig#{<<"type">> => TypeBin, <<"name">> => Name},
+    emqx_bridge_testlib:probe_bridge_api(TypeBin, Name, MongoConfig).
-    Path = emqx_mgmt_api_test_util:api_path(["bridges_probe"]),
-    AuthHeader = emqx_mgmt_api_test_util:auth_header_(),
-    Opts = #{return_all => true},
-    ct:pal("probing bridge (via http): ~p", [Params]),
-    Res =
-        case emqx_mgmt_api_test_util:request_api(post, Path, "", AuthHeader, Params, Opts) of
-            {ok, {{_, 204, _}, _Headers, _Body0} = Res0} -> {ok, Res0};
-            Error -> Error
-        end,
-    ct:pal("bridge probe result: ~p", [Res]),
-    Res.
 
 resource_id(Config) ->
     Type0 = ?config(mongo_type, Config),

apps/emqx_bridge_oracle/test/emqx_bridge_oracle_SUITE.erl

@@ -344,22 +344,14 @@ probe_bridge_api(Config, Overrides) ->
     Name = ?config(oracle_name, Config),
     OracleConfig0 = ?config(oracle_config, Config),
     OracleConfig = emqx_utils_maps:deep_merge(OracleConfig0, Overrides),
-    Params = OracleConfig#{<<"type">> => TypeBin, <<"name">> => Name},
+    case emqx_bridge_testlib:probe_bridge_api(TypeBin, Name, OracleConfig) of
-    Path = emqx_mgmt_api_test_util:api_path(["bridges_probe"]),
-    AuthHeader = emqx_mgmt_api_test_util:auth_header_(),
-    Opts = #{return_all => true},
-    ct:pal("probing bridge (via http): ~p", [Params]),
-    Res =
-        case emqx_mgmt_api_test_util:request_api(post, Path, "", AuthHeader, Params, Opts) of
         {ok, {{_, 204, _}, _Headers, _Body0} = Res0} ->
             {ok, Res0};
         {error, {Status, Headers, Body0}} ->
             {error, {Status, Headers, emqx_bridge_testlib:try_decode_error(Body0)}};
         Error ->
             Error
-        end,
+    end.
-    ct:pal("bridge probe result: ~p", [Res]),
-    Res.
 
 create_rule_and_action_http(Config) ->
     OracleName = ?config(oracle_name, Config),