Packages

commanded

1.3.1
1.4.10 1.4.9 1.4.8 1.4.7 1.4.6 1.4.3 1.4.2 1.4.1 1.4.0 1.4.0-rc.0 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.1 1.0.0 1.0.0-rc.1 1.0.0-rc.0 0.19.1 0.19.0 0.18.1 0.18.0 0.17.5 0.17.4 0.17.3 0.17.2 0.17.1 0.17.0 0.16.0 0.16.0-rc.1 0.16.0-rc.0 0.15.1 0.15.0 0.14.0 0.14.0-rc.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.5 0.8.4 0.8.3 0.8.1 0.8.0 0.7.1 0.6.2 0.6.1 0.6.0 0.4.0 0.3.1 0.3.0 0.2.1 0.2.0 0.1.0

Use Commanded to build your own Elixir applications following the CQRS/ES pattern.

HexDocs

Current section

Files

Jump to
Readme
56 Versions
6 Dependencies
Dependants
Files
Activity
commanded test helpers event_factory.ex
Raw

test/helpers/event_factory.ex 

defmodule Commanded.Helpers.EventFactory do

  @moduledoc false

  alias Commanded.EventStore.RecordedEvent



  def map_to_recorded_events(events, initial_event_number \\ 1, opts \\ []) do

    stream_id = UUID.uuid4()

    causation_id = Keyword.get(opts, :causation_id, UUID.uuid4())

    correlation_id = Keyword.get(opts, :correlation_id, UUID.uuid4())

    metadata = Keyword.get(opts, :metadata, %{})



    fields = [causation_id: causation_id, correlation_id: correlation_id, metadata: metadata]



    events

    |> Commanded.Event.Mapper.map_to_event_data(fields)

    |> Enum.with_index(initial_event_number)

    |> Enum.map(fn {event, index} ->

      %RecordedEvent{

        event_id: UUID.uuid4(),

        event_number: index,

        stream_id: stream_id,

        stream_version: index,

        causation_id: event.causation_id,

        correlation_id: event.correlation_id,

        event_type: event.event_type,

        data: event.data,

        metadata: event.metadata,

        created_at: DateTime.utc_now()

      }

    end)

  end

end