durango

defmodule Durango.Repo.Client do

  def headers(repo) do
      Durango.Repo.Auth.headers!(repo) ++ [
      "Accept": "application/json",
      "Content-Type": "application/json; charset=utf-8",
    ]
  end

  def url(repo, path, query) do
    uri = repo.__config__()[:uri]
    query = Durango.Api.Request.render_querystring(query)
    uri
    |> Map.put(:path, path)
    |> Map.put(:query, query)
    |> to_string
  end

  def send_request(repo, method, path, body \\ "", query \\ nil) do
    HTTPoison.request(method, url(repo, path, query), body, headers(repo))
    |> case do
      {:error, _} = err ->
        err
      {:ok, %{status_code: code, body: body}} when code in 200..202 ->
        Jason.decode(body)
      {:ok, %{body: body}} ->
        case Jason.decode(body) do
          {:ok, json} ->
            {:error, json}
          _ ->
            {:error, :invalid_api_response_body}
        end
    end
  end
  def send_request!(repo, method, path, body \\ "", query \\ nil) do
    case HTTPoison.request(method, url(repo, path, query), body, headers(repo)) do
      {:ok, %{status_code: code, body: body}} when code in 200..202 ->
        Jason.decode(body)
      {:ok, %{status_code: code}} ->
        # IO.puts("Bad Response #{inspect resp}", :stderr)
        raise "Durango.Repo.Client bad response #{code} for connection to #{inspect repo.__config__(:name)}"
      {:error, %HTTPoison.Error{reason: reason}} ->
        raise "Durango.Repo.Client bad response #{reason} for connection to #{inspect repo.__config__(:name)}"
    end
  end

end