Class: RailsEventStore::Repositories::EventRepository
- Inherits:
-
Object
- Object
- RailsEventStore::Repositories::EventRepository
- Defined in:
- lib/rails_event_store/repositories/event_repository.rb
Instance Attribute Summary collapse
-
#adapter ⇒ Object
readonly
Returns the value of attribute adapter.
Instance Method Summary collapse
- #create(event, stream_name) ⇒ Object
- #delete_stream(stream_name) ⇒ Object
- #get_all_events ⇒ Object
- #has_event?(event_id) ⇒ Boolean
-
#initialize ⇒ EventRepository
constructor
A new instance of EventRepository.
- #last_stream_event(stream_name) ⇒ Object
- #read_all_streams_backward(start_event_id, count) ⇒ Object
- #read_all_streams_forward(start_event_id, count) ⇒ Object
- #read_events_backward(stream_name, start_event_id, count) ⇒ Object
- #read_events_forward(stream_name, start_event_id, count) ⇒ Object
- #read_stream_events_backward(stream_name) ⇒ Object
- #read_stream_events_forward(stream_name) ⇒ Object
Constructor Details
#initialize ⇒ EventRepository
Returns a new instance of EventRepository.
5 6 7 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 5 def initialize @adapter = ::RailsEventStore::Models::Event end |
Instance Attribute Details
#adapter ⇒ Object (readonly)
Returns the value of attribute adapter.
8 9 10 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 8 def adapter @adapter end |
Instance Method Details
#create(event, stream_name) ⇒ Object
10 11 12 13 14 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 10 def create(event, stream_name) data = event.to_h.merge!(stream: stream_name, event_type: event.class.name) adapter.create(data) event end |
#delete_stream(stream_name) ⇒ Object
16 17 18 19 20 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 16 def delete_stream(stream_name) condition = {stream: stream_name} adapter.destroy_all condition nil end |
#get_all_events ⇒ Object
30 31 32 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 30 def get_all_events adapter.order('id ASC').order('stream').all.map(&method(:build_event_entity)) end |
#has_event?(event_id) ⇒ Boolean
22 23 24 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 22 def has_event?(event_id) adapter.exists?(event_id: event_id) end |
#last_stream_event(stream_name) ⇒ Object
26 27 28 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 26 def last_stream_event(stream_name) build_event_entity(adapter.where(stream: stream_name).last) end |
#read_all_streams_backward(start_event_id, count) ⇒ Object
77 78 79 80 81 82 83 84 85 86 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 77 def read_all_streams_backward(start_event_id, count) stream = adapter unless start_event_id.equal?(:head) starting_event = adapter.find_by(event_id: start_event_id) stream = stream.where('id < ?', starting_event.id) end stream.order('id DESC').limit(count) .map(&method(:build_event_entity)) end |
#read_all_streams_forward(start_event_id, count) ⇒ Object
66 67 68 69 70 71 72 73 74 75 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 66 def read_all_streams_forward(start_event_id, count) stream = adapter unless start_event_id.equal?(:head) starting_event = adapter.find_by(event_id: start_event_id) stream = stream.where('id > ?', starting_event.id) end stream.order('id ASC').limit(count) .map(&method(:build_event_entity)) end |
#read_events_backward(stream_name, start_event_id, count) ⇒ Object
45 46 47 48 49 50 51 52 53 54 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 45 def read_events_backward(stream_name, start_event_id, count) stream = adapter.where(stream: stream_name) unless start_event_id.equal?(:head) starting_event = adapter.find_by(event_id: start_event_id) stream = stream.where('id < ?', starting_event.id) end stream.order('id DESC').limit(count) .map(&method(:build_event_entity)) end |
#read_events_forward(stream_name, start_event_id, count) ⇒ Object
34 35 36 37 38 39 40 41 42 43 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 34 def read_events_forward(stream_name, start_event_id, count) stream = adapter.where(stream: stream_name) unless start_event_id.equal?(:head) starting_event = adapter.find_by(event_id: start_event_id) stream = stream.where('id > ?', starting_event.id) end stream.order('id ASC').limit(count) .map(&method(:build_event_entity)) end |
#read_stream_events_backward(stream_name) ⇒ Object
61 62 63 64 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 61 def read_stream_events_backward(stream_name) adapter.where(stream: stream_name).order('id DESC') .map(&method(:build_event_entity)) end |
#read_stream_events_forward(stream_name) ⇒ Object
56 57 58 59 |
# File 'lib/rails_event_store/repositories/event_repository.rb', line 56 def read_stream_events_forward(stream_name) adapter.where(stream: stream_name).order('id ASC') .map(&method(:build_event_entity)) end |