Sha256: ce414f2acdf36fe97ec9cfce5e55b965432aa041fc5625f5ae0ff74e20c38700

Contents?: true

Size: 1.25 KB

Versions: 4

Compression:

Stored size: 1.25 KB

Contents

# frozen_string_literal: true

# :markup: markdown

module ActionCable
  module Server
    # # Action Cable Connection TaggedLoggerProxy
    #
    # Allows the use of per-connection tags against the server logger. This wouldn't work using the traditional
    # ActiveSupport::TaggedLogging enhanced Rails.logger, as that logger will reset the tags between requests.
    # The connection is long-lived, so it needs its own set of tags for its independent duration.
    class TaggedLoggerProxy
      attr_reader :tags

      def initialize(logger, tags:)
        @logger = logger
        @tags = tags.flatten
      end

      def add_tags(*tags)
        @tags += tags.flatten
        @tags = @tags.uniq
      end

      def tag(logger, &block)
        if logger.respond_to?(:tagged)
          current_tags = tags - logger.formatter.current_tags
          logger.tagged(*current_tags, &block)
        else
          yield
        end
      end

      %i( debug info warn error fatal unknown ).each do |severity|
        define_method(severity) do |message = nil, &block|
          log severity, message, &block
        end
      end

      private
        def log(type, message, &block) # :doc:
          tag(@logger) { @logger.send type, message, &block }
        end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
actioncable-next-0.2.0 lib/action_cable/server/tagged_logger_proxy.rb
actioncable-next-0.1.2 lib/action_cable/server/tagged_logger_proxy.rb
actioncable-next-0.1.1 lib/action_cable/server/tagged_logger_proxy.rb
actioncable-next-0.1.0 lib/action_cable/server/tagged_logger_proxy.rb