Contents

require 'logger'
require 'socket'
require 'time'

module LogStashLogger
  module Formatter
    HOST = ::Socket.gethostname

    class Base < ::Logger::Formatter
      include ::LogStashLogger::TaggedLogging::Formatter

      def call(severity, time, progname, message)
        @event = build_event(message, severity, time)
      end

      protected

      def build_event(message, severity, time)
        data = message
        if data.is_a?(String) && data.start_with?('{'.freeze)
          data = (JSON.parse(message) rescue nil) || message
        end

        event = case data
                  when LogStash::Event
                    data.clone
                  when Hash
                    event_data = data.merge("@timestamp".freeze => time)
                    LogStash::Event.new(event_data)
                  else
                    LogStash::Event.new("message".freeze => msg2str(data), "@timestamp".freeze => time)
                end

        event['severity'.freeze] ||= severity
        #event.type = progname

        event['host'.freeze] ||= HOST

        current_tags.each { |tag| event.tag(tag) }
        
        LogStashLogger.configuration.customize_event_block.call(event) if LogStashLogger.configuration.customize_event_block.respond_to?(:call)

        # In case Time#to_json has been overridden
        if event.timestamp.is_a?(Time)
          event.timestamp = event.timestamp.iso8601(3)
        end
        
        event
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
logstash-logger-0.15.2	lib/logstash-logger/formatter/base.rb
logstash-logger-0.15.1	lib/logstash-logger/formatter/base.rb
logstash-logger-0.15.0	lib/logstash-logger/formatter/base.rb
logstash-logger-0.14.1	lib/logstash-logger/formatter/base.rb
logstash-logger-0.14.0	lib/logstash-logger/formatter/base.rb
logstash-logger-0.13.0	lib/logstash-logger/formatter/base.rb
logstash-logger-0.12.0	lib/logstash-logger/formatter/base.rb