Commanded v1.0.0 Commanded.Event.Mapper View Source

Map events to/from the structs used for persistence.

Example

Map domain event structs to Commanded.EventStore.EventData structs in preparation for appending to the configured event store:

events = [%ExampleEvent1{}, %ExampleEvent2{}]
event_data = Commanded.Event.Mapper.map_to_event_data(events)

:ok = Commanded.EventStore.append_to_stream("stream-1234", :any_version, event_data)

Link to this section Summary

Types

event()

Functions

map_from_recorded_event(recorded_event)

Map an Commanded.EventStore.RecordedEvent struct to its event data.

map_from_recorded_events(recorded_events)

Map a list of Commanded.EventStore.RecordedEvent structs to their event data.

map_to_event_data(events, fields \\ [])

Map a domain event (or list of events) to an Commanded.EventStore.EventData struct (or list of structs).

Link to this section Types

event()

event() :: struct()

Link to this section Functions

map_from_recorded_event(recorded_event)

map_from_recorded_event(Commanded.EventStore.RecordedEvent.t()) :: event()

Map an Commanded.EventStore.RecordedEvent struct to its event data.

map_from_recorded_events(recorded_events)

map_from_recorded_events([Commanded.EventStore.RecordedEvent.t()]) :: [event()]

Map a list of Commanded.EventStore.RecordedEvent structs to their event data.

map_to_event_data(events, fields \\ [])

map_to_event_data([event()], Keyword.t()) :: [
  Commanded.EventStore.EventData.t()
]

map_to_event_data(struct(), Keyword.t()) :: Commanded.EventStore.EventData.t()

Map a domain event (or list of events) to an Commanded.EventStore.EventData struct (or list of structs).

Optionally, include the causation_id, correlation_id, and metadata associated with the event(s).

Examples

event_data = Commanded.Event.Mapper.map_to_event_data(%ExampleEvent{})

event_data =
  Commanded.Event.Mapper.map_to_event_data(
    [
      %ExampleEvent1{},
      %ExampleEvent2{}
    ],
    causation_id: UUID.uuid4(),
    correlation_id: UUID.uuid4(),
    metadata: %{"user_id" => user_id}
  )