95 lines
2.8 KiB
Erlang
95 lines
2.8 KiB
Erlang
%%--------------------------------------------------------------------
|
|
%% Copyright (c) 2020-2021 EMQ Technologies Co., Ltd. All Rights Reserved.
|
|
%%
|
|
%% Licensed under the Apache License, Version 2.0 (the "License");
|
|
%% you may not use this file except in compliance with the License.
|
|
%% You may obtain a copy of the License at
|
|
%%
|
|
%% http://www.apache.org/licenses/LICENSE-2.0
|
|
%%
|
|
%% Unless required by applicable law or agreed to in writing, software
|
|
%% distributed under the License is distributed on an "AS IS" BASIS,
|
|
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
%% See the License for the specific language governing permissions and
|
|
%% limitations under the License.
|
|
%%--------------------------------------------------------------------
|
|
|
|
-define(APP, emqx_rule_engine).
|
|
|
|
-define(KV_TAB, '@rule_engine_db').
|
|
|
|
-type maybe(T) :: T | undefined.
|
|
|
|
-type rule_id() :: binary().
|
|
-type rule_name() :: binary().
|
|
|
|
-type mf() :: {Module::atom(), Fun::atom()}.
|
|
|
|
-type hook() :: atom() | 'any'.
|
|
-type topic() :: binary().
|
|
|
|
-type selected_data() :: map().
|
|
-type envs() :: map().
|
|
|
|
-type builtin_output_func() :: republish | console.
|
|
-type builtin_output_module() :: emqx_rule_outputs.
|
|
-type bridge_channel_id() :: binary().
|
|
-type output_fun_args() :: map().
|
|
|
|
-type output() :: #{
|
|
mod := builtin_output_module() | module(),
|
|
func := builtin_output_func() | atom(),
|
|
args => output_fun_args()
|
|
} | bridge_channel_id().
|
|
|
|
-type rule() ::
|
|
#{ id := rule_id()
|
|
, name := binary()
|
|
, sql := binary()
|
|
, outputs := [output()]
|
|
, enable := boolean()
|
|
, description => binary()
|
|
, created_at := integer() %% epoch in millisecond precision
|
|
, from := list(topic())
|
|
, is_foreach := boolean()
|
|
, fields := list()
|
|
, doeach := term()
|
|
, incase := term()
|
|
, conditions := tuple()
|
|
}.
|
|
|
|
%% Arithmetic operators
|
|
-define(is_arith(Op), (Op =:= '+' orelse
|
|
Op =:= '-' orelse
|
|
Op =:= '*' orelse
|
|
Op =:= '/' orelse
|
|
Op =:= 'div')).
|
|
|
|
%% Compare operators
|
|
-define(is_comp(Op), (Op =:= '=' orelse
|
|
Op =:= '=~' orelse
|
|
Op =:= '>' orelse
|
|
Op =:= '<' orelse
|
|
Op =:= '<=' orelse
|
|
Op =:= '>=' orelse
|
|
Op =:= '<>' orelse
|
|
Op =:= '!=')).
|
|
|
|
%% Logical operators
|
|
-define(is_logical(Op), (Op =:= 'and' orelse Op =:= 'or')).
|
|
|
|
-define(RAISE(_EXP_, _ERROR_),
|
|
?RAISE(_EXP_, _ = do_nothing, _ERROR_)).
|
|
|
|
-define(RAISE(_EXP_, _EXP_ON_FAIL_, _ERROR_),
|
|
fun() ->
|
|
try (_EXP_)
|
|
catch _EXCLASS_:_EXCPTION_:_ST_ ->
|
|
_EXP_ON_FAIL_,
|
|
throw(_ERROR_)
|
|
end
|
|
end()).
|
|
|
|
%% Tables
|
|
-define(RULE_TAB, emqx_rule_engine).
|