Packages
otpbp
7.6.0
7.18.0
7.16.1
7.15.0
7.14.0
7.13.0
7.12.0
7.11.0
7.10.2
7.9.3
7.9.2
7.9.1
7.8.7
7.8.6
7.8.5
7.8.4
7.7.1
7.7.0
7.6.3
7.6.2
7.6.1
7.6.0
7.5.1
7.5.0
7.4.0
7.3.4
7.3.3
7.3.2
7.3.1
7.3.0
7.2.0
7.1.1
7.1.0
7.0.4
7.0.3
7.0.2
7.0.1
6.26.0
6.25.0
6.24.0
6.23.0
6.22.2
6.21.3
6.21.2
6.21.1
6.20.2
6.19.1
6.19.0
6.18.3
6.18.2
6.18.1
6.18.0
6.17.1
6.17.0
6.16.0
6.15.4
6.15.3
6.15.2
6.15.1
6.15.0
6.14.0
6.13.5
6.13.4
6.13.3
6.13.2
6.13.1
6.13.0
6.12.0
6.11.2
6.11.1
6.10.0
6.9.2
6.9.1
6.9.0
6.8.0
6.7.1
6.7.0
6.6.4
6.6.3
6.6.2
6.6.1
6.6.0
6.5.0
6.4.0
6.3.3
6.3.2
6.3.1
6.3.0
6.2.1
6.2.0
6.1.0
6.0.0
5.39.0
5.38.0
5.37.0
5.36.0
5.35.2
5.34.3
5.34.2
5.34.1
5.33.1
5.32.1
5.32.0
5.31.3
5.31.2
5.31.1
5.31.0
5.30.1
5.30.0
5.29.0
5.28.4
5.28.3
5.28.2
5.28.1
5.28.0
5.27.0
5.26.5
5.26.4
5.26.3
5.26.2
5.26.1
5.26.0
5.25.0
5.24.2
5.24.1
5.23.0
5.22.2
5.22.1
5.22.0
5.21.0
5.20.1
5.20.0
5.19.4
5.19.3
5.19.2
5.19.1
5.19.0
5.18.0
5.17.0
5.16.3
5.16.1
5.16.0
5.15.1
5.15.0
5.14.0
5.13.1
5.13.0
5.12.1
5.12.0
5.11.2
5.11.1
5.10.1
5.10.0
5.9.0
5.8.0
5.7.0
5.6.1
5.6.0
5.5.0
5.4.2
5.4.1
5.4.0
5.3.0
5.2.2
5.2.1
5.2.0
5.1.2
5.1.1
4.79.0
4.78.0
4.77.0
4.76.2
4.75.3
4.75.2
4.75.1
4.74.0
4.73.1
4.73.0
4.72.3
4.72.2
4.72.1
4.72.0
4.71.1
4.71.0
4.70.0
4.69.4
4.69.3
4.69.2
4.69.1
4.69.0
4.68.0
4.67.5
4.67.4
4.67.3
4.67.2
4.67.0
4.66.0
4.65.2
4.65.1
4.64.0
4.63.2
4.63.1
4.63.0
4.62.0
4.61.1
4.61.0
4.60.4
4.60.3
4.60.2
4.60.1
4.60.0
4.59.0
4.58.0
4.57.2
4.57.1
4.57.0
4.56.2
4.56.1
4.56.0
4.55.0
4.54.0
4.53.0
4.52.1
4.52.0
4.51.3
4.51.2
4.51.0
4.50.0
4.49.3
4.49.2
OTP backports
Current section
Files
Jump to
Current section
Files
src/otpbp_http_uri.erl
-module(otpbp_http_uri).
-ifndef(HAVE_http_uri__parse_1).
% OTP < 25.0
-export([parse/1]).
-endif.
-ifndef(HAVE_http_uri__parse_2).
% OTP < 25.0
-export([parse/2]).
-endif.
-ifndef(HAVE_http_uri__scheme_defaults_0).
% OTP < 25.0
-export([scheme_defaults/0]).
-endif.
-ifndef(HAVE_http_uri__parse_1).
-ifdef(HAVE_http_uri__parse_2).
-import(http_uri, [parse/2]).
-endif.
-endif.
-ifndef(HAVE_http_uri__parse_2).
-ifdef(HAVE_http_uri__scheme_defaults_0).
-import(http_uri, [scheme_defaults/0]).
-endif.
-endif.
-ifndef(HAVE_http_uri__parse_2).
parse(URI) -> parse(URI, []).
-endif.
-ifndef(HAVE_http_uri__parse_2).
parse(URI, Options) ->
case uri_string:parse(URI) of
#{scheme := S, host := H, port := P} = M -> parse(M, Options, scheme(S), H, P, S);
#{scheme := S, host := H} = M ->
Scheme = scheme(S),
case lists:keyfind(Scheme, 1, scheme_defaults(Options)) of
{_Scheme, P} -> parse(M, Options, Scheme, H, P, S);
false -> {error, {no_default_port, Scheme, URI}}
end;
#{scheme := S} -> {error, {malformed_url, scheme(S), URI}};
#{} -> {error, no_scheme};
{error, invalid_uri, _} -> {error, {malformed_url, scheme(protocol(URI)), URI}};
{error, _, _} -> {error, no_scheme}
end.
parse(M, Options, Scheme, H, P, S) ->
case lists:keyfind(scheme_validation_fun, 1, Options) of
{_scheme_validation_fun, Fun} when is_function(Fun) ->
case Fun(S) of
valid -> parse(M, Options, Scheme, H, P);
{error, _} = E -> E
end;
_ -> parse(M, Options, Scheme, H, P)
end.
parse(M, Options, Scheme, H, Port) ->
E = empty(H),
Host = host(H, Options),
#{path := P, query := Q, userinfo := U} = maps:merge(#{path => E, query => E, userinfo => E}, M),
Path = path(P),
Query = prefix(Q, $?),
{ok,
case lists:member({fragment, true}, Options) of
false -> {Scheme, U, Host, Port, Path, Query};
true ->
{Scheme, U, Host, Port, Path, Query,
case M of
#{fragment := F} -> fragment(F);
_ -> E
end}
end}.
-compile({inline, prefix/2}).
prefix([_|_] = S, C) -> [C|S];
prefix(S, C) when byte_size(S) =/= 0 -> <<C, S/binary>>;
prefix(S, _) -> S.
scheme(S) when is_list(S) -> list_to_atom(S);
scheme(S) when is_binary(S) -> binary_to_atom(S, latin1).
-compile({inline, path/1}).
path("") -> "/";
path(<<>>) -> <<$/>>;
path(S) -> S.
-compile({inline, fragment/1}).
fragment(F) when is_list(F) -> [$#|F];
fragment(F) when is_binary(F) -> <<$#, F/binary>>.
-compile({inline, host/2}).
host(H, Options) ->
case lists:member({ipv6_host_with_brackets, true}, Options) of
false -> H;
true -> ipv6(H)
end.
-compile({inline, ipv6/1}).
ipv6(H) when is_list(H) ->
case string:chr(H, $:) of
0 -> H;
_ -> [$[|H ++ "]"]
end;
ipv6(H) when is_binary(H) ->
case binary:match(H, <<$:>>) of
nomatch -> H;
_ -> <<$[, H/binary, $]>>
end.
-compile({inline, protocol/1}).
protocol(URI) when is_list(URI) -> string:sub_word(URI, 1, $:);
protocol(URI) when is_binary(URI) ->
{I, _} = binary:match(URI, <<$:>>),
binary:part(URI, 0, I).
-compile({inline, scheme_defaults/1}).
scheme_defaults(Options) ->
case lists:keyfind(scheme_defaults, 1, Options) of
false -> scheme_defaults();
{_scheme_defaults, SD} -> SD
end.
-compile({inline, empty/1}).
empty(URI) when is_list(URI) -> "";
empty(URI) when is_binary(URI) -> <<>>.
-endif.
-ifndef(HAVE_http_uri__scheme_defaults_0).
scheme_defaults() -> [{http, 80}, {https, 443}, {ftp, 21}, {ssh, 22}, {sftp, 22}, {tftp, 69}].
-endif.