Packages

conduit

0.10.8
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 created_at.ex
Raw

lib/conduit/plug/created_at.ex 

defmodule Conduit.Plug.CreatedAt do

  use Conduit.Plug.Builder



  @moduledoc """

  Assigns a created_at date to the message.



  A format can be specified. The default is `"{ISO:Extended:Z}"`. The format

  can be anything that `Timex.format/1` accepts. See

  [here](https://hexdocs.pm/timex/formatting.html).



  `:unix_epoch` may also be passed, which will

  set the timestamp to seconds since the UNIX epoch.



  ## Examples



      plug Conduit.Plug.CreatedAt

      plug Conduit.Plug.CreatedAt, format: "{YYYY}-{M}-{D}"

      plug Conduit.Plug.CreatedAt, format: :unix_epoch



      iex> message = Conduit.Plug.CreatedAt.run(%Conduit.Message{}, format: "{ISO:Extended:Z}")

      iex> # e.g. "2016-11-16T03:00:24.575904Z"

      iex> {:ok, %DateTime{}} = Timex.parse(message.created_at, "{ISO:Extended:Z}")

      iex> message = Conduit.Plug.CreatedAt.run(%Conduit.Message{}, format: :unix_epoch)

      iex> # e.g. 1479265596

      iex> is_integer(message.created_at)

      true



  """



  def init(opts) do

    Keyword.get(opts, :format, "{ISO:Extended:Z}")

  end



  @doc """

  Assigns a ISO8601 timestamp to the message.

  """

  def call(message, next, format) do

    message

    |> put_created_at(created_at(format))

    |> next.()

  end



  defp created_at(:unix_epoch), do: Timex.to_unix(Timex.now())

  defp created_at(format), do: Timex.format!(Timex.now(), format)

end