Sha256: 48c56bcdb01031fd60934684ed63ac05ef51af84515cebb8ec2c162d1ec0a0a0

Contents?: true

Size: 1.59 KB

Versions: 1

Compression:

Stored size: 1.59 KB

Contents

require 'semantic_logger'
require 'rails_semantic_logger/extensions/rails/server' if defined?(Rails::Server)
require 'rails_semantic_logger/engine'

module RailsSemanticLogger
  module ActionController
    autoload :LogSubscriber, 'rails_semantic_logger/action_controller/log_subscriber'
  end
  module ActionView
    autoload :LogSubscriber, 'rails_semantic_logger/action_view/log_subscriber'
  end
  module ActiveRecord
    autoload :LogSubscriber, 'rails_semantic_logger/active_record/log_subscriber'
  end
  module Rack
    autoload :Logger, 'rails_semantic_logger/rack/logger'
  end
  module DelayedJob
    autoload :Plugin, 'rails_semantic_logger/delayed_job/plugin'
  end

  autoload :Options, 'rails_semantic_logger/options'

  # Swap an existing subscriber with a new one
  def self.swap_subscriber(old_class, new_class, notifier)
    subscribers = ActiveSupport::LogSubscriber.subscribers.select { |s| s.is_a?(old_class) }
    subscribers.each { |subscriber| unattach(subscriber) }

    new_class.attach_to(notifier)
  end

  def self.unattach(subscriber)
    subscriber_patterns(subscriber).each do |pattern|
      ActiveSupport::Notifications.notifier.listeners_for(pattern).each do |sub|
        next unless sub.instance_variable_get(:@delegate) == subscriber
        ActiveSupport::Notifications.unsubscribe(sub)
      end
    end

    ActiveSupport::LogSubscriber.subscribers.delete(subscriber)
  end

  def self.subscriber_patterns(subscriber)
    subscriber.patterns.respond_to?(:keys) ?
      subscriber.patterns.keys :
      subscriber.patterns
  end

  private_class_method :subscriber_patterns, :unattach
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
rails_semantic_logger-4.4.3 lib/rails_semantic_logger.rb