Class: Akasha::Repository

Inherits:
Object
  • Object
show all
Defined in:
lib/akasha/repository.rb

Overview

Aggregate repository. Not meant to be used directly (see aggregate/syntax_helpers.rb) See specs for usage.

Constant Summary collapse

STREAM_NAME_SEP = 
'-'.freeze

Instance Method Summary collapse

Constructor Details

#initialize(store) ⇒ Repository

Creates a new repository using the underlying store (e.g. MemoryEventStore).



9
10
11
12
 
# File 'lib/akasha/repository.rb', line 9

def initialize(store)
  @store = store
  @subscribers = []
end

Instance Method Details

#load_aggregate(klass, id) ⇒ Object

Loads an aggregate identified by id and klass from the repository. Returns an aggregate instance of class klass constructed by applying events from the corresponding stream.



17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/akasha/repository.rb', line 17

def load_aggregate(klass, id)
  agg = klass.new(id)

  start = 0
  page_size = 20
  stream(klass, id).read_events(start, page_size) do |events|
    agg.apply_events(events)
  end

  agg
end

#save_aggregate(aggregate) ⇒ Object

Saves an aggregate to the repository, appending events to the corresponding stream.



30
31
32
33
34
 
# File 'lib/akasha/repository.rb', line 30

def save_aggregate(aggregate)
  changeset = aggregate.changeset
  stream(aggregate.class, changeset.aggregate_id).write_events(changeset.events)
  notify_subscribers(aggregate)
end

#subscribe(lambda = nil, &block) ⇒ Object

Subscribes to event streams passing either a lambda or a block. Example:

repo.subscribe do |aggregate_id, event|
  ... handle the event ...
end



42
43
44
45
 
# File 'lib/akasha/repository.rb', line 42

def subscribe(lambda = nil, &block)
  callable = lambda || block
  @subscribers << callable
end