module ParallelTests

def self.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.exists?(filename)
    current, previous = File.expand_path("..", current), current
  end
  false
end

def self.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 self.first_process?
  !ENV["TEST_ENV_NUMBER"] || ENV["TEST_ENV_NUMBER"].to_i == 0
end

def self.number_of_running_processes
  if RUBY_ENGINE == "jruby"
    Thread.list.count { |t| t[:running_parallel_test] }
  else
    result = `#{GREP_PROCESSES_COMMAND}`
    raise "Could not grep for processes -> #{result}" if result.strip != "" && !$?.success?
    result.split("\n").size
  end
end

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