From a9c9d9d805f24b33505ebff18e4221944268ac0e Mon Sep 17 00:00:00 2001 From: Shawn <506895667@qq.com> Date: Sat, 18 Dec 2021 20:24:23 +0800 Subject: [PATCH] fix(rule): rename enabled to enable --- apps/emqx_rule_engine/include/rule_engine.hrl | 2 +- apps/emqx_rule_engine/src/emqx_rule_engine.erl | 2 +- apps/emqx_rule_engine/src/emqx_rule_engine_api.erl | 8 ++++---- apps/emqx_rule_engine/src/emqx_rule_runtime.erl | 2 +- apps/emqx_rule_engine/src/emqx_rule_sqltester.erl | 2 +- 5 files changed, 8 insertions(+), 8 deletions(-) diff --git a/apps/emqx_rule_engine/include/rule_engine.hrl b/apps/emqx_rule_engine/include/rule_engine.hrl index 4884f329e..d7e02cf2e 100644 --- a/apps/emqx_rule_engine/include/rule_engine.hrl +++ b/apps/emqx_rule_engine/include/rule_engine.hrl @@ -47,7 +47,7 @@ , name := binary() , sql := binary() , outputs := [output()] - , enabled := boolean() + , enable := boolean() , description => binary() , created_at := integer() %% epoch in millisecond precision , from := list(topic()) diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl index 35be28610..5316ca5ef 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl @@ -223,7 +223,7 @@ do_create_rule(Params = #{id := RuleId, sql := Sql, outputs := Outputs}) -> id => RuleId, name => maps:get(name, Params, <<"">>), created_at => erlang:system_time(millisecond), - enabled => maps:get(enabled, Params, true), + enable => maps:get(enable, Params, true), sql => Sql, outputs => parse_outputs(Outputs), description => maps:get(description, Params, ""), diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl b/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl index 85f27a651..205f85488 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl @@ -197,8 +197,8 @@ param_path_id() -> {404, #{code => 'NOT_FOUND', message => <<"Rule Id Not Found">>}} end; -'/rules/:id'(put, #{bindings := #{id := Id}, body := Params}) -> - Params = filter_out_request_body(Params), +'/rules/:id'(put, #{bindings := #{id := Id}, body := Params0}) -> + Params = filter_out_request_body(Params0), ConfPath = emqx_rule_engine:config_key_path() ++ [Id], case emqx:update_config(ConfPath, Params, #{}) of {ok, #{post_config_update := #{emqx_rule_engine := AllRules}}} -> @@ -235,7 +235,7 @@ format_rule_resp(#{ id := Id, name := Name, from := Topics, outputs := Output, sql := SQL, - enabled := Enabled, + enable := Enable, description := Descr}) -> NodeMetrics = get_rule_metrics(Id), #{id => Id, @@ -245,7 +245,7 @@ format_rule_resp(#{ id := Id, name := Name, sql => SQL, metrics => aggregate_metrics(NodeMetrics), node_metrics => NodeMetrics, - enabled => Enabled, + enable => Enable, created_at => format_datetime(CreatedAt, millisecond), description => Descr }. diff --git a/apps/emqx_rule_engine/src/emqx_rule_runtime.erl b/apps/emqx_rule_engine/src/emqx_rule_runtime.erl index 1cabf3e32..4225c6f72 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_runtime.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_runtime.erl @@ -48,7 +48,7 @@ -spec(apply_rules(list(rule()), input()) -> ok). apply_rules([], _Input) -> ok; -apply_rules([#{enabled := false}|More], Input) -> +apply_rules([#{enable := false}|More], Input) -> apply_rules(More, Input); apply_rules([Rule = #{id := RuleID}|More], Input) -> try apply_rule_discard_result(Rule, Input) diff --git a/apps/emqx_rule_engine/src/emqx_rule_sqltester.erl b/apps/emqx_rule_engine/src/emqx_rule_sqltester.erl index 7cd9448db..74ec1bb1c 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_sqltester.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_sqltester.erl @@ -47,7 +47,7 @@ test_rule(Sql, Select, Context, EventTopics) -> sql => Sql, from => EventTopics, outputs => [#{mod => ?MODULE, func => get_selected_data, args => #{}}], - enabled => true, + enable => true, is_foreach => emqx_rule_sqlparser:select_is_foreach(Select), fields => emqx_rule_sqlparser:select_fields(Select), doeach => emqx_rule_sqlparser:select_doeach(Select),