test: fix flaky influxdb test

lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_influxdb_SUITE.erl

@@ -990,9 +990,7 @@ t_write_failure(Config) ->
                     ?assertMatch([_ | _], Trace),
                     [#{result := Result} | _] = Trace,
                     ?assert(
-                        {error, {error, {closed, "The connection was lost."}}} =:= Result orelse
+                        not emqx_ee_connector_influxdb:is_unrecoverable_error(Result),
-                            {error, {error, closed}} =:= Result orelse
-                            {error, {recoverable_error, econnrefused}} =:= Result,
                         #{got => Result}
                     );
                 async ->
@@ -1000,11 +998,7 @@ t_write_failure(Config) ->
                     ?assertMatch([#{action := nack} | _], Trace),
                     [#{result := Result} | _] = Trace,
                     ?assert(
-                        {error, {recoverable_error, {closed, "The connection was lost."}}} =:=
+                        not emqx_ee_connector_influxdb:is_unrecoverable_error(Result),
-                            Result orelse
-                            {error, {error, closed}} =:= Result orelse
-                            {error, {recoverable_error, econnrefused}} =:= Result orelse
-                            {error, {recoverable_error, noproc}} =:= Result,
                         #{got => Result}
                     )
             end,

lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl

@@ -35,6 +35,9 @@
     desc/1
 ]).
 
+%% only for test
+-export([is_unrecoverable_error/1]).
+
 -type ts_precision() :: ns | us | ms | s.
 
 %% influxdb servers don't need parse
@@ -655,12 +658,6 @@ str(S) when is_list(S) ->
 
 is_unrecoverable_error({error, {unrecoverable_error, _}}) ->
     true;
-is_unrecoverable_error({error, {recoverable_error, _}}) ->
-    false;
-is_unrecoverable_error({error, {error, econnrefused}}) ->
-    false;
-is_unrecoverable_error({error, econnrefused}) ->
-    false;
 is_unrecoverable_error(_) ->
     false.