%% WARNING: DO NOT EDIT, AUTO-GENERATED CODE! %% See https://github.com/aws-beam/aws-codegen for more details. %% @doc With License Manager, you can create user-based subscriptions to %% utilize licensed software with a per user subscription fee on Amazon EC2 %% instances. -module(aws_license_manager_user_subscriptions). -export([associate_user/2, associate_user/3, deregister_identity_provider/2, deregister_identity_provider/3, disassociate_user/2, disassociate_user/3, list_identity_providers/2, list_identity_providers/3, list_instances/2, list_instances/3, list_product_subscriptions/2, list_product_subscriptions/3, list_user_associations/2, list_user_associations/3, register_identity_provider/2, register_identity_provider/3, start_product_subscription/2, start_product_subscription/3, stop_product_subscription/2, stop_product_subscription/3, update_identity_provider_settings/2, update_identity_provider_settings/3]). -include_lib("hackney/include/hackney_lib.hrl"). %%==================================================================== %% API %%==================================================================== %% @doc Associates the user to an EC2 instance to utilize user-based %% subscriptions. %% %% Your estimated bill for charges on the number of users and related costs %% will take 48 hours to appear for billing periods that haven't closed %% (marked as Pending billing status) in Amazon Web Services Billing. For %% more information, see Viewing your monthly charges in the Amazon Web %% Services Billing User Guide. associate_user(Client, Input) -> associate_user(Client, Input, []). associate_user(Client, Input0, Options0) -> Method = post, Path = ["/user/AssociateUser"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Deregisters the identity provider from providing user-based %% subscriptions. deregister_identity_provider(Client, Input) -> deregister_identity_provider(Client, Input, []). deregister_identity_provider(Client, Input0, Options0) -> Method = post, Path = ["/identity-provider/DeregisterIdentityProvider"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Disassociates the user from an EC2 instance providing user-based %% subscriptions. disassociate_user(Client, Input) -> disassociate_user(Client, Input, []). disassociate_user(Client, Input0, Options0) -> Method = post, Path = ["/user/DisassociateUser"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Lists the identity providers for user-based subscriptions. list_identity_providers(Client, Input) -> list_identity_providers(Client, Input, []). list_identity_providers(Client, Input0, Options0) -> Method = post, Path = ["/identity-provider/ListIdentityProviders"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Lists the EC2 instances providing user-based subscriptions. list_instances(Client, Input) -> list_instances(Client, Input, []). list_instances(Client, Input0, Options0) -> Method = post, Path = ["/instance/ListInstances"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Lists the user-based subscription products available from an identity %% provider. list_product_subscriptions(Client, Input) -> list_product_subscriptions(Client, Input, []). list_product_subscriptions(Client, Input0, Options0) -> Method = post, Path = ["/user/ListProductSubscriptions"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Lists user associations for an identity provider. list_user_associations(Client, Input) -> list_user_associations(Client, Input, []). list_user_associations(Client, Input0, Options0) -> Method = post, Path = ["/user/ListUserAssociations"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Registers an identity provider for user-based subscriptions. register_identity_provider(Client, Input) -> register_identity_provider(Client, Input, []). register_identity_provider(Client, Input0, Options0) -> Method = post, Path = ["/identity-provider/RegisterIdentityProvider"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Starts a product subscription for a user with the specified identity %% provider. %% %% Your estimated bill for charges on the number of users and related costs %% will take 48 hours to appear for billing periods that haven't closed %% (marked as Pending billing status) in Amazon Web Services Billing. For %% more information, see Viewing your monthly charges in the Amazon Web %% Services Billing User Guide. start_product_subscription(Client, Input) -> start_product_subscription(Client, Input, []). start_product_subscription(Client, Input0, Options0) -> Method = post, Path = ["/user/StartProductSubscription"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Stops a product subscription for a user with the specified identity %% provider. stop_product_subscription(Client, Input) -> stop_product_subscription(Client, Input, []). stop_product_subscription(Client, Input0, Options0) -> Method = post, Path = ["/user/StopProductSubscription"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %% @doc Updates additional product configuration settings for the registered %% identity provider. update_identity_provider_settings(Client, Input) -> update_identity_provider_settings(Client, Input, []). update_identity_provider_settings(Client, Input0, Options0) -> Method = post, Path = ["/identity-provider/UpdateIdentityProviderSettings"], SuccessStatusCode = 200, Options = [{send_body_as_binary, false}, {receive_body_as_binary, false} | Options0], Headers = [], Input1 = Input0, CustomHeaders = [], Input2 = Input1, Query_ = [], Input = Input2, request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode). %%==================================================================== %% Internal functions %%==================================================================== -spec request(aws_client:aws_client(), atom(), iolist(), list(), list(), map() | undefined, list(), pos_integer() | undefined) -> {ok, {integer(), list()}} | {ok, Result, {integer(), list(), hackney:client()}} | {error, Error, {integer(), list(), hackney:client()}} | {error, term()} when Result :: map(), Error :: map(). request(Client, Method, Path, Query, Headers0, Input, Options, SuccessStatusCode) -> RequestFun = fun() -> do_request(Client, Method, Path, Query, Headers0, Input, Options, SuccessStatusCode) end, aws_request:request(RequestFun, Options). do_request(Client, Method, Path, Query, Headers0, Input, Options, SuccessStatusCode) -> Client1 = Client#{service => <<"license-manager-user-subscriptions">>}, Host = build_host(<<"license-manager-user-subscriptions">>, Client1), URL0 = build_url(Host, Path, Client1), URL = aws_request:add_query(URL0, Query), AdditionalHeaders = [ {<<"Host">>, Host} , {<<"Content-Type">>, <<"application/x-amz-json-1.1">>} ], Headers1 = aws_request:add_headers(AdditionalHeaders, Headers0), Payload = case proplists:get_value(send_body_as_binary, Options) of true -> maps:get(<<"Body">>, Input, <<"">>); false -> encode_payload(Input) end, MethodBin = aws_request:method_to_binary(Method), SignedHeaders = aws_request:sign_request(Client1, MethodBin, URL, Headers1, Payload), Response = hackney:request(Method, URL, SignedHeaders, Payload, Options), DecodeBody = not proplists:get_value(receive_body_as_binary, Options), handle_response(Response, SuccessStatusCode, DecodeBody). handle_response({ok, StatusCode, ResponseHeaders}, SuccessStatusCode, _DecodeBody) when StatusCode =:= 200; StatusCode =:= 202; StatusCode =:= 204; StatusCode =:= 206; StatusCode =:= SuccessStatusCode -> {ok, {StatusCode, ResponseHeaders}}; handle_response({ok, StatusCode, ResponseHeaders}, _, _DecodeBody) -> {error, {StatusCode, ResponseHeaders}}; handle_response({ok, StatusCode, ResponseHeaders, Client}, SuccessStatusCode, DecodeBody) when StatusCode =:= 200; StatusCode =:= 202; StatusCode =:= 204; StatusCode =:= 206; StatusCode =:= SuccessStatusCode -> case hackney:body(Client) of {ok, <<>>} when StatusCode =:= 200; StatusCode =:= SuccessStatusCode -> {ok, #{}, {StatusCode, ResponseHeaders, Client}}; {ok, Body} -> Result = case DecodeBody of true -> jsx:decode(Body); false -> #{<<"Body">> => Body} end, {ok, Result, {StatusCode, ResponseHeaders, Client}} end; handle_response({ok, StatusCode, ResponseHeaders, Client}, _, _DecodeBody) -> {ok, Body} = hackney:body(Client), Error = jsx:decode(Body), {error, Error, {StatusCode, ResponseHeaders, Client}}; handle_response({error, Reason}, _, _DecodeBody) -> {error, Reason}. build_host(_EndpointPrefix, #{region := <<"local">>, endpoint := Endpoint}) -> Endpoint; build_host(_EndpointPrefix, #{region := <<"local">>}) -> <<"localhost">>; build_host(EndpointPrefix, #{region := Region, endpoint := Endpoint}) -> aws_util:binary_join([EndpointPrefix, Region, Endpoint], <<".">>). build_url(Host, Path0, Client) -> Proto = maps:get(proto, Client), Path = erlang:iolist_to_binary(Path0), Port = maps:get(port, Client), aws_util:binary_join([Proto, <<"://">>, Host, <<":">>, Port, Path], <<"">>). -spec encode_payload(undefined | map()) -> binary(). encode_payload(undefined) -> <<>>; encode_payload(Input) -> jsx:encode(Input).