Packages

walex

4.0.0
4.8.0 4.7.1 4.7.0 4.6.0 4.5.0 4.4.0 4.3.0 4.2.0 4.1.0 4.0.0 3.8.0 3.7.0 3.6.0 3.5.0 3.4.0 3.2.0 3.1.2 3.1.0 3.0.6 3.0.5 3.0.4 3.0.2 3.0.0 2.3.2 2.3.0 2.2.0 2.1.1 2.1.0 2.0.0 1.0.1 1.0.0 0.9.0 0.8.2 0.8.1 0.8.0 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

Listen to change events on your Postgres tables then perform callback-like actions with the data.

HexDocs

Current section

Files

Jump to
Readme
46 Versions
4 Dependencies
Dependants
Files
Activity
walex lib walex events events.ex
Raw

lib/walex/events/events.ex 

defmodule WalEx.Events do

  @moduledoc """

  Process events

  """



  use GenServer



  alias WalEx.{Events, Config}

  alias Config.Registry

  alias Events.EventModules



  def start_link(opts) do

    name =

      opts

      |> Keyword.get(:app_name)

      |> registry_name



    GenServer.start_link(__MODULE__, opts, name: name)

  end



  def process(txn, app_name) do

    name = registry_name(app_name)



    GenServer.call(name, {:process, txn, app_name}, :infinity)

  end



  defp registry_name(app_name) do

    Registry.set_name(:set_gen_server, __MODULE__, app_name)

  end



  @impl true

  def init(_) do

    {:ok, %{}}

  end



  @impl true

  def handle_call({:process, txn, app_name}, _from, state) do

    process_destinations(txn, app_name)



    {:reply, :ok, state}

  end



  defp process_destinations(txn, app_name) do

    # TODO: EventModules should be dynamic (only if modules exist)

    EventModules.process(txn, app_name)

  end

end