42 lines
988 B
Ruby
42 lines
988 B
Ruby
module AbfWorker
|
|
class BaseObserver
|
|
COMPLETED = 0
|
|
FAILED = 1
|
|
PENDING = 2
|
|
STARTED = 3
|
|
CANCELED = 4
|
|
TESTS_FAILED = 5
|
|
|
|
attr_accessor :status, :options
|
|
|
|
def initialize(options, subject_class)
|
|
@status = options['status'].to_i
|
|
@options = options
|
|
@subject_class = subject_class
|
|
end
|
|
|
|
def perform
|
|
raise NotImplementedError, "You should implement this method"
|
|
end
|
|
|
|
protected
|
|
|
|
def subject
|
|
@subject ||= @subject_class.find(options['id'])
|
|
end
|
|
|
|
def update_results
|
|
now = Time.zone.now.to_i
|
|
results = options['results'] || []
|
|
results.each{ |r| r['timestamp'] = now }
|
|
results += subject.results || []
|
|
sort_results_and_save(results)
|
|
end
|
|
|
|
def sort_results_and_save(results, item = subject)
|
|
item.results = results.sort_by{ |r| [r['timestamp'].to_s, r['file_name'].to_s] }
|
|
item.save(validate: false)
|
|
end
|
|
|
|
end
|
|
end |