discourse/lib/discourse_event.rb

# This is meant to be used by plugins to trigger and listen to events
# So we can execute code when things happen.
class DiscourseEvent
  def self.async
    @async ||= !Rails.env.test?
  end

  def self.async=(val)
    @async = val
  end

  # Defaults to a hash where default values are empty sets.
  def self.events
    @events ||= Hash.new { |hash, key| hash[key] = Set.new }
  end

  def self.trigger(event_name, *params)
    if async
      Thread.new { call_events(event_name, *params) }
    else
      call_events(event_name, *params)
    end
  end

  def self.call_events(event_name, *params)
    events[event_name].each do |event|
      event.call(*params)
    end
  end

  def self.on(event_name, &block)
    if event_name == :site_setting_saved
      Discourse.deprecate("The :site_setting_saved event is deprecated. Please use :site_setting_changed instead", since: "2.3.0beta8", drop_from: "2.4")
    end
    events[event_name] << block
  end

  def self.off(event_name, &block)
    events[event_name].delete(block)
  end

end