Packages

push_ex

0.1.0-rc1
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 application.ex
Raw

lib/push_ex/application.ex 

defmodule PushEx.Application do

  @moduledoc false



  use Application



  def start(_type, _args) do

    check_config!()



    children =

      [

        pre_endpoint_children(),

        PushExWeb.Endpoint,

        post_endpoint_children()

      ]

      |> List.flatten()



    opts = [strategy: :one_for_one, name: PushEx.Supervisor]

    Supervisor.start_link(children, opts)

  end



  if Mix.env() == :test do

    defp check_config!(), do: nil

  else

    defp check_config!(), do: PushEx.Config.check!()

  end



  def pre_endpoint_children(),

    do: [

      PushEx.Push.ItemProducer,

      PushEx.Push.ItemConsumer,

      PushEx.Instrumentation.Tracker

    ]



  def post_endpoint_children(),

    do: [

      {PushExWeb.PushPresence, [pool_size: presence_pool_size()]}

    ]



  def config_change(changed, _new, removed) do

    PushExWeb.Endpoint.config_change(changed, removed)

    :ok

  end



  def presence_pool_size do

    Application.get_env(:push_ex, PushExWeb.Endpoint)

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

    |> Keyword.get(:pool_size, 1)

  end

end