mirror of
https://github.com/plashchynski/crono.git
synced 2026-09-17 23:41:26 +02:00
106 lines
2.5 KiB
Ruby
106 lines
2.5 KiB
Ruby
require 'stringio'
|
|
require 'logger'
|
|
|
|
module Crono
|
|
# Crono::Job represents a Crono job
|
|
class Job
|
|
include Logging
|
|
|
|
attr_accessor :performer, :period, :last_performed_at,
|
|
:next_performed_at, :job_log, :job_logger, :healthy
|
|
|
|
def initialize(performer, period)
|
|
self.performer, self.period = performer, period
|
|
self.job_log = StringIO.new
|
|
self.job_logger = Logger.new(job_log)
|
|
self.next_performed_at = period.next
|
|
@semaphore = Mutex.new
|
|
end
|
|
|
|
def next
|
|
return next_performed_at if next_performed_at.future?
|
|
Time.now
|
|
end
|
|
|
|
def description
|
|
"Perform #{performer} #{period.description}"
|
|
end
|
|
|
|
def job_id
|
|
description
|
|
end
|
|
|
|
def perform
|
|
log "Perform #{performer}"
|
|
self.last_performed_at = Time.now
|
|
self.next_performed_at = period.next(since: last_performed_at)
|
|
|
|
Thread.new { perform_job }
|
|
end
|
|
|
|
def save
|
|
@semaphore.synchronize do
|
|
update_model
|
|
clear_job_log
|
|
end
|
|
end
|
|
|
|
def load
|
|
self.last_performed_at = model.last_performed_at
|
|
self.next_performed_at = period.next(since: last_performed_at)
|
|
end
|
|
|
|
private
|
|
|
|
def clear_job_log
|
|
job_log.truncate(job_log.rewind)
|
|
end
|
|
|
|
def update_model
|
|
saved_log = model.reload.log || ''
|
|
log_to_save = saved_log + job_log.string
|
|
model.update(last_performed_at: last_performed_at, log: log_to_save,
|
|
healthy: healthy)
|
|
end
|
|
|
|
def perform_job
|
|
performer.new.perform
|
|
rescue StandardError => e
|
|
handle_job_fail(e)
|
|
else
|
|
handle_job_success
|
|
ensure
|
|
save
|
|
end
|
|
|
|
def handle_job_fail(exception)
|
|
finished_time_sec = format('%.2f', Time.now - last_performed_at)
|
|
self.healthy = false
|
|
log_error "Finished #{performer} in #{finished_time_sec} seconds"\
|
|
" with error: #{exception.message}"
|
|
log_error exception.backtrace.join("\n")
|
|
end
|
|
|
|
def handle_job_success
|
|
finished_time_sec = format('%.2f', Time.now - last_performed_at)
|
|
self.healthy = true
|
|
log "Finished #{performer} in #{finished_time_sec} seconds"
|
|
end
|
|
|
|
def log_error(message)
|
|
log(message, Logger::ERROR)
|
|
end
|
|
|
|
def log(message, severity = Logger::INFO)
|
|
@semaphore.synchronize do
|
|
logger.log severity, message
|
|
job_logger.log severity, message
|
|
end
|
|
end
|
|
|
|
def model
|
|
@model ||= Crono::CronoJob.find_or_create_by(job_id: job_id)
|
|
end
|
|
end
|
|
end
|