Sha256: 485c7defd8210a74de46ef5f23227f96dfc186f532e470d0f8445025b093a091
Contents?: true
Size: 1.34 KB
Versions: 6
Compression:
Stored size: 1.34 KB
Contents
module ORS
class LogUnifier
attr_reader :logs, :pretty_adjust
def initialize logs
@pretty_adjust = 0
@logs = logs.inject(Hash.new) do |hash, (server, log_rows)|
@pretty_adjust = [@pretty_adjust, server.length].max
hash[server] = log_rows
hash
end
end
def unify
group_by_entry.
select {|entry| entry[:timestamp].size == 14 }.
sort_by {|entry| entry[:timestamp] }.
map do |entry|
entry[:lines].
map {|line| ["[#{entry[:server]}]".ljust(pretty_adjust + 3), line].join }.
join "\n"
end.
flatten.
join("\n\n\n")
end
private
def group_by_entry
entries = Array.new
logs.each do |server, log_rows|
entry = {:lines => Array.new, :server => server}
log_rows.split(/\n/).each do |line|
if line == ""
unless entry[:lines].empty?
entries << entry
entry = {:lines => Array.new, :server => server}
end
else
if entry[:lines].empty?
entry[:timestamp] = line.gsub(/^(?:Processing|Started).*?(\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}).*$/, '\1').gsub(/\D/, '')
end
entry[:lines] << line
end
end
entries << entry
end
entries
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems