You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

230 lines
7.5 KiB

4 months ago
3 months ago
4 months ago
4 months ago
4 months ago
4 months ago
3 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
3 months ago
4 months ago
3 months ago
3 months ago
3 months ago
3 months ago
3 months ago
3 months ago
3 months ago
4 months ago
4 months ago
3 months ago
4 months ago
4 months ago
3 months ago
4 months ago
3 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
4 months ago
3 months ago
3 months ago
4 months ago
  1. require_relative 'ansi_wrapper'
  2. require_relative 'ansi_colors'
  3. require_relative 'ansi_dimensions'
  4. require_relative 'ansi_common'
  5. require 'io/console'
  6. require 'amazing_print'
  7. require 'json'
  8. # wraps meanwhile takes care of ansi colors
  9. class AnsiFormatter < SemanticLogger::Formatters::Color
  10. include AnsiColors
  11. CENTER_SIZE = 20
  12. FOREMAN_PREFIX_LENGTH = 18
  13. FAILOVER_WRAP = 80
  14. CHAR_FATAL = '⯶'.freeze
  15. TERMINUS_STRING = '╙─╜'.freeze
  16. RENDERED_VIEW_DURATION = 100
  17. TOTAL_RENDERED_VIEW_DURATION = RENDERED_VIEW_DURATION * 5
  18. def initialize
  19. super(color_map:
  20. ColorMap.new(
  21. debug: CLEAR + TEXT_GRAY_400,
  22. info: CLEAR + TEXT_GRAY_100,
  23. warn: CLEAR + BG_YELLOW + TEXT_BLACK,
  24. error: CLEAR + BG_RED + TEXT_WHITE,
  25. fatal: CLEAR + BG_MAGENTA + BOLD + TEXT_WHITE
  26. ))
  27. @memory = nil
  28. end
  29. def call(log, logger)
  30. log = alter(log)
  31. self.log = log
  32. self.logger = logger
  33. self.color = color_map[log.level]
  34. wrap_level(compute_useful_length, message, payload, exception)
  35. end
  36. def reject(log)
  37. return true if log.name == 'ActionView::Base' && log.message&.starts_with?(' Rendering')
  38. true if log.name == 'Rails' && log.message&.starts_with?('Loaded')
  39. end
  40. private
  41. def two_captures_last_as_bold(message, regex)
  42. match = message.match(regex)
  43. return "unmatched: #{message}" unless match
  44. m1, m2 = match.captures
  45. "#{m1}#{BOLD}#{m2}#{CLEAR}"
  46. end
  47. def alter(log)
  48. if log.name == 'Rails'
  49. if log.message
  50. log.message.lstrip!
  51. log.message.chomp!('')
  52. if log.message.starts_with?('Started')
  53. rails = '╓─╖'
  54. before = 1
  55. if @memory
  56. rails = "#{@memory}"
  57. before = 0
  58. end
  59. log.dimensions = AnsiDimensions.new(rails:, before:)
  60. @memory = nil
  61. log.message = two_captures_last_as_bold(log.message, /(^Started \w* )"(.*?)"/)
  62. elsif log.message.starts_with?('Parameters')
  63. parameters = log.message.match(/Parameters: ({.*}$)/).match(1)
  64. parameters = JSON.parse(parameters.gsub('=>', ':'), symbolize_names: true)
  65. parameters = parameters.ai(ruby19_syntax: true, plain: true, multiline: false)
  66. parameters = parameters.gsub(/\w*:/) { |key| "#{TEXT_GRAY_200}#{key.chop}#{color_map[:debug]}:" }
  67. parameters = parameters.gsub(/: ".*?"/) do |value|
  68. ": \"#{TEXT_YELLOW}#{value[3..-2]}#{color_map[:debug]}\""
  69. end
  70. log.message = "Parameters: #{parameters}"
  71. log.level = :debug
  72. elsif log.message.starts_with?('Completed')
  73. m1, m2, m3, m4 = log.message.match(/^Completed (\d+) (.*) in (\d+\.?\d*)ms (.*)$/).captures
  74. http_code = m1.to_i
  75. duration = m3.to_f
  76. duration = duration > TOTAL_RENDERED_VIEW_DURATION ? " in #{m3}ms #{m4}" : ''
  77. log.message = "Completed #{BOLD}#{http_code}#{CLEAR} #{m2}#{duration}"
  78. if http_code / 100 == 2
  79. log.dimensions = AnsiDimensions.new(rails: TERMINUS_STRING, after: 1)
  80. elsif http_code / 100 == 3
  81. @memory = '║'
  82. log.dimensions = AnsiDimensions.new(rails: "#{@memory}")
  83. elsif http_code / 100 == 4
  84. log.dimensions = AnsiDimensions.new(rails: '╙╨╜')
  85. elsif http_code / 100 == 5
  86. log.dimensions = AnsiDimensions.new(rails: "#{draw_fatal}")
  87. end
  88. elsif log.message =~ /^(Processing|Parameters)/
  89. log.level = :debug
  90. if log.message =~ /^Processing/
  91. log.message = two_captures_last_as_bold(log.message, /(^Processing by \w*#\w* as )(.*)/)
  92. end
  93. elsif log.message =~ /Redirected/
  94. log.level = :debug
  95. log.message = two_captures_last_as_bold(log.message,
  96. /^(Redirected to )#{Rails.application.routes.url_helpers.root_url.chop}(.*)/)
  97. end
  98. elsif log.exception
  99. log.dimensions = AnsiDimensions.new(
  100. rails: "#{draw_fatal(log.level.to_s.chr.upcase)}",
  101. after: 1,
  102. terminus: true
  103. )
  104. end
  105. elsif log.name =~ /^(ActionView|ActiveRecord)::Base/
  106. log.level = :debug
  107. log.message.lstrip!
  108. if log.name == 'ActiveRecord::Base'
  109. unbold!(log.message)
  110. if log.message.starts_with?('↳ ')
  111. log.message = AnsiCommon.ansi_trace(log.message, '⇄')
  112. else
  113. sql_match = log.message.match(/\s+\[\[.*\]\]$/)
  114. if sql_match
  115. sql_command = sql_match.pre_match
  116. sql_type, sql_entry = sql_command.split("\e[0m")
  117. sql_color_entry = sql_entry.match(AnsiCommon::ANSI_REGEX).to_s
  118. sql_args = JSON.parse(sql_match.to_s).map(&:last)
  119. sql_args.each_with_index do |val, index|
  120. sql_arg = val.inspect
  121. sql_arg = "'#{val.gsub("'", "''")}'" if val.is_a?(String)
  122. sql_entry.gsub!("$#{index + 1}", colorize(sql_arg, BOLD) + sql_color_entry)
  123. end
  124. log.message = [sql_type, sql_entry].join(CLEAR)
  125. end
  126. end
  127. elsif log.name == 'ActionView::Base'
  128. match = log.message.match(/^Rendered( layout| collection of|) (.*?\.erb)(.*)(\(Duration:.*\))/)
  129. if match
  130. m1, m2, m3, m4 = match.captures
  131. duration = m4.match(/Duration: (\d+\.?\d*)ms/).match(1).to_f
  132. duration = duration < RENDERED_VIEW_DURATION ? '' : m4.to_s
  133. log.message = "⇤ Rendered#{m1} app/views/#{m2}#{m3}#{duration}"
  134. end
  135. end
  136. end
  137. log
  138. end
  139. def draw_fatal(char = CHAR_FATAL)
  140. AnsiColors::BG_MAGENTA + AnsiColors::BOLD + AnsiColors::TEXT_WHITE + char + AnsiColors::CLEAR
  141. end
  142. def origin = colorize(centerize(log.name), TEXT_CYAN)
  143. def build_prefix(char) = "#{origin}#{colorize(char)}"
  144. def build_terminus = "#{origin} #{TERMINUS_STRING} "
  145. def centerize(text) = text.truncate(CENTER_SIZE).center(CENTER_SIZE)
  146. def colorize(text, tint = color) = "#{tint}#{text}#{CLEAR}"
  147. def stackisize(items)
  148. return '' if items.empty?
  149. traces = items.map { |item| AnsiCommon.ansi_trace(item, '➟') }
  150. "\n#{traces.join("\n")}"
  151. end
  152. def build_dimensions(dimensions)
  153. "#{origin} #{dimensions.rails} "
  154. end
  155. def compute_useful_length
  156. IO.console.winsize[1] - FOREMAN_PREFIX_LENGTH
  157. rescue StandardError
  158. FAILOVER_WRAP
  159. end
  160. def unbold!(text) = text.gsub!(BOLD, '')
  161. def message
  162. colorize(log.message) if log.message
  163. end
  164. def payload
  165. return unless log.payload
  166. log.payload.ai(indent: 2, object_id: false)
  167. end
  168. def exception
  169. return unless log.exception
  170. exc = log.exception
  171. clazz = colorize("#{exc.class}\n", color_map[:fatal])
  172. message = colorize(exc.message.chomp(''), color_map[:error])
  173. backtrace = stackisize(Rails.backtrace_cleaner.clean(exc.backtrace))
  174. "#{clazz}#{message}#{backtrace}"
  175. end
  176. def level_char
  177. case log.level
  178. when :info, :debug then ' '
  179. else log.level.to_s.chr.upcase
  180. end
  181. end
  182. def wrap_level(length, *items)
  183. prefix = log.dimensions ? build_dimensions(log.dimensions) : build_prefix(level_char)
  184. continuation = build_prefix('┆')
  185. result = items.map do |item|
  186. AnsiWrapper.wrap(item, length, prefix, continuation)
  187. end
  188. if log.dimensions&.terminus
  189. terminus = AnsiWrapper.wrap(' ', length, build_terminus)
  190. result << terminus
  191. end
  192. log.dimensions&.before&.times { result.unshift('') }
  193. log.dimensions&.after&.times { result << '' }
  194. result.compact.join("\n")
  195. end
  196. end