class RubyEventStore::ROM::Memory::Relations::Events

Public Instance Methods

by_pk(id) click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 33
def by_pk(id)
  restrict(id: id)
end
create_changeset(tuples) click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 16
def create_changeset(tuples)
  events.changeset(Changesets::CreateEvents, tuples)
end
exist?() click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 37
def exist?
  one?
end
for_stream_entries(_assoc, stream_entries) click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 29
def for_stream_entries(_assoc, stream_entries)
  restrict(id: stream_entries.map { |e| e[:event_id] })
end
insert(tuple) click to toggle source
Calls superclass method
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 24
def insert(tuple)
  verify_uniquness!(tuple)
  super
end
pluck(name) click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 41
def pluck(name)
  map { |e| e[name] }
end
update_changeset(tuples) click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 20
def update_changeset(tuples)
  events.changeset(Changesets::UpdateEvents, tuples)
end

Private Instance Methods

verify_uniquness!(tuple) click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 47
def verify_uniquness!(tuple)
  return unless by_pk(tuple[:id]).exist?

  raise TupleUniquenessError.for_event_id(tuple[:id])
end