Module: Rollgeist::Notifier

Defined in:

lib/rollgeist/notifier.rb

Constant Summary

EVENT_NAME =

"ghost_access.rollgeist"

WATCHPOINT_BITS =

{
  serialization: 1,
  global_id: 2,
  resave: 4
}.freeze

Class Method Summary

• .notify(record, watchpoint) ⇒ Object
• .report_suppressed(count) ⇒ Object

Class Method Details

.notify(record, watchpoint) ⇒ Object

# File 'lib/rollgeist/notifier.rb', line 13

def notify(record, watchpoint)
  return unless Rollgeist.enabled?
  return if Rollgeist.suppressed?

  configuration = Rollgeist.configuration
  return unless configuration.watchpoint_enabled?(watchpoint)

  mark = Rollgeist.mark_for(record)
  return unless mark

  report = Report.build(record: record, mark: mark, watchpoint: watchpoint)
  return if ignored?(configuration, report)
  return if configuration.warn_once && !claim_watchpoint(record, watchpoint)

  decision = ExecutionState.claim(configuration.max_reports_per_request)
  report_suppressed(decision.suppressed_to_flush) if decision.suppressed_to_flush
  return unless decision.allowed

  emit(report, configuration)
rescue GhostRecordAccess
  raise
rescue StandardError => error
  warn_safely("Rollgeist notifier failure: #{error.class}: #{error.message}")
end

.report_suppressed(count) ⇒ Object

# File 'lib/rollgeist/notifier.rb', line 38

def report_suppressed(count)
  return unless count.to_i.positive?

  log_safely("Rollgeist: +#{count} more suppressed")
end