require "spec_helper"

describe "Invoker::Commander" do
  
  describe "With no processes configured" do
    before do
      @commander = Invoker::Commander.new()
    end
    
    it "should throw error" do
      invoker_config.stubs(:processes).returns([])

      lambda {
        @commander.start_manager()
      }.should.raise(Invoker::Errors::InvalidConfig)
    end
  end

  describe "#add_command_by_label" do
    before do
      @commander = Invoker::Commander.new()
    end

    it "should find command by label and start it, if found" do
      invoker_config.stubs(:processes).returns([OpenStruct.new(:label => "resque", :cmd => "foo", :dir => "bar")])
      @commander.expects(:add_command).returns(true)
      
      @commander.add_command_by_label("resque")
    end
  end

  describe "#remove_command" do
    describe "when a worker is found" do
      before do
        @commander = Invoker::Commander.new()
        @commander.workers.expects(:[]).returns(OpenStruct.new(:pid => "bogus"))
      end

      describe "if a signal is specified" do
        it "should use that signal to kill the worker" do
          @commander.expects(:process_kill).with("bogus", "HUP").returns(true)
          @commander.remove_command("resque", "HUP")
        end
      end

      describe "if no signal is specified" do
        it "should use INT signal" do
          @commander.expects(:process_kill).with("bogus", "INT").returns(true)
          @commander.remove_command("resque", nil)
        end
      end
    end

    describe "when no worker is found" do
      before do
        @commander = Invoker::Commander.new()
        @commander.workers.expects(:[]).returns(nil)
      end

      it "should not kill anything" do
        @commander.expects(:process_kill).never()
        @commander.remove_command("resque", "HUP")
      end
    end

  end

  describe "#add_command" do
    before do
      invoker_config.stubs(:processes).returns([OpenStruct.new(:label => "sleep", :cmd => "sleep 4", :dir => ENV['HOME'])])
      @commander = Invoker::Commander.new()
    end

    it "should populate workers and open_pipes" do
      @commander.reactor.expects(:start).returns(true)
      @commander.start_manager()
      @commander.open_pipes.should.not.be.empty
      @commander.workers.should.not.be.empty

      worker = @commander.workers['sleep']

      worker.should.not.equal nil
      worker.command_label.should.equal "sleep"
      worker.color.should.equal "green"


      pipe_end_worker = @commander.open_pipes[worker.pipe_end.fileno]
      pipe_end_worker.should.not.equal nil
    end
  end

end