require 'set'
require 'tork/engine'
require 'tork/server'
require 'tork/config'

module Tork
class Driver < Server

  REABSORB_FILE_GREPS = []
  ALL_TEST_FILE_GLOBS = []
  TEST_FILE_GLOBBERS = {}

  def initialize
    super
    Tork.config :driver
  end

  def loop
    @herald = popen('tork-herald')
    @engine = popen('tork-engine')
    super
  ensure
    pclose @herald
    pclose @engine
  end

  def run_all_test_files
    all_test_files = Dir[*ALL_TEST_FILE_GLOBS]
    if all_test_files.empty?
      tell @client, 'There are no test files to run.'
    else
      run_test_files all_test_files
    end
  end

  # accept and delegate tork-engine(1) commands
  Engine.public_instance_methods(false).each do |name|
    unless method_defined? name
      define_method name do |*args|
        send @engine, [name, *args]
      end
    end
  end

protected

  def recv client, message
    case client
    when @engine
      send @clients, message # propagate downstream

    when @herald
      message.each do |changed_file|
        # reabsorb text execution overhead if overhead files changed
        overhead_changed = REABSORB_FILE_GREPS.any? do |pattern|
          if pattern.kind_of? Regexp
            pattern =~ changed_file
          else
            pattern == changed_file
          end
        end

        if overhead_changed
          send @clients, [:reabsorb, changed_file]
          reabsorb_overhead
        else
          run_test_files find_dependent_test_files(changed_file).to_a
        end
      end

    else
      super
    end
  end

private

  def find_dependent_test_files source_file, results=Set.new
    TEST_FILE_GLOBBERS.each do |regexp, globber|
      if regexp =~ source_file and globs = globber.call($~)
        Dir[*globs].each do |dependent_file|
          if results.add? dependent_file
            find_dependent_test_files dependent_file, results
          end
        end
      end
    end
    results
  end

end
end