177 lines
2.8 KiB
Ruby
177 lines
2.8 KiB
Ruby
module Mutant
|
|
# Runner baseclass
|
|
class Runner
|
|
include Adamantium::Flat, AbstractType
|
|
|
|
REGISTRY = {}
|
|
|
|
# Register handler
|
|
#
|
|
# @param [Class] klass
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def self.register(klass)
|
|
REGISTRY[klass]=self
|
|
end
|
|
private_class_method :register
|
|
|
|
# Lookup runner
|
|
#
|
|
# @param [Class] klass
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def self.lookup(klass)
|
|
current = klass
|
|
while current
|
|
handler = REGISTRY.fetch(current) do
|
|
current = current.superclass; nil
|
|
end
|
|
return handler if handler
|
|
end
|
|
|
|
raise ArgumentError, "No handler for: #{klass}"
|
|
end
|
|
private_class_method :lookup
|
|
|
|
# Run runner for object
|
|
#
|
|
# @param [Config] config
|
|
# @param [Object] object
|
|
#
|
|
# @return [Runner]
|
|
#
|
|
# @api private
|
|
#
|
|
def self.run(config, object)
|
|
handler = lookup(object.class)
|
|
handler.new(config, object)
|
|
end
|
|
|
|
# Return config
|
|
#
|
|
# @return [Mutant::Config]
|
|
#
|
|
# @api private
|
|
#
|
|
attr_reader :config
|
|
|
|
# Initialize object
|
|
#
|
|
# @param [Config] config
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def initialize(config)
|
|
@config = config
|
|
@start = Time.now
|
|
run
|
|
@end = Time.now
|
|
end
|
|
|
|
# Test if runner should stop
|
|
#
|
|
# @return [true]
|
|
# if runner should stop
|
|
#
|
|
# @return [false]
|
|
# otherwise
|
|
#
|
|
def stop?
|
|
!!@stop
|
|
end
|
|
|
|
# Return runtime
|
|
#
|
|
# @return [Float]
|
|
#
|
|
# @api private
|
|
#
|
|
def runtime
|
|
(@end || Time.now) - @start
|
|
end
|
|
|
|
# Return reporter
|
|
#
|
|
# @return [Reporter]
|
|
#
|
|
# @api private
|
|
#
|
|
def reporter
|
|
config.reporter
|
|
end
|
|
|
|
# Test if runner is successful
|
|
#
|
|
# @return [true]
|
|
# if successful
|
|
#
|
|
# @return [false]
|
|
# otherwise
|
|
#
|
|
# @api private
|
|
#
|
|
abstract_method :success?
|
|
|
|
private
|
|
|
|
# Perform operation
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
abstract_method :run
|
|
|
|
# Return reporter
|
|
#
|
|
# @param [Object] object
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def report(object)
|
|
reporter.report(object)
|
|
end
|
|
|
|
# Perform dispatch
|
|
#
|
|
# @return [Enumerable<Runner>]
|
|
#
|
|
# @api private
|
|
#
|
|
def dispatch(input)
|
|
collection = []
|
|
input.each do |object|
|
|
runner = visit(object)
|
|
collection << runner
|
|
if runner.stop?
|
|
@stop = true
|
|
break
|
|
end
|
|
end
|
|
collection
|
|
end
|
|
|
|
# Visit object
|
|
#
|
|
# @param [Object] object
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def visit(object)
|
|
Runner.run(config, object)
|
|
end
|
|
|
|
end # Runner
|
|
end # Mutant
|