fix: don't create virtual type "rule_engine_api"

This commit is contained in:
Stefan Strigler 2023-04-05 16:46:19 +02:00
parent 576d1524bb
commit b799af1f71
2 changed files with 29 additions and 27 deletions

View File

@ -56,7 +56,7 @@ roots() ->
]. ].
fields("rule_engine") -> fields("rule_engine") ->
emqx_rule_engine_schema:fields("rule_engine_api"); emqx_rule_engine_schema:rule_engine_settings();
fields("rule_creation") -> fields("rule_creation") ->
emqx_rule_engine_schema:fields("rules"); emqx_rule_engine_schema:fields("rules");
fields("rule_info") -> fields("rule_info") ->

View File

@ -27,7 +27,8 @@
roots/0, roots/0,
fields/1, fields/1,
desc/1, desc/1,
post_config_update/5 post_config_update/5,
rule_engine_settings/0
]). ]).
-export([validate_sql/1]). -export([validate_sql/1]).
@ -40,37 +41,13 @@ tags() ->
roots() -> ["rule_engine"]. roots() -> ["rule_engine"].
fields("rule_engine") -> fields("rule_engine") ->
fields("rule_engine_api") ++ rule_engine_settings() ++
[ [
{rules, {rules,
?HOCON(hoconsc:map("id", ?R_REF("rules")), #{ ?HOCON(hoconsc:map("id", ?R_REF("rules")), #{
desc => ?DESC("rule_engine_rules"), default => #{} desc => ?DESC("rule_engine_rules"), default => #{}
})} })}
]; ];
fields("rule_engine_api") ->
[
{ignore_sys_message,
?HOCON(boolean(), #{default => true, desc => ?DESC("rule_engine_ignore_sys_message")})},
{jq_function_default_timeout,
?HOCON(
emqx_schema:duration_ms(),
#{
default => <<"10s">>,
desc => ?DESC("rule_engine_jq_function_default_timeout")
}
)},
{jq_implementation_module,
?HOCON(
hoconsc:enum([jq_nif, jq_port]),
#{
default => jq_nif,
mapping => "jq.jq_implementation_module",
desc => ?DESC("rule_engine_jq_implementation_module"),
deprecated => {since, "v5.0.22"},
importance => ?IMPORTANCE_HIDDEN
}
)}
];
fields("rules") -> fields("rules") ->
[ [
rule_name(), rule_name(),
@ -233,6 +210,31 @@ actions() ->
qos() -> qos() ->
?UNION([emqx_schema:qos(), binary()]). ?UNION([emqx_schema:qos(), binary()]).
rule_engine_settings() ->
[
{ignore_sys_message,
?HOCON(boolean(), #{default => true, desc => ?DESC("rule_engine_ignore_sys_message")})},
{jq_function_default_timeout,
?HOCON(
emqx_schema:duration_ms(),
#{
default => <<"10s">>,
desc => ?DESC("rule_engine_jq_function_default_timeout")
}
)},
{jq_implementation_module,
?HOCON(
hoconsc:enum([jq_nif, jq_port]),
#{
default => jq_nif,
mapping => "jq.jq_implementation_module",
desc => ?DESC("rule_engine_jq_implementation_module"),
deprecated => {since, "v5.0.22"},
importance => ?IMPORTANCE_HIDDEN
}
)}
].
validate_sql(Sql) -> validate_sql(Sql) ->
case emqx_rule_sqlparser:parse(Sql) of case emqx_rule_sqlparser:parse(Sql) of
{ok, _Result} -> ok; {ok, _Result} -> ok;