diff --git a/apps/emqx_authn/src/emqx_authn_utils.erl b/apps/emqx_authn/src/emqx_authn_utils.erl index 6e8976cee..20d2b57c9 100644 --- a/apps/emqx_authn/src/emqx_authn_utils.erl +++ b/apps/emqx_authn/src/emqx_authn_utils.erl @@ -45,9 +45,14 @@ ?PH_CERT_CN_NAME ]). -%%------------------------------------------------------------------------------ +-define(DEFAULT_RESOURCE_OPTS, #{ + auto_retry_interval => 6000, + start_after_created => false +}). + +%%-------------------------------------------------------------------- %% APIs -%%------------------------------------------------------------------------------ +%%-------------------------------------------------------------------- create_resource(ResourceId, Module, Config) -> Result = emqx_resource:create_local( @@ -55,13 +60,14 @@ create_resource(ResourceId, Module, Config) -> ?RESOURCE_GROUP, Module, Config, - #{start_after_created => false} + ?DEFAULT_RESOURCE_OPTS ), start_resource_if_enabled(Result, ResourceId, Config). update_resource(Module, Config, ResourceId) -> - Opts = #{start_after_created => false}, - Result = emqx_resource:recreate_local(ResourceId, Module, Config, Opts), + Result = emqx_resource:recreate_local( + ResourceId, Module, Config, ?DEFAULT_RESOURCE_OPTS + ), start_resource_if_enabled(Result, ResourceId, Config). start_resource_if_enabled({ok, _} = Result, ResourceId, #{enable := true}) -> @@ -166,9 +172,9 @@ make_resource_id(Name) -> NameBin = bin(Name), emqx_resource:generate_id(NameBin). -%%------------------------------------------------------------------------------ +%%-------------------------------------------------------------------- %% Internal functions -%%------------------------------------------------------------------------------ +%%-------------------------------------------------------------------- handle_var({var, Name}, undefined) -> error({cannot_get_variable, Name}); diff --git a/apps/emqx_authz/src/emqx_authz_utils.erl b/apps/emqx_authz/src/emqx_authz_utils.erl index 2e547941a..e0ee41817 100644 --- a/apps/emqx_authz/src/emqx_authz_utils.erl +++ b/apps/emqx_authz/src/emqx_authz_utils.erl @@ -34,9 +34,14 @@ render_sql_params/2 ]). -%%------------------------------------------------------------------------------ +-define(DEFAULT_RESOURCE_OPTS, #{ + auto_retry_interval => 6000, + start_after_created => false +}). + +%%-------------------------------------------------------------------- %% APIs -%%------------------------------------------------------------------------------ +%%-------------------------------------------------------------------- create_resource(Module, Config) -> ResourceId = make_resource_id(Module), @@ -48,7 +53,7 @@ create_resource(ResourceId, Module, Config) -> ?RESOURCE_GROUP, Module, Config, - #{start_after_created => false} + ?DEFAULT_RESOURCE_OPTS ), start_resource_if_enabled(Result, ResourceId, Config). @@ -59,7 +64,7 @@ update_resource(Module, #{annotations := #{id := ResourceId}} = Config) -> ResourceId, Module, Config, - #{start_after_created => false} + ?DEFAULT_RESOURCE_OPTS ) of {ok, _} -> {ok, ResourceId}; @@ -125,9 +130,9 @@ render_sql_params(ParamList, Values) -> #{return => rawlist, var_trans => fun handle_sql_var/2} ). -%%------------------------------------------------------------------------------ +%%-------------------------------------------------------------------- %% Internal functions -%%------------------------------------------------------------------------------ +%%-------------------------------------------------------------------- client_vars(ClientInfo) -> maps:from_list(