# frozen_string_literal: true

require 'active_support/notifications'
require 'active_record/log_subscriber'
require 'logstasher/custom_fields'

module LogStasher
  module ActiveRecord
    class LogSubscriber < ::ActiveRecord::LogSubscriber
      include CustomFields::LogSubscriber

      def identity(event)
        lsevent = logstash_event(event)
        logger << "#{lsevent.to_json}\n" if logger && lsevent
      end
      alias sql identity

      def logger
        LogStasher.logger
      end

      private

      def logstash_event(event)
        self.class.runtime += event.duration
        data = event.payload.dup

        return if data[:name] == 'SCHEMA'

        # A connection cannot be converted to JSON as it fails with
        # SystemStackError when running against ActiveSupport JSON patches.
        data.delete(:connection)

        data.merge! runtimes(event)
        data.merge! extract_sql(data)
        data.merge! request_context
        data.merge! LogStasher.store
        data.merge! extract_custom_fields(data)

        tags = ['request']
        tags.push('exception') if data[:exception]
        LogStasher.build_logstash_event(data, tags)
      end

      def request_context
        LogStasher.request_context
      end

      def runtimes(event)
        if event.duration
          { duration: event.duration.to_f.round(2) }
        else
          {}
        end
      end

      def extract_sql(data)
        { sql: data[:sql].squeeze(' ') }
      end
    end
  end
end