Packages

conduit

0.6.2
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 decode.ex
Raw

lib/conduit/plug/decode.ex 

defmodule Conduit.Plug.Decode do

  use Conduit.Plug.Builder

  @moduledoc """

  Decodes the message body based on the content encoding.



  It uses in order of preference:



    1. The content encoding specified for the plug.

    2. The content encoding specified on the message.

    3. The default content encoding `identity`.



  This plug should be used in an incoming pipeline. Generally before

  a `Conduit.Plug.Parse` plug.



  ## Examples



      plug Conduit.Plug.Decode

      plug Conduit.Plug.Decode, content_encoding: "gzip"



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body("{}")

      iex>   |> Conduit.Plug.Decode.run

      iex> message.body

      "{}"

      iex> message.content_encoding

      "identity"



  """



  @doc """

  Formats the message body based on the content encoding.

  """

  @default_content_encoding "identity"

  def call(message, next, opts) do

    content_encoding =

      Keyword.get(opts, :content_encoding)

      || Map.get(message, :content_encoding)

      || @default_content_encoding



    message

    |> Conduit.Encoding.decode(content_encoding, opts)

    |> next.()

  end

end