Packages

walex

4.7.1
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 event_modules.ex
Raw

lib/walex/events/event_modules.ex 

defmodule WalEx.Events.EventModules do

  @moduledoc """

  Process events (call modules containing process functions)

  """

  use GenServer



  alias WalEx.Config.Registry



  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

    Process.flag(:message_queue_data, :off_heap)

    {:ok, %{}}

  end



  @impl true

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

    server

    |> WalEx.Config.get_configs(:modules)

    |> process_events(txn)



    {:reply, :ok, state}

  end



  defp process_events(nil, %{changes: [], commit_timestamp: _}), do: nil



  defp process_events(modules, txn) when is_list(modules) do

    process_modules(modules, txn)

  end



  defp process_modules(modules, txn) do

    functions = ~w(process_all process_insert process_update process_delete)a



    Enum.each(modules, &process_module(&1, functions, txn))

  end



  defp process_module(module_name, functions, txn) do

    Enum.each(functions, &apply_process_macro(&1, module_name, txn))

  end



  defp apply_process_macro(function, module, txn) do

    if Keyword.has_key?(module.__info__(:functions), function) do

      apply(module, function, [txn])

    end

  end

end