Sha256: a37b776a2394d3f60a81b5b3591c18e8b56a96856a83d5598ae6c162e4a5fb21
Contents?: true
Size: 1.75 KB
Versions: 15
Compression:
Stored size: 1.75 KB
Contents
require 'yajl'
module Logical::Naf
module LogParser
class Job < Base
def initialize(params)
super(params)
end
def logs
retrieve_logs
end
private
def insert_log_line(elem)
" <span>#{elem['line_number']} #{elem['output_time']}: #{elem['message']}</br></span>"
end
def sort_jsons
# Sort log lines based on timestamp
@jsons = jsons.sort { |x, y| x['line_number'] <=> y['line_number'] }
end
def parse_newest_log
if newest_log.scan(/\d+ \d{4}-\d{2}-\d{2}/).present?
newest_log.slice!(newest_log.split(/ /).first + ' ')
end
if newest_log.scan(/\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}.\d{3}:/).present?
date = newest_log.slice!(/\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}.\d{3}:/)[0..-2]
@newest_log = date + newest_log
end
newest_log
end
def retrieve_log_files_from_s3
s3_log_reader.retrieve_job_files(record_id)
end
def get_files
if log_type == 'old' && read_from_s3 == 'true'
get_s3_files do
@s3_log_reader = ::Logical::Naf::LogReader.new
return retrieve_log_files_from_s3
end
else
files = Dir["#{::Naf::PREFIX_PATH}/#{::Naf.schema_name}/jobs/#{record_id}/*"]
if files.present?
# Sort log files based on time
return files.sort { |x, y| Time.parse(y.scan(DATE_REGEX)[0][0]) <=> Time.parse(x.scan(DATE_REGEX)[0][0]) }
else
get_s3_files do
@read_from_s3 = 'true'
@s3_log_reader = ::Logical::Naf::LogReader.new
return retrieve_log_files_from_s3
end
end
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems