easy-going-rails/lib/semantic/ansi_formatter.rb

require 'io/console'
require 'amazing_print'
require 'json'

module Semantic
  # wraps meanwhile takes care of ansi colors
  class AnsiFormatter < SemanticLogger::Formatters::Color
    include AnsiColors

    CENTER_SIZE = 20
    FOREMAN_PREFIX_LENGTH = 18
    FAILOVER_WRAP = 80
    CHAR_FATAL = '⯶'.freeze
    TERMINUS_STRING = '╙─╜'.freeze
    RENDERED_VIEW_DURATION = 100
    TOTAL_RENDERED_VIEW_DURATION = RENDERED_VIEW_DURATION * 5

    def initialize
      super(color_map:
        ColorMap.new(
          debug: CLEAR + TEXT_GRAY_400,
          info: CLEAR + TEXT_GRAY_100,
          warn: CLEAR + BG_YELLOW + TEXT_BLACK,
          error: CLEAR + BG_RED + TEXT_WHITE,
          fatal: CLEAR + BG_MAGENTA + BOLD + TEXT_WHITE
        ))
      @memory = nil
    end

    def call(log, logger)
      log = alter(log)

      self.log = log
      self.logger = logger
      self.color = color_map[log.level]

      wrap_level(compute_useful_length, message, payload, exception)
    end

    def reject(log)
      return true if log.name == 'ActionView::Base' && log.message&.starts_with?('  Rendering')

      true if log.name == 'Rails' && log.message&.starts_with?('Loaded')
    end

    private

    def tags
      first_tag = log.tags.empty? ? 'none' : log.tags.first
      first_tag.truncate(CENTER_SIZE).center(CENTER_SIZE)
    end

    def named_tags
      return if log.named_tags.empty?

      log.named_tags
    end

    def build_regex_redirected
      dev_port = Rails.application.routes.default_url_options[:port]
      dev_hosts = ['127.0.0.1', 'localhost', Rails.application.routes.default_url_options[:host]].uniq.join('|')
      dev_from = "http://(?:#{dev_hosts}):#{dev_port}"
      regex_s = "^(Redirected to )#{dev_from}(.*)"
      Regexp.new(regex_s)
    end

    def ansi_trace(trace, symbol)
      match = trace.match(/(↳ )?(.*:\d+)(:in `)?(.*'?)/) # only m2(=file) and m4(=optional function) are useful
      return trace unless match

      _, m2, _, m4 = match.captures
      "#{symbol} #{m2} #{BOLD}#{m4.chop}#{CLEAR}"
    end

    def two_captures_last_as_bold(message, regex)
      match = message.match(regex)
      return "unmatched: #{message}" unless match

      m1, m2 = match.captures
      "#{m1}#{BOLD}#{m2}#{CLEAR}"
    end

    def alter(log)
      if log.name == 'Rails'
        if log.message
          log.message.lstrip!
          log.message.chomp!('')
          if log.message.starts_with?('Started')
            rails = '╓─╖'
            before = 1
            if @memory
              rails = "╓#{@memory}╖"
              before = 0
            end
            log.dimensions = Semantic::AnsiDimensions.new(rails:, before:)
            @memory = nil
            log.message = two_captures_last_as_bold(log.message, /(^Started \w* )"(.*?)"/)
          elsif log.message.starts_with?('Parameters')
            parameters = log.message.match(/Parameters: ({.*}$)/).match(1)
            parameters = JSON.parse(parameters.gsub('=>', ':'), symbolize_names: true)
            parameters = parameters.ai(ruby19_syntax: true, plain: true, multiline: false)
            parameters = parameters.gsub(/\w*:/) { |key| "#{TEXT_GRAY_200}#{key.chop}#{color_map[:debug]}:" }
            parameters = parameters.gsub(/: ".*?"/) do |value|
              ": \"#{TEXT_YELLOW}#{value[3..-2]}#{color_map[:debug]}\""
            end
            log.message = "Parameters: #{parameters}"
            log.level = :debug
          elsif log.message.starts_with?('Completed')
            m1, m2, m3, m4 = log.message.match(/^Completed (\d+) (.*) in (\d+\.?\d*)ms (.*)$/).captures
            http_code = m1.to_i
            duration = m3.to_f
            duration = duration > TOTAL_RENDERED_VIEW_DURATION ? " in #{m3}ms #{m4}" : ''
            log.message = "Completed #{BOLD}#{http_code}#{CLEAR} #{m2}#{duration}"
            if http_code / 100 == 2
              log.dimensions = Semantic::AnsiDimensions.new(rails: TERMINUS_STRING, after: 1)
            elsif http_code / 100 == 3
              @memory = '║'
              log.dimensions = Semantic::AnsiDimensions.new(rails: "╙#{@memory}╜")
            elsif http_code / 100 == 4
              log.dimensions = Semantic::AnsiDimensions.new(rails: '╙╨╜')
            elsif http_code / 100 == 5
              log.dimensions = Semantic::AnsiDimensions.new(rails: "╙#{draw_fatal}╜")
            end
          elsif log.message =~ /^(Processing|Parameters)/
            log.level = :debug
            if log.message =~ /^Processing/
              log.message = two_captures_last_as_bold(log.message, /(^Processing by \w*#\w* as )(.*)/)
            end
          elsif log.message =~ /Redirected/
            log.level = :debug
            @regex_redirected ||= build_regex_redirected # lazy building
            log.message = two_captures_last_as_bold(log.message, @regex_redirected)
          end
        elsif log.exception
          log.dimensions = Semantic::AnsiDimensions.new(
            rails: "╓#{draw_fatal(log.level.to_s.chr.upcase)}╖",
            after: 1,
            terminus: true
          )
        end
      elsif log.name =~ /^(ActionView|ActiveRecord)::Base/
        log.level = :debug
        log.message.lstrip!
        if log.name == 'ActiveRecord::Base'
          unbold!(log.message)

          if log.message.starts_with?('↳ ')
            log.message = ansi_trace(log.message, '⇄')
          else
            sql_match = log.message.match(/\s+\[\[.*\]\]$/)
            if sql_match
              sql_command = sql_match.pre_match
              sql_type, sql_entry = sql_command.split("\e[0m")
              sql_color_entry = sql_entry.match(ANSI_REGEX).to_s
              sql_args = JSON.parse(sql_match.to_s).map(&:last)
              sql_args.each_with_index do |val, index|
                sql_arg = val.inspect
                sql_arg = "'#{val.gsub("'", "''")}'" if val.is_a?(String)
                sql_entry.gsub!("$#{index + 1}", colorize(sql_arg, BOLD) + sql_color_entry)
              end
              log.message = [sql_type, sql_entry].join(CLEAR)
            end
          end
        elsif log.name == 'ActionView::Base'
          match = log.message.match(/^Rendered( layout| collection of|) (.*?\.erb)(.*)(\(Duration:.*\))/)
          if match
            m1, m2, m3, m4 = match.captures
            duration = m4.match(/Duration: (\d+\.?\d*)ms/).match(1).to_f
            duration = duration < RENDERED_VIEW_DURATION ? '' : m4.to_s
            log.message = "⇤ Rendered#{m1} app/views/#{m2}#{m3}#{duration}"
          end
        end

      end

      log
    end

    def draw_fatal(char = CHAR_FATAL)   = BG_MAGENTA + BOLD + TEXT_WHITE + char + CLEAR
    def origin                          = colorize(centerize(log.name), TEXT_CYAN)
    def build_prefix(char)              = "#{tags} #{origin} ╣#{colorize(char)}╠  "
    def build_terminus                  = "#{tags} #{origin} #{TERMINUS_STRING}  "
    def centerize(text)                 = text.truncate(CENTER_SIZE).center(CENTER_SIZE)
    def colorize(text, tint = color)    = "#{tint}#{text}#{CLEAR}"

    def stackisize(items)
      return '' if items.empty?

      traces = items.map { |item| ansi_trace(item, '➟') }
      "\n#{traces.join("\n")}"
    end

    def build_dimensions(dimensions)
      "#{tags} #{origin} #{dimensions.rails}  "
    end

    def compute_useful_length
      IO.console.winsize[1] - FOREMAN_PREFIX_LENGTH
    rescue StandardError
      FAILOVER_WRAP
    end

    def unbold!(text) = text.gsub!(BOLD, '')

    def message
      colorize(log.message) if log.message
    end

    def payload
      return unless log.payload

      log.payload.ai(indent: 2, object_id: false)
    end

    def exception
      return unless log.exception

      exc = log.exception
      clazz = colorize("#{exc.class}\n", color_map[:fatal])
      message = colorize(exc.message.chomp(''), color_map[:error])
      backtrace = stackisize(Rails.backtrace_cleaner.clean(exc.backtrace))

      "#{clazz}#{message}#{backtrace}"
    end

    def level_char
      case log.level
      when :info, :debug then ' '
      else log.level.to_s.chr.upcase
      end
    end

    def wrap_level(length, *items)
      prefix = log.dimensions ? build_dimensions(log.dimensions) : build_prefix(level_char)
      continuation = build_prefix('┆')

      result = items.map do |item|
        Semantic::AnsiWrapper.wrap(item, length, prefix, continuation)
      end

      if log.dimensions&.terminus
        terminus = Semantic::AnsiWrapper.wrap(' ', length, build_terminus)
        result << terminus
      end

      log.dimensions&.before&.times { result.unshift('') }
      log.dimensions&.after&.times { result << '' }
      result.compact.join("\n")
    end
  end
end