module RSMP
  class Logger

    attr_accessor :settings
    
    def initialize settings={}
      defaults = {
        'active'=>false,
        'path'=>nil,
        'author'=>false,
        'color'=>true,
        'site_id'=>true,
        'component'=>false,
        'level'=>false,
        'ip'=>false,
        'index'=>false,
        'timestamp'=>true,
        'json'=>false,
        'debug'=>false,
        'statistics'=>false,
        'hide_ip_and_port' => false
      }
      if settings
        @settings = defaults.merge settings
      else
        @settings = defaults
      end

      @muted = {}

      setup_output_destination
    end

    def setup_output_destination
      if @settings['path']
        @stream = File.open(@settings['path'],'a')  # appending
      else
        @stream = $stdout
      end
    end

    def mute ip, port
      @muted["#{ip}:#{port}"] = true
    end

    def unmute ip, port
      @muted.delete "#{ip}:#{port}"
    end

    def unmute_all
      @muted = {}
    end

    def output? item, force=false
      return false if item[:ip] && item[:port] && @muted["#{item[:ip]}:#{item[:port]}"]
      return false if @settings["active"] == false && force != true
      return false if @settings["info"] == false && item[:level] == :info
      return false if @settings["debug"] != true && item[:level] == :debug
      return false if @settings["statistics"] != true && item[:level] == :statistics
      return false if @settings["test"] != true && item[:level] == :test

      if item[:message]
        type = item[:message].type
        ack = type == "MessageAck" || type == "MessageNotAck"
        if @settings["watchdogs"] == false
          return false if type == "Watchdog"
          if ack
            return false if item[:message].original && item[:message].original.type == "Watchdog"
          end
        end
        return false if ack && @settings["acknowledgements"] == false && 
          [:not_acknowledged,:warning,:error].include?(item[:level]) == false
      end
      true
    end

    def output level, str
      return if str.empty? || /^\s+$/.match(str)
      str = colorize level, str
      @stream.puts str
      @stream.flush
    end

    def colorize level, str
      if @settings["color"] == false || @settings["color"] == nil
        str
      elsif @settings["color"] == true
        case level
        when  :error
          str.colorize(:red)
        when :warning
          str.colorize(:light_yellow)
        when :not_acknowledged
          str.colorize(:cyan)
        when :log
          str.colorize(:light_blue)
        when :statistics
          str.colorize(:light_black)
        when :test
          str.colorize(:light_magenta)
        else
          str
        end
      else
        if level == :nack || level == :warning || level == :error
          str.colorize(@settings["color"]).bold
        else
          str.colorize @settings["color"]
        end
      end
    end

    def log item, force:false 
      if output?(item, force)
        output item[:level], build_output(item) 
      end
    end

    def self.shorten_message_id m_id, length=4
      if m_id
        m_id[0..length-1].ljust(length)
      else
        ' '*length
      end
    end 

    def dump archive, force:false, num:nil
      num ||= archive.items.size
      log = archive.items.last(num).map do |item|
        str = build_output item
        str = colorize item[:level], str
      end
      log.join("\n")
    end
  
    def build_output item
      parts = []
      parts << item[:index].to_s.ljust(7) if @settings["index"] == true
      parts << item[:author].to_s.ljust(13) if @settings["author"] == true
      parts << item[:timestamp].to_s.ljust(24) unless @settings["timestamp"] == false
      parts << item[:ip].to_s.ljust(22) unless @settings["ip"] == false
      parts << item[:site_id].to_s.ljust(13) unless @settings["site_id"] == false
      parts << item[:component_id].to_s.ljust(18) unless @settings["component"] == false
      
      directions = {in:"-->",out:"<--"}
      parts << directions[item[:direction]].to_s.ljust(4) unless @settings["direction"] == false

      parts << item[:level].to_s.capitalize.ljust(7) unless @settings["level"] == false

      
      unless @settings["id"] == false
        length = 4
        if item[:message]
          parts << Logger.shorten_message_id(item[:message].m_id,length)+' '
        else
          parts << " "*(length+1)
        end
      end
      parts << item[:str].to_s.strip unless @settings["text"] == false
      parts << item[:message].json unless @settings["json"] == false || item[:message] == nil

      if item[:exception]
        parts << "#{item[:exception].class.to_s}\n"
        parts << item[:exception].backtrace.join("\n")
      end

      out = parts.join(' ').chomp(' ')
      out
    end

  end
end