Packages

conduit

0.2.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 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.



      plug Conduit.Plug.Decode

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



  """



  @doc """

  Formats the message body based on the content encoding.



  ## Examples



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body("{}")

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

      iex> message.body

      "{}"

      iex> get_meta(message, :content_encoding)

      "identity"

  """

  @default_content_encoding "identity"

  def call(message, opts) do

    content_encoding =

      Keyword.get(opts, :content_encoding)

      || get_meta(message, :content_encoding)

      || @default_content_encoding



    Conduit.Encoding.decode(message, content_encoding, opts)

  end

end