require 'eventmachine'
module VirtualMonkey
  module Command
  
# trollop supports Chronic for human readable dates. use with run command for delayed run?

# monkey run --feature --tag --only <regex to match on deploy nickname>
    def self.run
      options = Trollop::options do
        opt :feature, "path to feature(s) to run against the deployments", :type => :string, :required => true
        opt :breakpoint, "feature file line to stop at", :type => :integer, :short => '-b'
        opt :tag, "Tag to match prefix of the deployments.", :type => :string, :required => true, :short => "-t"
        opt :only, "regex string to use for subselection matching on deployments.  Eg. --only x86_64", :type => :string
        opt :terminate, "Terminate using the specified runner if feature successfully completes. (No destroy)", :type => :string, :short => "-r"
        opt :no_resume, "Do not use current test-in-progress, start from scratch", :short => "-n"
        opt :yes, "Turn off confirmation", :short => "-y"
      end

      global_state_dir = File.join(File.dirname(__FILE__), "..", "..", "..", "test_states")
      begin
        eval("VirtualMonkey::#{options[:terminate]}.new('fgasvgreng243o520sdvnsals')") if options[:terminate]
      rescue Exception => e
        raise e unless e.message =~ /Could not find a deployment named/
        options[:terminate] = "SimpleRunner" if options[:terminate]
      end
      EM.run {
        cm = CukeMonk.new
        dm = DeploymentMonk.new(options[:tag])
        if options[:only]
          do_these = dm.deployments.select { |d| d.nickname =~ /#{options[:only]}/ }
        else
          do_these = dm.deployments
        end

        unless options[:no_resume]
          temp = do_these.select do |d|
            File.exist?(File.join(global_state_dir, d.nickname, File.basename(options[:feature])))
          end
          do_these = temp if temp.length > 0
        end

        cm.options = options
        raise "No deployments matched!" unless do_these.length > 0
        do_these.each { |d| say d.nickname }

        unless options[:yes]
          confirm = ask("Run tests on these #{do_these.length} deployments (y/n)?", lambda { |ans| true if (ans =~ /^[y,Y]{1}/) })
          raise "Aborting." unless confirm
        end

        remaining_jobs = cm.jobs.dup
        do_these.each do |deploy|
          cm.run_test(deploy, options[:feature])
        end

        watch = EM.add_periodic_timer(10) {
          cm.watch_and_report
          if cm.all_done?
            watch.cancel
          end
          if options[:terminate]
            remaining_jobs.each do |job|
              if job.status == 0
                @runner = eval("VirtualMonkey::#{options[:terminate]}.new(job.deployment.nickname)")
                puts "destroying successful deployment: #{@runner.deployment.nickname}"
                @runner.behavior(:stop_all, false)
                remaining_jobs.delete(job)
              end
            end
          end
        }

      }
    end
  end
end