Packages

extreme

0.6.1
1.1.4 1.1.3 1.1.2 1.1.1 1.1.1-rc01 1.1.0 1.1.0-rc9 1.1.0-rc8 1.1.0-rc7 1.1.0-rc6 1.1.0-rc5 1.1.0-rc4 1.1.0-rc3 1.1.0-rc2 1.1.0-rc1 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.13.4 0.13.3 0.13.2 0.13.1 0.13.0 0.12.1 0.12.0 0.11.0 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.2 0.9.1 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1

Elixir TCP client for EventStore.

HexDocs

Current section

Files

Jump to
Readme
55 Versions
4 Dependencies
Dependants
Files
Activity
extreme lib listener.ex
Raw

lib/listener.ex 

defmodule Extreme.Listener do

  defmacro __using__(_) do

    quote do

      use GenServer



      def start_link(event_store, stream_name, opts \\ []), 

        do: GenServer.start_link __MODULE__, {event_store, stream_name}, opts

      

      def init({event_store, stream_name}) do

        state = %{ event_store: event_store, last_event: nil, subscription_ref: nil, stream_name: stream_name }

        GenServer.cast self, :subscribe

        {:ok, state}

      end



	  def handle_cast(:subscribe, state) do

	    last_event = get_last_event(state.stream_name)

	    {:ok, subscription} = Extreme.read_and_stay_subscribed state.event_store, self, state.stream_name, last_event + 1

	    ref = Process.monitor subscription

	    {:noreply, %{state|subscription_ref: ref, last_event: last_event}}

	  end

	  

	  def handle_info({:DOWN, ref, :process, _pid, _reason}, %{subscription_ref: ref} = state) do

	    GenServer.cast self, :subscribe

	    {:noreply, state}

	  end

      def handle_info({:on_event, push}, state) do

        {:ok, event_number} = process_push(push, state.stream_name)

        {:noreply, %{state|last_event: event_number}}

      end

      def handle_info(_msg, state), do: {:noreply, state}

    end

  end

end