187 lines
3.6 KiB
Ruby
187 lines
3.6 KiB
Ruby
module Mutant
|
|
# Runner baseclass
|
|
class Runner
|
|
include Adamantium::Flat, Concord.new(:env), Procto.call(:result)
|
|
|
|
# Initialize object
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def initialize(env)
|
|
super
|
|
|
|
@collector = Collector.new(env)
|
|
@mutex = Mutex.new
|
|
@mutations = env.mutations.dup
|
|
|
|
config.integration.setup
|
|
|
|
config.reporter.start(env)
|
|
|
|
run
|
|
|
|
@result = @collector.result.update(done: true)
|
|
|
|
config.reporter.report(result)
|
|
end
|
|
|
|
# Return result
|
|
#
|
|
# @return [Result::Env]
|
|
#
|
|
# @api private
|
|
#
|
|
attr_reader :result
|
|
|
|
private
|
|
|
|
# Run mutation analysis
|
|
#
|
|
# @return [Report::Subject]
|
|
#
|
|
# @api private
|
|
#
|
|
def run
|
|
Parallel.map(
|
|
@mutations,
|
|
in_processes: config.processes,
|
|
finish: method(:finish),
|
|
start: method(:start),
|
|
&method(:run_mutation)
|
|
)
|
|
end
|
|
|
|
# Handle started mutation
|
|
#
|
|
# @param [Mutation] mutation
|
|
# @param [Fixnum] _index
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def start(mutation, _index)
|
|
@mutex.synchronize do
|
|
@collector.start(mutation)
|
|
end
|
|
end
|
|
|
|
# Handle finished mutation
|
|
#
|
|
# @param [Mutation] mutation
|
|
# @param [Fixnum] index
|
|
# @param [Object] result
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def finish(mutation, index, result)
|
|
return unless result.kind_of?(Mutant::Result::Mutation)
|
|
|
|
test_results = result.test_results.zip(mutation.subject.tests).map do |test_result, test|
|
|
test_result.update(test: test, mutation: mutation) if test_result
|
|
end.compact
|
|
|
|
@mutex.synchronize do
|
|
process_result(result.update(index: index, mutation: mutation, test_results: test_results))
|
|
end
|
|
end
|
|
|
|
# Process result
|
|
#
|
|
# @param [Result::Mutation] result
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def process_result(result)
|
|
@collector.finish(result)
|
|
config.reporter.progress(@collector)
|
|
handle_exit(result)
|
|
end
|
|
|
|
# Handle exit if needed
|
|
#
|
|
# @param [Result::Mutation] result
|
|
#
|
|
# @return [undefined]
|
|
#
|
|
# @api private
|
|
#
|
|
def handle_exit(result)
|
|
return if !config.fail_fast || result.success?
|
|
|
|
@mutations.clear
|
|
end
|
|
|
|
# Run mutation
|
|
#
|
|
# @param [Mutation] mutation
|
|
#
|
|
# @return [Report::Mutation]
|
|
#
|
|
# @api private
|
|
#
|
|
def run_mutation(mutation)
|
|
Result::Mutation.compute do
|
|
{
|
|
index: nil,
|
|
mutation: nil,
|
|
test_results: kill_mutation(mutation)
|
|
}
|
|
end
|
|
end
|
|
|
|
# Kill mutation
|
|
#
|
|
# @param [Mutation] mutation
|
|
#
|
|
# @return [Array<Result::Test>]
|
|
#
|
|
# @api private
|
|
#
|
|
def kill_mutation(mutation)
|
|
mutation.subject.tests.each_with_object([]) do |test, results|
|
|
results << result = run_mutation_test(mutation, test)
|
|
return results if mutation.killed_by?(result)
|
|
end
|
|
end
|
|
|
|
# Return config
|
|
#
|
|
# @return [Config]
|
|
#
|
|
# @api private
|
|
#
|
|
def config
|
|
env.config
|
|
end
|
|
|
|
# Return test result
|
|
#
|
|
# @return [Report::Test]
|
|
#
|
|
# @api private
|
|
#
|
|
def run_mutation_test(mutation, test)
|
|
time = Time.now
|
|
config.isolation.call do
|
|
mutation.insert
|
|
test.run
|
|
end
|
|
rescue Isolation::Error => exception
|
|
Result::Test.new(
|
|
test: nil,
|
|
mutation: nil,
|
|
runtime: Time.now - time,
|
|
output: exception.message,
|
|
passed: false
|
|
)
|
|
end
|
|
|
|
end # Runner
|
|
end # Mutant
|