module Sandthorn::EventInspector

Public Instance Methods

events_with_trace_info() click to toggle source
# File lib/sandthorn/event_inspector.rb, line 48
def events_with_trace_info
  begin
    saved = Sandthorn.find aggregate_id, self.class  
  rescue Exception
    saved = []
  end
  
  unsaved = self.aggregate_events
  all = saved
    .concat(unsaved)
    .sort { |a, b| a[:aggregate_version] <=> b[:aggregate_version] }

  extracted = all.collect do |e|
    if e[:event_data].nil? && !e[:event_data].nil?
      data = Sandthorn.deserialize e[:event_data]
    else
      data = e[:event_data]
    end

    {
      aggregate_version: e[:aggregate_version],
      event_name: e[:event_name].to_sym, 
      event_data: data,
      event_metadata: e[:event_metadata]
    }
  end

  extracted
end
has_event?(event_name, options = {}) click to toggle source
# File lib/sandthorn/event_inspector.rb, line 39
def has_event? event_name, options = {}
  matching_events = events_with_trace_info
    .select { |e| e[:event_name] == event_name }

  event_exists = matching_events.length > 0
  trace = has_trace? matching_events, options.fetch(:trace, {})
  !!(event_exists && trace)
end
has_saved_event?(event_name, options = {}) click to toggle source
# File lib/sandthorn/event_inspector.rb, line 22
def has_saved_event? event_name, options = {}
  saved = events_with_trace_info

  unless self.aggregate_events.empty?
    saved.reject! do |e| 
      e[:aggregate_version] >= self
        .aggregate_events.first[:aggregate_version]
    end
  end

  matching_events = saved.select { |e| e[:event_name] == event_name }
  event_exists = matching_events.length > 0
  trace = has_trace? matching_events, options.fetch(:trace, {})

  !!(event_exists && trace)
end
has_unsaved_event?(event_name, options = {}) click to toggle source
# File lib/sandthorn/event_inspector.rb, line 3
def has_unsaved_event? event_name, options = {}
  unsaved = events_with_trace_info

  if self.aggregate_events.empty?
    unsaved = []
  else
    unsaved.reject! do |e| 
      e[:aggregate_version] < self
        .aggregate_events.first[:aggregate_version]
    end
  end

  matching_events = unsaved.select { |e| e[:event_name] == event_name }
  event_exists = matching_events.length > 0
  trace = has_trace? matching_events, options.fetch(:trace, {})

  !!(event_exists && trace)
end

Private Instance Methods

get_saved_events(event_name) click to toggle source
# File lib/sandthorn/event_inspector.rb, line 84
def get_saved_events event_name
  saved_events = Sandthorn.find self.class, self.aggregate_id
  saved_events.select { |e| e[:event_name] == event_name.to_s  }
end
get_unsaved_events(event_name) click to toggle source
# File lib/sandthorn/event_inspector.rb, line 80
def get_unsaved_events event_name
  self.aggregate_events.select { |e| e[:event_name] == event_name.to_s  }
end
has_trace?(events_to_check, trace_info) click to toggle source
# File lib/sandthorn/event_inspector.rb, line 89
def has_trace? events_to_check, trace_info
  return true if trace_info.empty?
  events_to_check.each do |event|
    return false if event[:trace] != trace_info
  end
  true
end