couchdb_connector

defprotocol Couchdb.Connector.AsMap do
  @moduledoc """
  This protocol provides 'as_map' transformations that take either tuples of
  status code and content (BitString is expected here) as they would be
  returned by the lower level Couchdb Connector modules
  (Couchdb.Connector.Reader and Couchdb.Connector.Writer).
  In case there is a sensible payload (other than errors), the protocol will
  return the payload converted into a Map.
  """
  @dialyzer {:nowarn_function, __protocol__: 1}
  def as_map(json)
end

# Documents are returned as either a tuple containing an :ok and
# the actual document (String) or alternatively an :error together
# with a reason.
defimpl Couchdb.Connector.AsMap, for: Tuple do
  def as_map(tuple) do
    case tuple do
      {:ok, document} -> {:ok, Couchdb.Connector.AsMap.as_map(document)}
      {:error, details} -> {:error, Couchdb.Connector.AsMap.as_map(details)}
    end
  end
end

# The actual document will be given as a BitString.
defimpl Couchdb.Connector.AsMap, for: BitString do
  def as_map(json) do
    case Poison.decode(json) do
      {:ok, decoded} -> decoded
      # poison 1.5 and 2.0 can produce these errors
      {:error, :invalid} ->
        raise RuntimeError, message:
        """
        Document returned by CouchDB is invalid
        json: #{json}
        """
      {:error, {:invalid, token}} ->
        raise RuntimeError, message:
        """
        Document returned by CouchDB is invalid
        token: #{token}
        json: #{json}
        """
      # poison 3.0 can produce these errors
      {:error, :invalid, pos} ->
        raise RuntimeError, message:
        """
        Document returned by CouchDB is invalid
        pos: #{pos}
        json: #{json}
        """
      {:error, {:invalid, token, pos}} ->
        raise RuntimeError, message:
        """
        Document returned by CouchDB is invalid
        token: #{token}
        pos: #{pos}
        json: #{json}
        """
      # catch all
      {:error, any} ->
        raise RuntimeError, message:
        """
        Document returned by CouchDB is invalid
        reason: #{inspect(any)}
        json: #{json}
        """
    end
  end
end

# The headers returned by CouchDB are contained
# in a List of Tuples of Strings
defimpl Couchdb.Connector.AsMap, for: List do
  def as_map(tuples) do
    Enum.into(tuples, %{})
  end
end