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

Format code

This commit is contained in:
turtled 2019-12-04 13:54:59 +08:00
parent 4b59db62fa
commit dceb087039
1 changed files with 2 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/emqx_mqtt_caps.erl
View File

@ -118,44 +118,22 @@ do_check_sub(_Flags, _Caps) -> ok.
-spec(get_caps(emqx_zone:zone()) -> caps()). -spec(get_caps(emqx_zone:zone()) -> caps()).
get_caps(Zone) -> get_caps(Zone) ->
% with_env(Zone, '$mqtt_caps', fun all_caps/1). maps:from_list([{Cap, emqx_zone:get_env(Zone, Cap, Def)} ||
maps:from_list([{Cap, emqx_zone:get_env(Zone, Cap, Def)} || {Cap, Def} <- maps:to_list(?DEFAULT_CAPS)]). {Cap, Def} <- maps:to_list(?DEFAULT_CAPS)]).
-spec(get_caps(emqx_zone:zone(), publish|subscribe) -> caps()). -spec(get_caps(emqx_zone:zone(), publish|subscribe) -> caps()).
get_caps(Zone, publish) -> get_caps(Zone, publish) ->
% with_env(Zone, '$mqtt_pub_caps', fun pub_caps/1);
filter_caps(?PUBCAP_KEYS, get_caps(Zone)); filter_caps(?PUBCAP_KEYS, get_caps(Zone));
get_caps(Zone, subscribe) -> get_caps(Zone, subscribe) ->
% with_env(Zone, '$mqtt_sub_caps', fun sub_caps/1).
filter_caps(?SUBCAP_KEYS, get_caps(Zone)). filter_caps(?SUBCAP_KEYS, get_caps(Zone)).
-spec(get_caps(emqx_zone:zone(), atom(), term()) -> term()). -spec(get_caps(emqx_zone:zone(), atom(), term()) -> term()).
get_caps(Zone, Cap, Def) -> get_caps(Zone, Cap, Def) ->
emqx_zone:get_env(Zone, Cap, Def). emqx_zone:get_env(Zone, Cap, Def).
% pub_caps(Zone) ->
% filter_caps(?PUBCAP_KEYS, get_caps(Zone)).
% sub_caps(Zone) ->
% filter_caps(?SUBCAP_KEYS, get_caps(Zone)).
% all_caps(Zone) ->
% maps:map(fun(Cap, Def) ->
% emqx_zone:get_env(Zone, Cap, Def)
% end, ?DEFAULT_CAPS).
filter_caps(Keys, Caps) -> filter_caps(Keys, Caps) ->
maps:filter(fun(Key, _Val) -> lists:member(Key, Keys) end, Caps). maps:filter(fun(Key, _Val) -> lists:member(Key, Keys) end, Caps).
% with_env(Zone, Key, InitFun) ->
% case emqx_zone:get_env(Zone, Key) of
% undefined ->
% Caps = InitFun(Zone),
% ok = emqx_zone:set_env(Zone, Key, Caps),
% Caps;
% Caps -> Caps
% end.
-spec(default() -> caps()). -spec(default() -> caps()).
default() -> ?DEFAULT_CAPS. default() -> ?DEFAULT_CAPS.