Packages

conduit

0.1.1
0.12.10 0.12.9 0.12.8 0.12.7 0.12.6 0.12.5 0.12.4 0.12.3 0.12.2 0.12.1 0.12.0 0.11.0 0.10.8 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Message queue framework, with support for middleware and multiple adapters.

HexDocs

Current section

Files

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
conduit lib conduit plug parse.ex
Raw

lib/conduit/plug/parse.ex 

defmodule Conduit.Plug.Parse do

  use Conduit.Plug.Builder

  @moduledoc """

  Parses the message body based on the content type.



  It uses in order of preference:



    1. The content type specified for the plug.

    2. The content type specified on the message.

    3. The default content type `application/json`.



  This plug should be used in an incoming pipeline.



      plug Conduit.Plug.Parse

      plug Conduit.Plug.Parse, content_type: "application/xml"



  """



  @doc """

  Formats the message body based on the content type.



  ## Examples



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body("{}")

      iex>   |> Conduit.Plug.Parse.call([])

      iex> message.body

      %{}

      iex> get_meta(message, :content_type)

      "application/json"

  """

  @default_content_type "application/json"

  def call(message, opts) do

    content_type =

      Keyword.get(opts, :content_type)

      || get_meta(message, :content_type)

      || @default_content_type



    Conduit.ContentType.parse(message, content_type, opts)

  end

end