Contents

require 'json'
require 'pp'
module SandthornSequelProjection
  class MockEventStore

    def initialize(events = nil)
      Array.wrap(events).each do |event|
        add_event(event)
      end
    end

    def reset(events = [])
      @events = events
    end

    def events
      @events ||= []
    end

    def add_event(event)
      # We have to do these silly things b/c of Sandthorn design errors.
      event[:event_data] = Sandthorn.serialize(event[:event_args])
      events << event
    end

    alias_method :add, :add_event

    def get_events(after_sequence_number: 0, take: 1, **rest)
      unless numeric?(after_sequence_number, take)
        raise ArgumentError, "arguments have to be numbers, received: #{after_sequence_number.inspect} and #{take.inspect}"
      end
      events.select { |event| event[:sequence_number] > after_sequence_number }.take(take).map { |e| e.dup }
    end

    def numeric?(*args)
      args.all? { |arg| arg.is_a?(Numeric) }
    end

    def self.with_data
      self.new(JSON.parse(File.read("./spec/test_data/event_data.json"), symbolize_names: true))
    end

  end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sandthorn_sequel_projection-0.0.4	spec/support/mock_event_store.rb
sandthorn_sequel_projection-0.0.3	spec/support/mock_event_store.rb