Module: Euston::Repository

Defined in:
lib/euston-eventstore/repository.rb

Class Method Summary collapse

Class Method Details

.find(type, id) ⇒ Object 



4
5
6
7
8
9
 
# File 'lib/euston-eventstore/repository.rb', line 4

def find type, id
  pair = event_store.get_snapshot_stream_pair id
  return nil if pair.snapshot.nil? && pair.stream.committed_events.empty?

  type.hydrate pair.stream, pair.snapshot
end

.save(aggregate) ⇒ Object 



11
12
13
14
15
16
17
18
 
# File 'lib/euston-eventstore/repository.rb', line 11

def save aggregate
  stream = aggregate.stream || event_store.create_stream(aggregate.aggregate_id)
  aggregate.uncommitted_events.each { |e| stream << EventStore::EventMessage.new(e.to_hash.stringify__keys) }
  aggregate.uncommitted_commands.each { |c| stream << EventStore::CommandMessage.new(c.to_hash.stringify__keys) }
  aggregate.uncommitted_headers.each { |key, value| stream.uncommitted_headers[key] = value }
  stream.uncommitted_headers[:aggregate_type] = aggregate.class.to_s
  stream.commit_changes Euston.uuid.generate
end