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

test: add disable_enable tests

This commit is contained in:
Stefan Strigler 2023-10-03 12:03:28 +02:00 committed by Zaiming (Stone) Shi
parent 009b9c3d39
commit 9195838c17
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
apps/emqx_connector/test/emqx_connector_SUITE.erl
View File

@ -43,7 +43,7 @@ end_per_testcase(TestCase, Config) ->
t_connector_lifecycle({init, Config}) -> t_connector_lifecycle({init, Config}) ->
meck:new(emqx_connector_ee_schema, [passthrough]), meck:new(emqx_connector_ee_schema, [passthrough]),
meck:expect(emqx_connector_ee_schema, resource_type, 1, dummy_connector_impl), meck:expect(emqx_connector_ee_schema, resource_type, 1, ?CONNECTOR),
meck:new(?CONNECTOR, [non_strict]), meck:new(?CONNECTOR, [non_strict]),
meck:expect(?CONNECTOR, callback_mode, 0, async_if_possible), meck:expect(?CONNECTOR, callback_mode, 0, async_if_possible),
meck:expect(?CONNECTOR, on_start, 2, {ok, connector_state}), meck:expect(?CONNECTOR, on_start, 2, {ok, connector_state}),
@ -71,12 +71,12 @@ t_connector_lifecycle(_Config) ->
), ),
?assertMatch( ?assertMatch(
{ok, #{name := my_connector, type := kafka}}, {ok, #{name := my_connector, type := kafka, resource_data := #{status := connected}}},
emqx_connector:lookup(<<"kafka:my_connector">>) emqx_connector:lookup(<<"kafka:my_connector">>)
), ),
?assertMatch( ?assertMatch(
{ok, #{name := my_connector, type := kafka}}, {ok, #{name := my_connector, type := kafka, resource_data := #{status := connected}}},
emqx_connector:lookup(kafka, my_connector) emqx_connector:lookup(kafka, my_connector)
), ),
@ -85,6 +85,26 @@ t_connector_lifecycle(_Config) ->
emqx_connector:list() emqx_connector:list()
), ),
?assertMatch(
{ok, #{config := #{enable := false}}},
emqx_connector:disable_enable(disable, kafka, my_connector)
),
?assertMatch(
{ok, #{resource_data := #{status := stopped}}},
emqx_connector:lookup(kafka, my_connector)
),
?assertMatch(
{ok, #{config := #{enable := true}}},
emqx_connector:disable_enable(enable, kafka, my_connector)
),
?assertMatch(
{ok, #{resource_data := #{status := connected}}},
emqx_connector:lookup(kafka, my_connector)
),
?assertMatch( ?assertMatch(
{ok, _}, {ok, _},
emqx_connector:remove(kafka, my_connector) emqx_connector:remove(kafka, my_connector)
@ -101,6 +121,10 @@ t_connector_lifecycle(_Config) ->
{_, {?CONNECTOR, callback_mode, []}, _}, {_, {?CONNECTOR, callback_mode, []}, _},
{_, {?CONNECTOR, on_start, [_, _]}, {ok, connector_state}}, {_, {?CONNECTOR, on_start, [_, _]}, {ok, connector_state}},
{_, {?CONNECTOR, on_get_status, [_, connector_state]}, connected}, {_, {?CONNECTOR, on_get_status, [_, connector_state]}, connected},
{_, {?CONNECTOR, on_stop, [_, connector_state]}, ok},
{_, {?CONNECTOR, on_stop, [_, connector_state]}, ok},
{_, {?CONNECTOR, on_start, [_, _]}, {ok, connector_state}},
{_, {?CONNECTOR, on_get_status, [_, connector_state]}, connected},
{_, {?CONNECTOR, on_stop, [_, connector_state]}, ok} {_, {?CONNECTOR, on_stop, [_, connector_state]}, ok}
], ],
meck:history(?CONNECTOR) meck:history(?CONNECTOR)