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

fix: update delayed config

This commit is contained in:
DDDHuang 2021-08-26 17:22:42 +08:00 committed by turtleDeng
parent bcd15e9388
commit e92255114f
1 changed files with 2 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/emqx_modules/src/emqx_delayed_api.erl
View File

@ -92,7 +92,7 @@ status_api() ->
<<"200">> => <<"200">> =>
schema(conf_schema(), <<"Enable or disable delayed successfully">>), schema(conf_schema(), <<"Enable or disable delayed successfully">>),
<<"400">> => <<"400">> =>
error_schema(<<"Already disabled or enabled">>, [?ALREADY_ENABLED, ?ALREADY_DISABLED]) error_schema(<<"Max limit illegality">>, [?BAD_REQUEST])
} }
} }
}, },
@ -174,7 +174,7 @@ update_config(Config) ->
{400, #{code => Code, message => Message}} {400, #{code => Code, message => Message}}
end. end.
generate_config(Config) -> generate_config(Config) ->
generate_config(Config, [fun generate_enable/1, fun generate_max_delayed_messages/1]). generate_config(Config, [fun generate_max_delayed_messages/1]).
generate_config(Config, []) -> generate_config(Config, []) ->
{ok, Config}; {ok, Config};
@ -186,18 +186,6 @@ generate_config(Config, [Fun | Tail]) ->
{error, CodeMessage} {error, CodeMessage}
end. end.
generate_enable(Config = #{<<"enable">> := Enable}) ->
case {Enable =:= maps:get(enable, get_status()), Enable} of
{true, true} ->
{error, {?ALREADY_ENABLED, <<"Delayed message status is already enabled">>}};
{true, false} ->
{error, {?ALREADY_DISABLED, <<"Delayed message status is already disable">>}};
_ ->
{ok, Config}
end;
generate_enable(Config) ->
{ok, Config}.
generate_max_delayed_messages(Config = #{<<"max_delayed_messages">> := Max}) when Max >= 0 -> generate_max_delayed_messages(Config = #{<<"max_delayed_messages">> := Max}) when Max >= 0 ->
{ok, Config}; {ok, Config};
generate_max_delayed_messages(#{<<"max_delayed_messages">> := Max}) when Max < 0 -> generate_max_delayed_messages(#{<<"max_delayed_messages">> := Max}) when Max < 0 ->