Class: Yes::Core::Aggregate::ReadModelRebuilder

Inherits:

Object

• Object
• Yes::Core::Aggregate::ReadModelRebuilder

Defined in:

lib/yes/core/aggregate/read_model_rebuilder.rb

Overview

Handles rebuilding of read models for aggregates

Examples:

Using the rebuilder

rebuilder = ReadModelRebuilder.new(aggregate)
rebuilder.call

Since:

• 0.1.0

Instance Method Summary

• #call(remove: true) ⇒ void

  Rebuilds the read model by processing all events.

• #initialize(aggregate) ⇒ ReadModelRebuilder constructor

  A new instance of ReadModelRebuilder.

Constructor Details

#initialize(aggregate) ⇒ ReadModelRebuilder

Returns a new instance of ReadModelRebuilder.

Parameters:

• aggregate (Yes::Core::Aggregate) —

  The aggregate whose read model needs rebuilding

Since:

• 0.1.0

# File 'lib/yes/core/aggregate/read_model_rebuilder.rb', line 18

def initialize(aggregate)
  @aggregate = aggregate
end

Instance Method Details

#call(remove: true) ⇒ void

This method returns an undefined value.

Rebuilds the read model by processing all events

Parameters:

• remove (Boolean) (defaults to: true) —

  Whether to remove the read model before rebuilding

Since:

• 0.1.0

# File 'lib/yes/core/aggregate/read_model_rebuilder.rb', line 25

def call(remove: true)
  remove ? remove_read_model : read_model.update(revision_column => -1)
  events.each { |events_page| events_page.each { |event| process_event(event) } }
end