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

fix(rule): replubish SUIT

This commit is contained in:
DDDHuang 2022-06-09 17:35:55 +08:00
parent 6b1da3bcc8
commit ac700b8e6f
1 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl
View File

@ -413,7 +413,8 @@ t_republish_action(_Config) ->
#{rawsql => <<"select topic, payload, qos from \"t1\"">>, #{rawsql => <<"select topic, payload, qos from \"t1\"">>,
actions => [#{name => 'republish', actions => [#{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"${payload}">>}}], <<"payload_tmpl">> => <<"${payload}">>}}],
description => <<"builtin-republish-rule">>}), description => <<"builtin-republish-rule">>}),
{ok, Client} = emqtt:start_link([{username, <<"emqx">>}]), {ok, Client} = emqtt:start_link([{username, <<"emqx">>}]),
@ -479,7 +480,8 @@ t_crud_rule_api(_Config) ->
{<<"params">>,[ {<<"params">>,[
{<<"arg1">>,1}, {<<"arg1">>,1},
{<<"target_topic">>, <<"t2">>}, {<<"target_topic">>, <<"t2">>},
{<<"target_qos">>, -1}, {<<"target_qos">>, <<"0">>},
{<<"target_retain">>, <<"false">>},
{<<"payload_tmpl">>, <<"${payload}">>} {<<"payload_tmpl">>, <<"${payload}">>}
]} ]}
]] ]]
@ -1618,7 +1620,8 @@ t_sqlselect_multi_actoins_1(Config) ->
#{name => 'crash_action', args => #{}, fallbacks => []}, #{name => 'crash_action', args => #{}, fallbacks => []},
#{name => 'republish', #{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"clientid=${clientid}">> <<"payload_tmpl">> => <<"clientid=${clientid}">>
}, },
fallbacks => []} fallbacks => []}
@ -1644,7 +1647,8 @@ t_sqlselect_multi_actoins_1_1(Config) ->
#{name => 'crash_action', args => #{}, fallbacks => []}, #{name => 'crash_action', args => #{}, fallbacks => []},
#{name => 'republish', #{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"clientid=${clientid}">> <<"payload_tmpl">> => <<"clientid=${clientid}">>
}, },
fallbacks => []} fallbacks => []}
@ -1672,7 +1676,8 @@ t_sqlselect_multi_actoins_2(Config) ->
#{name => 'crash_action', args => #{}, fallbacks => []}, #{name => 'crash_action', args => #{}, fallbacks => []},
#{name => 'republish', #{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"clientid=${clientid}">> <<"payload_tmpl">> => <<"clientid=${clientid}">>
}, },
fallbacks => []} fallbacks => []}
@ -1703,7 +1708,8 @@ t_sqlselect_multi_actoins_3(Config) ->
]}, ]},
#{name => 'republish', #{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"clientid=${clientid}">> <<"payload_tmpl">> => <<"clientid=${clientid}">>
}, },
fallbacks => []} fallbacks => []}
@ -1741,7 +1747,8 @@ t_sqlselect_multi_actoins_3_1(Config) ->
]}, ]},
#{name => 'republish', #{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"clientid=${clientid}">> <<"payload_tmpl">> => <<"clientid=${clientid}">>
}, },
fallbacks => []} fallbacks => []}
@ -1780,7 +1787,8 @@ t_sqlselect_multi_actoins_4(Config) ->
]}, ]},
#{name => 'republish', #{name => 'republish',
args => #{<<"target_topic">> => <<"t2">>, args => #{<<"target_topic">> => <<"t2">>,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => <<"clientid=${clientid}">> <<"payload_tmpl">> => <<"clientid=${clientid}">>
}, },
fallbacks => []} fallbacks => []}
@ -2534,7 +2542,8 @@ create_simple_repub_rule(TargetTopic, SQL, Template) ->
#{rawsql => SQL, #{rawsql => SQL,
actions => [#{name => 'republish', actions => [#{name => 'republish',
args => #{<<"target_topic">> => TargetTopic, args => #{<<"target_topic">> => TargetTopic,
<<"target_qos">> => -1, <<"target_qos">> => <<"-1">>,
<<"target_retain">> => <<"false">>,
<<"payload_tmpl">> => Template} <<"payload_tmpl">> => Template}
}], }],
description => <<"simple repub rule">>}), description => <<"simple repub rule">>}),