fintex

defmodule FinTex.Data.AccountHandler do
  @moduledoc false

  alias FinTex.Command.Sequencer
  alias FinTex.Model.Account


  @spec update_accounts({Sequencer.t, %{String.t => Account.t}}, module) :: {Sequencer.t, %{String.t => Account.t}}
  def update_accounts {seq, accounts}, module do
    {:module, module} = Code.ensure_loaded(module)
    cond do
      function_exported?(module, :update_account,  2) ->
        {acc, seq} = accounts
        |> Map.to_list
        |> Stream.filter(fn entry -> apply(module, :has_capability?, [{seq, [entry] |> Map.new}]) end)
        |> Enum.map_reduce(seq, fn({key, acc}, seq) ->
          {seq, account} = apply(module, :update_account, [seq, acc])
          {{key, account}, seq}
        end)
        {seq, Map.merge(accounts, acc |> Map.new)}
      function_exported?(module, :update_accounts, 1) ->
        case apply(module, :has_capability?, [{seq, accounts}]) do
          true  -> apply(module, :update_accounts, [{seq, accounts}])
          false -> {seq, accounts}
        end
    end
  end


  @spec to_accounts_map(Enumerable.t) :: %{String.t => Account.t}
  def to_accounts_map(accounts) do
    accounts |> Map.new(fn account -> {Account.key(account), account} end)
  end


  @spec to_list(%{String.t => Account.t}) :: Enumerable.t
  def to_list(accounts) do
    accounts
    |> Map.values
    |> Enum.sort(fn account1, account2 ->
        account1 |> Account.key |> String.length <= account2 |> Account.key |> String.length &&
        account1 |> Account.key <= account2 |> Account.key
      end)
  end


  @spec find_account(%{String.t => Account.t}, Account.t) :: Account.t | nil
  def find_account(accounts, account = %Account{}) do
    accounts
    |> Enum.reduce(nil, fn({_, value}, acc) -> find(value, account, acc) end)
  end


  defp find(
    %Account{iban: iban} = account,
    %Account{iban: iban},
    _
  ) when iban != nil
  do
    account
  end


  defp find(
    %Account{account_number: account_number, subaccount_id: subaccount_id} = account,
    %Account{account_number: account_number, subaccount_id: subaccount_id},
    _
  ) when account_number != nil
  do
    account
  end


  defp find(_, _, acc), do: acc
end