class ReeLogger::MultiLogger < Logger
  include Ree::LinkDSL

  link 'ree_logger/rate_limiter', -> { RateLimiter }
  link 'ree_logger/log_event', -> { LogEvent }
  link :transform_values, from: :ree_hash
  link :as_json, from: :ree_object

  undef level=
  undef datetime_format
  undef datetime_format=
  undef sev_threshold=

  LEVEL_MAPPING = {
    debug: Logger::DEBUG,
    info: Logger::INFO,
    warn: Logger::WARN,
    error: Logger::ERROR,
    fatal: Logger::FATAL,
    unknown: Logger::UNKNOWN
  }

  attr_reader :appenders, :silenced, :progname

  contract(
    Nilor[String],
    Nilor[RateLimiter],
    Nilor[ArrayOf[String]] => Any
  )
  def initialize(progname, rate_limiter, filter_words)
    @progname = progname
    @rate_limiter = rate_limiter
    @filter_words = filter_words || []
    @appenders = []
    @silenced  = false
  end

  def add_appender(appender)
    @appenders.push(appender)
  end

  contract Optblock => Bool
  def silence(&block)
    if block_given?
      @silenced = true
      block.call
      unsilence
    else
      @silenced = true
    end

    @silenced
  end

  contract None => Bool
  def unsilence
    @silenced = false
  end

  contract(String, Hash, Nilor[Exception], Bool => nil)
  def debug(message, parameters = {}, exception = nil, log_args = false)
    log(:debug, message, parameters, nil, false)
  end

  contract(String, Hash, Nilor[Exception], Bool => nil)
  def info(message, parameters = {}, exception = nil, log_args = false)
    log(:info, message, parameters, nil)
  end

  contract(String, Hash, Nilor[Exception], Bool => nil)
  def warn(message, parameters = {}, exception = nil, log_args = false)
    log(:warn, message, parameters, nil)
  end

  contract(String, Hash, Nilor[Exception], Bool => nil)
  def error(message, parameters = {}, exception = nil, log_args = true)
    log(:error, message, parameters, exception, log_args)
  end

  contract(String, Hash, Nilor[Exception], Bool => nil)
  def fatal(message, parameters = {}, exception = nil, log_args = true)
    log(:error, message, parameters, exception, true)
  end

  contract(String, Hash, Nilor[Exception], Bool => nil)
  def unknown(message, parameters = {}, exception = nil, log_args = true)
    log(:unknown, message, parameters, exception, true)
  end

  contract(Symbol, String, Hash, Nilor[Exception], Bool => nil)
  def log(level, message, parameters = {}, exception = nil, log_args = false)
    if @rate_limiter
      @rate_limiter.call do
        log_event(level, message, parameters, exception, log_args)
      end
    else
      log_event(level, message, parameters, exception, log_args)
    end

    nil
  end

  alias_method :add, :log

  private

  def log_event(level, message, parameters, exception, log_args)
    return if @silenced if ![:error, :fatal].include?(level)

    if log_args
      begin
        method_binding = binding.of_caller(2)
        method_name = method_binding.eval('__method__')
        obj = method_binding.eval('self')

        args = {}

        obj.method(method_name).parameters.each do |_, name|
          args[name] = method_binding.local_variable_get(name)
        end

        args = transform_values(as_json(args)) do |k, v|
          if @filter_words.any? { k.to_s.include?(_1) }
            'FILTERED'
          else
            v
          end
        end

        parameters[:method] = {}
        parameters[:method][:name] = method_name
        parameters[:method][:args] = args
      rescue
      end
    end

    parameters = transform_values(parameters) do |k, v|
      if @filter_words.any? { k.to_s.include?(_1) }
        'FILTERED'
      else
        v
      end
    end

    event = LogEvent.new(level, message, exception, parameters)

    appenders.each do |appender|
      if higher_or_equal_level?(event.level, appender.level)
        begin
          appender.append(event, @progname)
        rescue
          # fail silently if logger is not working by some reason
        end
      end
    end
  end

  def higher_or_equal_level?(message_level, appender_level)
    LEVEL_MAPPING[message_level] >= LEVEL_MAPPING[appender_level]
  end
end