defmodule Money.ExchangeRates do
@moduledoc """
Implements a behaviour and functions to retrieve exchange rates
from an exchange rate service.
Configuration for the exchange rate service is defined
in a `Money.ExchangeRates.Config` struct. A default
configuration is returned by `Money.ExchangeRates.default_config/0`.
The default configuration is:
config :ex_money,
exchange_rate_service: false,
exchange_rates_retrieve_every: 300_000,
api_module: Money.ExchangeRates.OpenExchangeRates,
callback_module: Money.ExchangeRates.Callback,
preload_historic_rates: nil
log_failure: :warn,
log_info: :info,
log_success: nil
These keys are are defined as follows:
* `:exchange_rate_service` is a boolean that determines whether to
automatically start the exchange rate retrieval service.
The default it false.
* `:exchange_rates_retrieve_every` defines how often the exchange
rates are retrieved in milliseconds. The default is 5 minutes
(300,000 milliseconds)
* `:api_module` identifies the module that does the retrieval of
exchange rates. This is any module that implements the
`Money.ExchangeRates` behaviour. The default is
`Money.ExchangeRates.OpenExchangeRates`
* `:callback_module` defines a module that follows the
Money.ExchangeRates.Callback behaviour whereby the function
`rates_retrieved/2` is invoked after every successful retrieval
of exchange rates. The default is `Money.ExchangeRates.Callback`.
* `:preload_historic_rates` defines a date or a date range,
that will be requested when the exchange rate service starts up.
The date or date range should be specified as either a `Date.t`
or a `Date.Range.t` or a tuple of `{Date.t, Date.t}` representing
the `from` and `to` dates for the rates to be retrieved. The
default is `nil` meaning no historic rates are preloaded.
* `:log_failure` defines the log level at which api retrieval
errors are logged. The default is `:warn`
* `:log_success` defines the log level at which successful api
retrieval notifications are logged. The default is `nil` which
means no logging.
* `:log_info` defines the log level at which service startup messages
are logged. The default is `:info`.
* `:retriever_options` is available for exchange rate retriever
module developers as a place to add retriever-specific configuration
information. This information should be added in the `init/1`
callback in the retriever module. See `Money.ExchangeRates.OpenExchangeRates.init/1`
for an example.
Keys can also be configured to retrieve values from environment
variables. This lookup is done at runtime to facilitate deployment
strategies. If the value of a configuration key is
`{:system, "some_string"}` then "some_string" is interpreted as
an environment variable name which is passed to System.get_env/2.
An example configuration might be:
config :ex_money,
exchange_rate_service: {:system, "RATE_SERVICE"},
exchange_rates_retrieve_every: {:system, "RETRIEVE_EVERY"},
## Open Exchange Rates
If you plan to use the provided Open Exchange Rates module
to retrieve exchange rates then you should also provide the additional
configuration key for `app_id`:
config :ex_money,
open_exchange_rates_app_id: "your_app_id"
or configure it via environment variable:
config :ex_money,
open_exchange_rates_app_id: {:system, "OPEN_EXCHANGE_RATES_APP_ID"}
The default exchange rate retrieval module is provided in
`Money.ExchangeRates.OpenExchangeRates` which can be used
as a example to implement your own retrieval module for
other services.
## Managing the configuration at runtime
During exchange rate service startup, the function `init/1` is called
on the configuration exchange rate retrieval module. This module is
expected to return an updated configuration allowing a developer to
customise how the configuration is to be managed. See the implementation
at `Money.ExchangeRates.OpenExchangeRates.init/1` for an example.
"""
@type t :: %{Money.currency_code() => Decimal.t()}
@doc """
Invoked to return the latest exchange rates from the configured
exchange rate retrieval service.
* `config` is an `%Money.ExchangeRataes.Config{}` struct
Returns `{:ok, map_of_rates}` or `{:error, reason}`
"""
@callback get_latest_rates(config :: Money.ExchangeRates.Config.t()) ::
{:ok, map()} | {:error, binary}
@doc """
Invoked to return the historic exchange rates from the configured
exchange rate retrieval service.
* `config` is an `%Money.ExchangeRataes.Config{}` struct
Returns `{:ok, map_of_historic_rates}` or `{:error, reason}`
"""
@callback get_historic_rates(Date.t(), config :: Money.ExchangeRates.Config.t()) ::
{:ok, map()} | {:error, binary}
@doc """
Decode the body returned from the API request and
return a map of rates. THe map of rates must have
an upcased atom key representing an ISO 4217 currency
code and the value must be a Decimal number.
"""
@callback decode_rates(any) :: map()
@doc """
Given the default configuration, returns an updated configuration at runtime
during exchange rates service startup.
This callback is optional. If the callback is not defined, the default
configuration returned by `Money.ExchangeRates.default_config/0` is used.
* `config` is the configuration returned by `Money.ExchangeRates.default_config/0`
The callback is expected to return a `%Money.ExchangeRates.Config.t()` struct
which may have been updated. The configuration key `:retriever_options` is
available for any service-specific configuration.
"""
@callback init(config :: Money.ExchangeRates.Config.t()) :: Money.ExchangeRates.Config.t()
@optional_callbacks init: 1
require Logger
import Money.ExchangeRates.Cache
alias Money.ExchangeRates.Retriever
@default_retrieval_interval :never
@default_callback_module Money.ExchangeRates.Callback
@default_api_module Money.ExchangeRates.OpenExchangeRates
@default_cache_module Money.ExchangeRates.Cache.Ets
@doc """
Returns the configuration for `ex_money` including the
configuration merged from the configured exchange rates
retriever module.
"""
def config do
api_module = default_config().api_module
if function_exported?(api_module, :init, 1) do
api_module.init(default_config())
else
default_config()
end
end
# Defines the configuration for the exchange rates mechanism.
defmodule Config do
@type t :: %__MODULE__{
retrieve_every: non_neg_integer | nil,
api_module: module() | nil,
callback_module: module() | nil,
log_levels: map(),
preload_historic_rates: Date.t() | Date.Range.t() | {Date.t(), Date.t()} | nil,
retriever_options: map() | nil,
cache_module: module() | nil,
verify_peer: boolean()
}
defstruct retrieve_every: nil,
api_module: nil,
callback_module: nil,
log_levels: %{},
preload_historic_rates: nil,
retriever_options: nil,
cache_module: nil,
verify_peer: true
end
@doc """
Returns the default configuration for the exchange rates retriever.
"""
def default_config do
%Config{
api_module: Money.get_env(:api_module, @default_api_module, :module),
callback_module: Money.get_env(:callback_module, @default_callback_module, :module),
preload_historic_rates: Money.get_env(:preload_historic_rates, nil),
cache_module: Money.get_env(:exchange_rates_cache_module, @default_cache_module, :module),
retrieve_every:
Money.get_env(:exchange_rates_retrieve_every, @default_retrieval_interval, :maybe_integer),
log_levels: %{
success: Money.get_env(:log_success, nil),
failure: Money.get_env(:log_failure, :warning),
info: Money.get_env(:log_info, :info)
},
verify_peer: Money.get_env(:verify_peer, true, :boolean)
}
end
@doc """
Return the latest exchange rates.
Returns:
* `{:ok, rates}` if exchange rates are successfully retrieved. `rates` is a map of
exchange rates.
* `{:error, reason}` if no exchange rates can be returned.
This function looks up the latest exchange rates in a an ETS table
called `:exchange_rates`. The actual retrieval of rates is requested
through `Money.ExchangeRates.Retriever.latest_rates/0`.
"""
@spec latest_rates() :: {:ok, map()} | {:error, {Exception.t(), binary}}
def latest_rates do
try do
case cache().latest_rates() do
{:ok, rates} -> {:ok, rates}
{:error, _} -> Retriever.latest_rates()
end
catch
:exit, {:noproc, {GenServer, :call, [Money.ExchangeRates.Retriever, :config, _timeout]}} ->
{:error, no_retriever_running_error()}
end
end
@doc """
Return historic exchange rates.
* `date` is a date returned by `Date.new/3` or any struct with the
elements `:year`, `:month` and `:day`.
Returns:
* `{:ok, rates}` if exchange rates are successfully retrieved. `rates` is a map of
exchange rates.
* `{:error, reason}` if no exchange rates can be returned.
**Note;** all dates are expected to be in the Calendar.ISO calendar
This function looks up the historic exchange rates in a an ETS table
called `:exchange_rates`. The actual retrieval of rates is requested
through `Money.ExchangeRates.Retriever.historic_rates/1`.
"""
@spec historic_rates(Date.t()) :: {:ok, map()} | {:error, {Exception.t(), binary}}
def historic_rates(date) do
try do
case cache().historic_rates(date) do
{:ok, rates} -> {:ok, rates}
{:error, _} -> Retriever.historic_rates(date)
end
catch
:exit, {:noproc, {GenServer, :call, [Money.ExchangeRates.Retriever, :config, _timeout]}} ->
{:error, no_retriever_running_error()}
end
end
@doc """
Returns `true` if the latest exchange rates are available
and false otherwise.
"""
@spec latest_rates_available?() :: boolean
def latest_rates_available? do
try do
case cache().latest_rates() do
{:ok, _rates} -> true
_ -> false
end
catch
:exit, {:noproc, {GenServer, :call, [Money.ExchangeRates.Retriever, :config, _timeout]}} ->
false
end
end
@doc """
Return the timestamp of the last successful retrieval of exchange rates or
`{:error, reason}` if no timestamp is known.
## Example
Money.ExchangeRates.last_updated
#> {:ok,
%DateTime{calendar: Calendar.ISO, day: 20, hour: 12, microsecond: {731942, 6},
minute: 36, month: 11, second: 6, std_offset: 0, time_zone: "Etc/UTC",
utc_offset: 0, year: 2016, zone_abbr: "UTC"}}
"""
@spec last_updated() :: {:ok, DateTime.t()} | {:error, {Exception.t(), binary}}
def last_updated do
try do
cache().last_updated()
catch
:exit, {:noproc, {GenServer, :call, [Money.ExchangeRates.Retriever, :config, _timeout]}} ->
{:error, no_retriever_running_error()}
end
end
defp no_retriever_running_error do
{Money.ExchangeRateError, "Exchange Rates retrieval process is not running"}
end
end
