class EntitySnapshot::EventStore

Constants

Error

Attributes

session[RW]

Public Instance Methods

configure(session: nil) click to toggle source
# File lib/entity_snapshot/event_store/event_store.rb, line 20
def configure(session: nil)
  MessageStore::EventStore::Session.configure(self, session: session)
  MessageStore::EventStore::Write.configure(self, session: self.session, attr_name: :write)
  MessageStore::EventStore::Get::Last.configure(self, session: self.session, attr_name: :read)
end
get(id) click to toggle source
# File lib/entity_snapshot/event_store/event_store.rb, line 54
def get(id)
  stream_name = snapshot_stream_name(id)

  logger.trace "Reading snapshot (Stream: #{stream_name.inspect}, Entity Class: #{entity_class.name})"

  event_data = read.(stream_name)

  if event_data.nil?
    logger.debug "No snapshot could not be read (Stream: #{stream_name.inspect}, Entity Class: #{entity_class.name})"
    return
  end

  entity_data = event_data.data[:entity_data]

  entity = Transform::Read.instance(entity_data, entity_class)

  version = event_data.data[:entity_version]
  time = event_data.time

  logger.debug "Read snapshot (Stream: #{stream_name.inspect}, Entity Class: #{entity_class.name}, Version: #{version.inspect}, Time: #{time})"

  return entity, version, time
end
put(id, entity, version, time) click to toggle source
# File lib/entity_snapshot/event_store/event_store.rb, line 26
def put(id, entity, version, time)
  unless entity.is_a? subject
    raise Error, "Persistent storage for #{subject} cannot store #{entity}"
  end

  stream_name = snapshot_stream_name(id)

  logger.trace "Writing snapshot (Stream: #{stream_name.inspect}, Entity Class: #{entity.class.name}, Version: #{version.inspect}, Time: #{time})"

  entity_data = Transform::Write.raw_data(entity)

  event_data = MessageStore::MessageData::Write.new

  data = {
    entity_data: entity_data,
    entity_version: version
  }

  event_data.type = 'Recorded'
  event_data.data = data

  position = write.(event_data, stream_name)

  logger.debug "Wrote snapshot (Stream: #{stream_name.inspect}, Entity Class: #{entity.class.name}, Version: #{version.inspect}, Time: #{time})"

  position
end
snapshot_stream_name(id) click to toggle source
# File lib/entity_snapshot/event_store/event_store.rb, line 13
def snapshot_stream_name(id)
  entity_class_name = entity_class.name.split('::').last
  entity_category = Casing::Camel.(entity_class_name)

  Messaging::StreamName.stream_name(id, entity_category, type: 'snapshot')
end