Packages

ex_esdb_gater

0.3.0
0.8.0 0.7.0 0.6.1 0.6.0 0.5.0 0.4.0 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.8 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

ExESDBGater is a API gateway and load balancer for ExESDB Stores

HexDocs

Current section

Files

Jump to
Readme
41 Versions
8 Dependencies
Dependants
Files
Activity
ex_esdb_gater lib ex_esdb_gater pubsub_manager.ex
Raw

lib/ex_esdb_gater/pubsub_manager.ex 

defmodule ExESDBGater.PubSubManager do

  @moduledoc """

  Local override of BCUtils.PubSubManager that ensures unique child spec IDs.

  Also fixes incorrect pid checking logic.

  """



  @pubsub_config [

    adapter: Phoenix.PubSub.PG2,

    pool_size: 1

  ]



  @doc """

  Returns a child spec for Phoenix.PubSub if not already started, otherwise nil.

  Each child spec has a unique ID based on the pubsub name.

  """

  @spec maybe_child_spec(atom()) :: Supervisor.child_spec() | nil

  def maybe_child_spec(nil), do: nil



  def maybe_child_spec(pubsub_name) when is_atom(pubsub_name) do

    case Process.whereis(pubsub_name) do

      pid when is_pid(pid) ->

        if Process.alive?(pid), do: nil, else: start_pubsub(pubsub_name)



      _ ->

        start_pubsub(pubsub_name)

    end

  end



  defp start_pubsub(pubsub_name) do

    config = Keyword.merge(@pubsub_config, name: pubsub_name)

    Supervisor.child_spec({Phoenix.PubSub, config}, id: :"#{pubsub_name}_pubsub")

  end

end