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 encode.ex
Raw

lib/conduit/plug/encode.ex 

defmodule Conduit.Plug.Encode do

  use Conduit.Plug.Builder

  @moduledoc """

  Encodes 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 outgoing pipeline. Generally after

  a `Conduit.Plug.Format` plug.



  ## Examples



      plug Conduit.Plug.Encode

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



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body("{}")

      iex>   |> Conduit.Plug.Encode.run

      iex> message.body

      "{}"

      iex> message.content_encoding

      "identity"



  """



  @doc """

  Encodes 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.encode(content_encoding, opts)

    |> next.()

  end

end