Packages

perspective

0.1.0
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.1 0.0.0

An event sourcing library based upon asynchronously generated perspectives

Current section

Files

Jump to
Readme
19 Versions
13 Dependencies
Dependants
Files
Activity
perspective lib perspective reactor state reactor_state.ex
Raw

lib/perspective/reactor/state/reactor_state.ex 

defmodule Perspective.Reactor.State do

  defstruct last_event_processed: nil, data: nil



  def new() do

    %__MODULE__{}

  end



  def from(last_event_processed: last_event_processed, data: data) do

    %__MODULE__{

      last_event_processed: last_event_processed,

      data: data

    }

  end



  def update(old_data, new_data, %{id: id}) do

    old_data

    |> Map.put(:last_event_processed, id)

    |> Map.put(:data, new_data)

  end



  def update(old_data, new_data, _) do

    old_data

    |> Map.put(:last_event_processed, nil)

    |> Map.put(:data, new_data)

  end

end