Sha256: c39d661996fdc2cca30272539ffa934fa7b50b6feef1793719a37eac1e294f65
Contents?: true
Size: 1.14 KB
Versions: 23
Compression:
Stored size: 1.14 KB
Contents
require 'evrone/ci/message'
require 'evrone/ci/common'
module Evrone
module CI
module Worker
class Job
include Helper::Logger
attr_reader :output, :message, :output_counter
def initialize(perform_job_message)
@output_counter = 0
@message = perform_job_message
@output = Common::OutputBuffer.new(&method(:publish_job_log_message))
end
def add_to_output(str)
output << str
logger.debug str.strip if logger.level == 0
end
def add_command_to_output(cmd)
add_to_output "$ #{cmd}\n"
end
def add_trace_to_output(log)
add_to_output log.split(/\n/).map{|i| " ===> #{i}\n" }.join
end
def release
output.close
end
def publish_job_log_message(str)
@output_counter += 1
log = Message::JobLog.new(
build_id: message.id,
job_id: message.job_id,
tm: output_counter,
log: str
)
JobLogsConsumer.publish log
log
end
end
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems