# frozen_string_literal: true require "active_support/per_thread_registry" require "active_support/notifications" module ActiveSupport # ActiveSupport::Subscriber is an object set to consume # ActiveSupport::Notifications. The subscriber dispatches notifications to # a registered object based on its given namespace. # # An example would be an Active Record subscriber responsible for collecting # statistics about queries: # # module ActiveRecord # class StatsSubscriber < ActiveSupport::Subscriber # attach_to :active_record # # def sql(event) # Statsd.timing("sql.#{event.payload[:name]}", event.duration) # end # end # end # # After configured, whenever a "sql.active_record" notification is published, # it will properly dispatch the event (ActiveSupport::Notifications::Event) to # the +sql+ method. # # We can detach a subscriber as well: # # ActiveRecord::StatsSubscriber.detach_from(:active_record) class Subscriber class << self # Attach the subscriber to a namespace. def attach_to(namespace, subscriber = new, notifier = ActiveSupport::Notifications) @namespace = namespace @subscriber = subscriber @notifier = notifier subscribers << subscriber # Add event subscribers for all existing methods on the class. subscriber.public_methods(false).each do |event| add_event_subscriber(event) end end # Detach the subscriber from a namespace. def detach_from(namespace, notifier = ActiveSupport::Notifications) @namespace = namespace @subscriber = find_attached_subscriber @notifier = notifier return unless subscriber subscribers.delete(subscriber) # Remove event subscribers of all existing methods on the class. subscriber.public_methods(false).each do |event| remove_event_subscriber(event) end # Reset notifier so that event subscribers will not add for new methods added to the class. @notifier = nil end # Adds event subscribers for all new methods added to the class. def method_added(event) # Only public methods are added as subscribers, and only if a notifier # has been set up. This means that subscribers will only be set up for # classes that call #attach_to. if public_method_defined?(event) && notifier add_event_subscriber(event) end end def subscribers @@subscribers ||= [] end private attr_reader :subscriber, :notifier, :namespace def add_event_subscriber(event) # :doc: return if invalid_event?(event.to_s) pattern = prepare_pattern(event) # Don't add multiple subscribers (eg. if methods are redefined). return if pattern_subscribed?(pattern) subscriber.patterns[pattern] = notifier.subscribe(pattern, subscriber) end def remove_event_subscriber(event) # :doc: return if invalid_event?(event.to_s) pattern = prepare_pattern(event) return unless pattern_subscribed?(pattern) notifier.unsubscribe(subscriber.patterns[pattern]) subscriber.patterns.delete(pattern) end def find_attached_subscriber subscribers.find { |attached_subscriber| attached_subscriber.instance_of?(self) } end def invalid_event?(event) %w{ start finish }.include?(event.to_s) end def prepare_pattern(event) "#{event}.#{namespace}" end def pattern_subscribed?(pattern) subscriber.patterns.key?(pattern) end end attr_reader :patterns # :nodoc: def initialize @queue_key = [self.class.name, object_id].join "-" @patterns = {} super end def start(name, id, payload) event = ActiveSupport::Notifications::Event.new(name, nil, nil, id, payload) event.start! parent = event_stack.last parent << event if parent event_stack.push event end def finish(name, id, payload) event = event_stack.pop event.finish! event.payload.merge!(payload) method = name.split(".").first send(method, event) end private def event_stack SubscriberQueueRegistry.instance.get_queue(@queue_key) end end # This is a registry for all the event stacks kept for subscribers. # # See the documentation of ActiveSupport::PerThreadRegistry # for further details. class SubscriberQueueRegistry # :nodoc: extend PerThreadRegistry def initialize @registry = {} end def get_queue(queue_key) @registry[queue_key] ||= [] end end end