yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(import): fix import bridge mqtt test cases

This commit is contained in:
Turtle 2021-05-08 14:11:49 +08:00 committed by Rory Z
parent 934d3c405d
commit c5aeeb3b40
1 changed files with 31 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
apps/emqx_management/test/emqx_bridge_mqtt_data_export_import_SUITE.erl
View File

@ -28,24 +28,11 @@ all() ->
emqx_ct:all(?MODULE).
init_per_suite(Cfg) ->
ok = ekka_mnesia:start(),
ok = emqx_rule_registry:mnesia(boot),
ok = emqx_rule_engine:load_providers(),
emqx_ct_helpers:start_apps([emqx_web_hook,
emqx_bridge_mqtt,
emqx_rule_engine,
emqx_modules,
emqx_management,
emqx_dashboard]),
emqx_ct_helpers:start_apps([emqx_bridge_mqtt, emqx_rule_engine]),
Cfg.
end_per_suite(Cfg) ->
emqx_ct_helpers:stop_apps([emqx_dashboard,
emqx_management,
emqx_modules,
emqx_rule_engine,
emqx_bridge_mqtt,
emqx_web_hook]),
emqx_ct_helpers:stop_apps([emqx_management, emqx_rule_engine]),
Cfg.
get_data_path() ->
@ -53,8 +40,8 @@ get_data_path() ->
import(FilePath, Version) ->
ok = emqx_mgmt_data_backup:import(get_data_path() ++ "/" ++ FilePath, <<"{}">>),
timer:sleep(500),
lists:foreach(fun(#resource{id = Id, config = Config} = _Resource) ->
timer:sleep(2000),
case Id of
<<"bridge">> ->
test_utils:resource_is_alive(Id),
@ -74,19 +61,23 @@ import(FilePath, Version) ->
t_import420(_) ->
import("420.json", 420),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_import430(_) ->
import("430.json", 430),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_import409(_) ->
import("409.json", 409),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_import415(_) ->
import("415.json", 415),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
handle_config(Config, 420, bridge) ->
@ -126,27 +117,33 @@ handle_config(_, _, _) -> ok.
t_importee4010(_) ->
import("ee4010.json", ee4010),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_importee410(_) ->
import("ee410.json", ee410),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_importee411(_) ->
import("ee411.json", ee411),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_importee420(_) ->
import("ee420.json", ee420),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_importee425(_) ->
import("ee425.json", ee425),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
t_importee430(_) ->
import("ee430.json", ee430),
{ok, _} = emqx_mgmt_data_backup:export().
{ok, _} = emqx_mgmt_data_backup:export(),
remove_resources().
%%--------------------------------------------------------------------
%% handle_config
@ -176,3 +173,11 @@ handle_config(Config, ee430, rpc) ->
handle_config(Config, ee435, Id) ->
handle_config(Config, ee430, Id).
-endif.
remove_resources() ->
timer:sleep(500),
lists:foreach(fun(#resource{id = Id}) ->
emqx_rule_registry:remove_resource(Id),
emqx_rule_registry:remove_resource_params(Id)
end, emqx_rule_registry:get_resources()),
timer:sleep(500).