Packages

conduit

0.7.0
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 `text/plain`.



  This plug should be used in an incoming pipeline.



  ## Examples



      plug Conduit.Plug.Parse

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



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body("{}")

      iex>   |> Conduit.Plug.Parse.run(content_type: "application/json")

      iex> message.body

      %{}

      iex> message.content_type

      "application/json"



  """



  @doc """

  Formats the message body based on the content type.

  """

  @default_content_type "text/plain"

  def call(message, next, opts) do

    content_type =

      Keyword.get(opts, :content_type)

      || Map.get(message, :content_type)

      || @default_content_type



    message

    |> Conduit.ContentType.parse(content_type, opts)

    |> next.()

  end

end