Contents

module EventSourcery
  module EventStore
    class EventBuilder
      def initialize(event_type_serializer:)
        @event_type_serializer = event_type_serializer
      end

      def build(**event_data)
        type = event_data.fetch(:type)
        klass = event_type_serializer.deserialize(type)
        upcast(klass.new(**event_data))
      end

      private

      attr_reader :event_type_serializer

      def upcast(event)
        event.class.upcast(event)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
event_sourcery-1.0.0	lib/event_sourcery/event_store/event_builder.rb
event_sourcery-0.24.0	lib/event_sourcery/event_store/event_builder.rb
event_sourcery-0.23.1	lib/event_sourcery/event_store/event_builder.rb