Packages
erlcloud
3.3.5
3.8.3
3.8.2
3.8.1
3.7.6
3.7.4
3.7.3
3.7.2
3.7.1
3.7.0
3.6.8
3.6.7
3.6.5
3.6.4
3.6.3
3.6.2
3.6.1
3.6.0
3.5.16
3.5.15
3.5.14
3.5.13
3.5.12
3.5.11
3.5.10
3.5.9
3.5.8
3.5.7
3.5.6
3.5.5
3.5.4
3.5.3
3.5.2
3.5.1
3.5.0
3.4.5
3.4.3
3.4.1
3.4.0
3.3.9
3.3.8
3.3.7
3.3.6
3.3.5
3.3.4
3.3.3
3.3.2
3.3.1
3.3.0
3.2.18
3.2.17
3.2.16
3.2.15
3.2.14
3.2.13
3.2.12
3.2.11
3.2.10
3.2.7
3.2.6
3.2.5
3.2.4
3.2.3
3.2.2
3.2.1
3.2.0
3.1.17
3.1.16
3.1.14
3.1.13
3.1.12
3.1.11
3.1.9
3.1.8
3.1.7
3.1.6
3.1.5
3.1.4
3.1.3
3.1.2
3.1.1
3.1.0
3.0.5
3.0.4
3.0.3
3.0.2
3.0.1
2.2.16
2.2.15
2.2.14
2.2.13
2.2.12
2.2.11
2.2.10
2.2.9
2.2.8
2.2.7
2.2.6
2.2.5
2.2.4
2.2.2
2.2.1
2.2.0
2.1.0
2.0.5
2.0.4
2.0.3
2.0.0
0.13.10
0.13.9
0.13.8
0.13.6
0.13.5
0.13.4
0.13.3
0.13.2
0.13.0
0.12.0
0.11.0
0.9.2
0.9.2-rc.1
0.9.1
0.9.0
AWS APIs library for Erlang
Current section
Files
Jump to
Current section
Files
src/erlcloud_util.erl
-module(erlcloud_util).
-export([
sha_mac/2,
sha256_mac/2,
md5/1,
sha256/1,
rand_uniform/1,
is_dns_compliant_name/1,
query_all/4, query_all/5,
query_all_token/4,
make_response/2,
get_items/2,
to_string/1,
encode_list/2,
encode_object/2,
encode_object_list/2,
next_token/2,
filter_undef/1,
uri_parse/1,
http_uri_decode/1,
http_uri_encode/1
]).
-define(MAX_ITEMS, 1000).
-ifdef(OTP_RELEASE).
-if(?OTP_RELEASE >= 23).
sha_mac(K, S) ->
crypto:mac(hmac, sha, K, S).
-else.
sha_mac(K, S) ->
crypto:hmac(sha, K, S).
-endif.
-else.
sha_mac(K, S) ->
crypto:hmac(sha, K, S).
-endif.
-ifdef(OTP_RELEASE).
-if(?OTP_RELEASE >= 23).
sha256_mac(K, S) ->
crypto:mac(hmac, sha256, K, S).
-else.
sha256_mac(K, S) ->
crypto:hmac(sha256, K, S).
-endif.
-else.
sha256_mac(K, S) ->
crypto:hmac(sha256, K, S).
-endif.
sha256(V) ->
crypto:hash(sha256, V).
md5(V) ->
crypto:hash(md5, V).
-ifndef(ERLANG_OTP_VERSION_19).
rand_uniform(N) ->
random:uniform(N).
-else.
rand_uniform(N) ->
rand:uniform(N).
-endif.
-spec is_dns_compliant_name(string()) -> boolean().
is_dns_compliant_name(Name) ->
RegExp = "^(([a-z0-9]|[a-z0-9][a-z0-9\\-]*[a-z0-9])\\.)*([a-z0-9]|[a-z0-9][a-z0-9\\-]*[a-z0-9])$",
case re:run(Name, RegExp) of
nomatch ->
false;
_ ->
true
end.
query_all_token(QueryFun, Config, Action, Params) ->
query_all_token(QueryFun, Config, Action, Params, undefined, []).
query_all_token(QueryFun, Config, Action, Params, Token, Acc) ->
NewParams = case Token of
undefined ->
Params;
_ ->
[{"NextToken", Token} | Params]
end,
case QueryFun(Config, Action, NewParams) of
{ok, Doc} ->
NewToken = next_token("/*/*/NextToken", Doc),
Queried = [Doc | Acc],
case NewToken of
ok ->
{ok, lists:reverse(Queried)};
{paged, NewTokenValue} ->
query_all_token(QueryFun, Config, Action, Params,
NewTokenValue, Queried)
end;
Error ->
Error
end.
query_all(QueryFun, Config, Action, Params) ->
query_all(QueryFun, Config, Action, Params, ?MAX_ITEMS, undefined, []).
query_all(QueryFun, Config, Action, Params, MaxItems) ->
query_all(QueryFun, Config, Action, Params, MaxItems, undefined, []).
query_all(QueryFun, Config, Action, Params, MaxItems, Marker, Acc) ->
MarkerParams = case Marker of
undefined ->
Params;
_ ->
[{"Marker", Marker} | Params]
end,
NewParams = [{"MaxItems", MaxItems} | MarkerParams],
case QueryFun(Config, Action, NewParams) of
{ok, Doc} ->
IsTruncated = erlcloud_xml:get_bool("/*/*/IsTruncated", Doc),
NewMarker = erlcloud_xml:get_text("/*/*/Marker", Doc),
Queried = [Doc | Acc],
case IsTruncated of
true ->
query_all(QueryFun, Config, Action, Params,
MaxItems, NewMarker, Queried);
false ->
{ok, lists:reverse(Queried)}
end;
Error ->
Error
end.
-spec encode_list(string(), [term()]) ->
proplists:proplist().
encode_list(ElementName, Elements) ->
Numbered = lists:zip(lists:seq(1, length(Elements)), Elements),
[{ElementName ++ ".member." ++ integer_to_list(N), Element} ||
{N, Element} <- Numbered].
-spec encode_object(string(), proplists:proplist()) ->
proplists:proplist().
encode_object(ElementName, ElementParameters) ->
lists:map(
fun({Key, Value}) ->
{ElementName ++ "." ++ Key, Value}
end,
ElementParameters
).
-spec encode_object_list(string(), [proplists:proplist()]) ->
proplists:proplist().
encode_object_list(Prefix, ElementParameterList) ->
lists:flatten(lists:foldl(
fun(ElementMap, Acc) ->
[lists:map(
fun({Key, Value}) ->
{Prefix ++ ".member." ++ integer_to_list(length(Acc)+1) ++ "." ++ Key, Value}
end,
ElementMap
) | Acc]
end,
[],
ElementParameterList
)).
make_response(Xml, Result) ->
IsTruncated = erlcloud_xml:get_bool("/*/*/IsTruncated", Xml),
Marker = erlcloud_xml:get_text("/*/*/Marker", Xml),
case IsTruncated of
false ->
{ok, Result};
true ->
{ok, Result, Marker}
end.
get_items(ItemPath, Xmls) when is_list(Xmls) ->
lists:append([get_items(ItemPath, Xml) || Xml <- Xmls]);
get_items(ItemPath, Xml) ->
xmerl_xpath:string(ItemPath, Xml).
-spec to_string(string() | integer()) -> string().
to_string(X) when is_list(X) -> X;
to_string(X) when is_integer(X) -> integer_to_list(X).
-spec next_token(string(), term()) -> ok | {paged, string()}.
next_token(Path, XML) ->
case xmerl_xpath:string(Path, XML) of
[Next] ->
{paged, erlcloud_xml:get_text(Next)};
_ ->
ok
end.
-spec filter_undef(proplists:proplist()) -> proplists:proplist().
filter_undef(List) ->
lists:filter(fun({_Name, Value}) -> Value =/= undefined end, List).
-ifdef(OTP_RELEASE).
-if(?OTP_RELEASE >= 23).
uri_parse(Uri) ->
URIMap = uri_string:parse(Uri),
DefaultScheme = "https",
DefaultPort = 443,
Scheme = list_to_atom(maps:get(scheme, URIMap, DefaultScheme)),
UserInfo = maps:get(userinfo, URIMap, ""),
Host = maps:get(host, URIMap, ""),
Port = maps:get(port, URIMap, DefaultPort),
Path = maps:get(path, URIMap, ""),
Query = maps:get(query, URIMap, ""),
{ok, {Scheme, UserInfo, Host, Port, Path, Query}}.
-else.
uri_parse(Uri) ->
http_uri:parse(Uri).
-endif.
-else.
uri_parse(Uri) ->
http_uri:parse(Uri).
-endif.
-ifdef(OTP_RELEASE).
-if(?OTP_RELEASE >= 23).
http_uri_decode(HexEncodedURI) ->
[{URI, true}] = uri_string:dissect_query(HexEncodedURI),
URI.
-else.
http_uri_decode(HexEncodedURI) ->
http_uri:decode(HexEncodedURI).
-endif.
-else.
http_uri_decode(HexEncodedURI) ->
http_uri:decode(HexEncodedURI).
-endif.
-ifdef(OTP_RELEASE).
-if(?OTP_RELEASE >= 23).
http_uri_encode(URI) ->
uri_string:compose_query([{URI, true}]).
-else.
http_uri_encode(URI) ->
http_uri:encode(URI).
-endif.
-else.
http_uri_encode(URI) ->
http_uri:encode(URI).
-endif.