1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48
defmodule ExOvh.Ovh.Openstack.Request do
alias ExOvh.Ovh.Openstack.Auth
alias ExOvh.Ovh.OvhApi.Cache, as: ClientCache
alias ExOvh.Ovh.Defaults
############################
# Public
############################
@spec request(query :: ExOvh.Client.raw_query_t)
:: {:ok, map} | {:error, map}
def request({method, uri, params} = query), do: request(ExOvh, {method, uri, params} = query)
@spec request(client :: atom, query :: ExOvh.Client.query_t)
:: {:ok, ExOvh.Client.response_t} | {:error, ExOvh.Client.response_t}
def request(client, {method, uri, params} = query) do
config = config(client)
{method, uri, options} = Auth.prepare_request(client, query)
resp = HTTPotion.request(method, uri, options)
resp =
%{
body: resp.body |> Poison.decode!(),
headers: resp.headers,
status_code: resp.status_code
}
if resp.status_code >= 100 and resp.status_code < 300 do
{:ok, resp}
else
{:error, resp}
end
end
############################
# Private
############################
defp config(), do: ClientCache.get_config(ExOvh)
defp config(client), do: ClientCache.get_config(client)
defp endpoint(config), do: Defaults.endpoints()[config[:endpoint]]
defp api_version(config), do: config[:api_version]
end