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

Merge pull request #13459 from savonarola/0712-reduce-flackyness 

chore(mgmt): reduce test flakyness
This commit is contained in:
Ilia Averianov 2024-07-12 13:14:14 +03:00 committed by GitHub
parent 7664b06e98 9ca8aeb155
commit 82e723bd18
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
apps/emqx_management/test/emqx_mgmt_api_clients_SUITE.erl
View File

@ -1562,17 +1562,25 @@ t_bulk_subscribe(Config) ->
Topic = <<"testtopic">>, Topic = <<"testtopic">>,
BulkSub = [#{topic => Topic, qos => 1, nl => 1, rh => 1}], BulkSub = [#{topic => Topic, qos => 1, nl => 1, rh => 1}],
?assertMatch({200, [_]}, bulk_subscribe_request(ClientId1, Config, BulkSub)), ?assertMatch({200, [_]}, bulk_subscribe_request(ClientId1, Config, BulkSub)),
?assertMatch( ?retry(
{200, [_]}, 100,
get_subscriptions_request(ClientId1, Config, #{simplify_result => true}) 5,
?assertMatch(
{200, [_]},
get_subscriptions_request(ClientId1, Config, #{simplify_result => true})
)
), ),
{ok, _} = emqtt:publish(C2, Topic, <<"hi1">>, [{qos, 1}]), {ok, _} = emqtt:publish(C2, Topic, <<"hi1">>, [{qos, 1}]),
?assertReceive({publish, #{topic := Topic, payload := <<"hi1">>}}), ?assertReceive({publish, #{topic := Topic, payload := <<"hi1">>}}),
BulkUnsub = [#{topic => Topic}], BulkUnsub = [#{topic => Topic}],
?assertMatch({204, _}, bulk_unsubscribe_request(ClientId1, Config, BulkUnsub)), ?assertMatch({204, _}, bulk_unsubscribe_request(ClientId1, Config, BulkUnsub)),
?assertMatch( ?retry(
{200, []}, 100,
get_subscriptions_request(ClientId1, Config, #{simplify_result => true}) 5,
?assertMatch(
{200, []},
get_subscriptions_request(ClientId1, Config, #{simplify_result => true})
)
), ),
{ok, _} = emqtt:publish(C2, Topic, <<"hi2">>, [{qos, 1}]), {ok, _} = emqtt:publish(C2, Topic, <<"hi2">>, [{qos, 1}]),
?assertNotReceive({publish, _}), ?assertNotReceive({publish, _}),