mpesa_elixir

defmodule MpesaElixir do
  use HTTPotion.Base

  alias MpesaElixir.Auth

  @user_agent "mpesa_elixir"

  @doc """
  Create a complete url to work with
  """
  def process_url(url) do
    get_api_url() <> "/mpesa" <> url
  end

  @doc """
  get the appropriate url from the configuration files.
  """
  def get_api_url do
    Application.get_env(:mpesa_elixir, :api_url)
  end

  @doc """
  get  short code from config
  """
  def get_short_code do
    Application.get_env(:mpesa_elixir, :short_code)
  end

  @doc """
    get business code to work with b2b
  """
  def get_b2c_short_code do
    Application.get_env(:mpesa_elixir, :b2c_short_code)
  end

  @doc """
  Get the initiator name from the config file
  """
  @spec get_initiator_name() :: String.t()
  def get_initiator_name do
    Application.get_env(:mpesa_elixir, :initiator_name)
  end

  @doc """
  Attach a user agent parameter for all the requests
  """
  def process_request_headers(headers) do
    headers =
      Keyword.put(headers, :"User-Agent", @user_agent)
      |> Keyword.put(:"Content-Type", "application/json")

    case Auth.generate_token() do
      {:ok, %Auth{access_token: token}, _} ->
        Keyword.put(headers, :Authorization, "Bearer #{token}")

      {:error, %HTTPotion.Response{body: body}} ->
        IO.inspect("Error occured #{body}")
        headers

      {:local_error, reason} ->
        IO.puts("Error :: #{reason}")
        headers
    end
  end

  @doc """
  Convert the body of the response into a %{}
  """
  @spec process_response_body(term) :: HTTPotion.Response.t()
  def process_response_body(body) do
    body |> Poison.decode!()
  end

  @doc """
  Process the response from the API
  """
  def process_response(%HTTPotion.Response{status_code: status_code, body: body} = resp) do
    cond do
      status_code == 200 ->
        {:ok, body, resp}

      true ->
        {:error, resp}
    end
  end

  def process_response(%HTTPotion.ErrorResponse{message: message}) do
    {:local_error, message}
  end
end