require 'log4r'

class RFlow
  class Logger
    extend Forwardable
    include Log4r

    LOG_PATTERN_FORMAT = '%l [%d] %x (%p) - %M'
    DATE_METHOD = 'xmlschema(6)'
    LOG_PATTERN_FORMATTER = PatternFormatter.new :pattern => LOG_PATTERN_FORMAT, :date_method => DATE_METHOD

    attr_accessor :config, :internal_logger
    attr_accessor :log_file_path, :log_level

    # Delegate log methods to internal logger
    def_delegators :@internal_logger, :fatal, :error, :warn, :info, :debug

    def initialize(config, include_stdout=nil)
      @log_file_path = config['rflow.log_file_path']
      @log_level = config['rflow.log_level']

      log_name = (config['rflow.application_name'] rescue File.basename(log_file_path))
      @internal_logger = Log4r::Logger.new(log_name)

      internal_logger.level = LNAMES.index log_level
      internal_logger.trace = true

      begin
        internal_logger.add FileOutputter.new('rflow.log_file', :filename => log_file_path, :formatter => LOG_PATTERN_FORMATTER)
      rescue Exception => e
        error_message = "Log file '#{File.expand_path log_file_path}' problem: #{e.message}\b#{e.backtrace.join("\n")}"
        RFlow.logger.error error_message
        raise ArgumentError, error_message
      end

      if include_stdout
        internal_logger.add StdoutOutputter.new('rflow_stdout', :formatter => LOG_PATTERN_FORMATTER)
      end

      # RFlow.logger.info "Transitioning to running log file #{log_file_path} at level #{log_level}"
      Log4r::NDC.clear
      Log4r::NDC.push(log_name)

      internal_logger
    end

    def reopen
      # TODO: Make this less of a hack, although Log4r doesn't support
      # it, so it might be permanent
      log_file = Outputter['rflow.log_file'].instance_variable_get(:@out)
      File.open(log_file.path, 'a') { |tmp_log_file| log_file.reopen(tmp_log_file) }
    end

    def close
      Outputter['rflow.log_file'].close
    end

    def toggle_log_level
      original_log_level = LNAMES[logger.level]
      new_log_level = (original_log_level == 'DEBUG' ? log_level : 'DEBUG')

      internal_logger.warn "Changing log level from #{original_log_level} to #{new_log_level}"
      internal_logger.level = LNAMES.index new_log_level
    end

  end
end