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

fix(dynamo): use correct default port for different schemas

This commit is contained in:
firest 2023-04-25 10:50:44 +08:00
parent 996d5eee45
commit 33c27ac2ac
1 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl
View File

@ -33,10 +33,6 @@
-import(hoconsc, [mk/2, enum/1, ref/2]).
-define(DYNAMO_HOST_OPTIONS, #{
default_port => 80
}).
%%=====================================================================
%% Hocon schema
roots() ->
@ -84,8 +80,8 @@ on_start(
config => redact(Config)
}),
{Schema, Server} = get_host_schema(to_str(Url)),
{Host, Port} = emqx_schema:parse_server(Server, ?DYNAMO_HOST_OPTIONS),
{Schema, Server, DefaultPort} = get_host_info(to_str(Url)),
{Host, Port} = emqx_schema:parse_server(Server, #{default_port => DefaultPort}),
Options = [
{config, #{
@ -226,12 +222,12 @@ to_str(List) when is_list(List) ->
to_str(Bin) when is_binary(Bin) ->
erlang:binary_to_list(Bin).
get_host_schema("http://" ++ Server) ->
{"http://", Server};
get_host_schema("https://" ++ Server) ->
{"https://", Server};
get_host_schema(Server) ->
{"http://", Server}.
get_host_info("http://" ++ Server) ->
{"http://", Server, 80};
get_host_info("https://" ++ Server) ->
{"https://", Server, 443};
get_host_info(Server) ->
{"http://", Server, 80}.
redact(Data) ->
emqx_utils:redact(Data, fun(Any) -> Any =:= aws_secret_access_key end).