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