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

feat: add bytesize rule sql function

This commit is contained in:
Zaiming (Stone) Shi 2023-09-15 16:04:21 +02:00
parent 2aae3856a3
commit ac41f497b4
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_rule_engine/src/emqx_rule_funcs.erl
View File

@ -89,6 +89,7 @@
bitsl/2, bitsl/2,
bitsr/2, bitsr/2,
bitsize/1, bitsize/1,
bytesize/1,
subbits/2, subbits/2,
subbits/3, subbits/3,
subbits/6 subbits/6
@ -405,6 +406,9 @@ find_topic_filter(Filter, TopicFilters, Func) ->
null() -> null() ->
undefined. undefined.
bytesize(IoList) ->
erlang:iolist_size(IoList).
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
%% Arithmetic Funcs %% Arithmetic Funcs
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------

4
apps/emqx_rule_engine/test/emqx_rule_funcs_SUITE.erl
View File

@ -759,6 +759,10 @@ t_bitsize(_) ->
?assertEqual(8, apply_func(bitsize, [<<"a">>])), ?assertEqual(8, apply_func(bitsize, [<<"a">>])),
?assertEqual(4, apply_func(bitsize, [<<15:4>>])). ?assertEqual(4, apply_func(bitsize, [<<15:4>>])).
t_bytesize(_) ->
?assertEqual(1, apply_func(bytesize, [<<"a">>])),
?assertEqual(0, apply_func(bytesize, [<<>>])).
t_subbits(_) -> t_subbits(_) ->
?assertEqual(1, apply_func(subbits, [<<255:8>>, 1])), ?assertEqual(1, apply_func(subbits, [<<255:8>>, 1])),
?assertEqual(3, apply_func(subbits, [<<255:8>>, 2])), ?assertEqual(3, apply_func(subbits, [<<255:8>>, 2])),