module ParallelTests

def bundler_enabled?
  return true if Object.const_defined?(:Bundler)
  previous = nil
  current = File.expand_path(Dir.pwd)
  until !File.directory?(current) || current == previous
    filename = File.join(current, "Gemfile")
    return true if File.exist?(filename)
    current, previous = File.expand_path("..", current), current
  end
  false
end

def delta
  before = now.to_f
  yield
  now.to_f - before
end

def determine_number_of_processes(count)
  [
    count,
    ENV["PARALLEL_TEST_PROCESSORS"],
    Parallel.processor_count
  ].detect{|c| not c.to_s.strip.empty? }.to_i
end

def first_process?
  ENV["TEST_ENV_NUMBER"].to_i <= 1
end

def last_process?
  current_process_number = ENV['TEST_ENV_NUMBER']
  total_processes = ENV['PARALLEL_TEST_GROUPS']
  return true if current_process_number.nil? && total_processes.nil?
  current_process_number = '1' if current_process_number.nil?
  current_process_number == total_processes
end

def now
  if Time.respond_to?(:now_without_mock_time) # Timecop
    Time.now_without_mock_time
  else
    Time.now
  end
end

def number_of_running_processes
  pids.count
end

def pid_file_path
  ENV['PARALLEL_PID_FILE'] ||= Tempfile.new('parallel-tests-pidfile').path
end

def pids
  @pids ||= Pids.new(pid_file_path)
end

def stop_all_processes
  pids.all.each { |pid| Process.kill(:INT, pid) }
end

def wait_for_other_processes_to_finish
  return unless ENV["TEST_ENV_NUMBER"]
  sleep 1 until number_of_running_processes <= 1
end

def with_ruby_binary(command)
  WINDOWS ? "#{RUBY_BINARY} -- #{command}" : command
end