Packages

push_ex

0.0.1-rc3
2.2.0 2.1.0 2.0.0 1.2.0 1.1.0 1.0.2 1.0.1-rc3 1.0.1-rc2 1.0.1-rc1 1.0.0-rc9 1.0.0-rc8 1.0.0-rc7 1.0.0-rc6 1.0.0-rc5 1.0.0-rc4 1.0.0-rc3 1.0.0-rc2 1.0.0-rc15 1.0.0-rc14 1.0.0-rc13 1.0.0-rc12 1.0.0-rc11 1.0.0-rc10 1.0.0-rc1 0.2.0-rc2 0.2.0-rc1 0.1.0-rc1 0.0.1-rc4 0.0.1-rc3 0.0.1-rc2 0.0.1-rc

PushEx is an implementation of Phoenix websockets/channels which handles best practices of running websockets for you, but allows your business logic to be specified through simple behaviour modules.

HexDocs

Current section

Files

Jump to
Readme
31 Versions
7 Dependencies
Dependants
Files
Activity
push_ex lib push_ex instrumentation push.ex
Raw

lib/push_ex/instrumentation/push.ex 

defmodule PushEx.Instrumentation.Push do

  alias PushEx.Push



  defmodule Behaviour do

    @callback requested(%Push{}) :: any

    @callback delivered(%Push{}) :: any

    @callback api_requested() :: any

    @callback api_processed() :: any

  end



  @behaviour Behaviour



  def requested(push = %Push{}) do

    listeners()

    |> Enum.each(& &1.requested(push))

  end



  def delivered(push = %Push{}) do

    listeners()

    |> Enum.each(& &1.delivered(push))

  end



  def api_requested() do

    listeners()

    |> Enum.each(& &1.api_requested())

  end



  def api_processed() do

    listeners()

    |> Enum.each(& &1.api_processed())

  end



  defp listeners() do

    Application.get_env(:push_ex, PushEx.Instrumentation, [])

    |> Keyword.get(:push_listeners, [])

  end

end