commander_spec.rb in invoker-0.1.1.pre

- old
+ new

@@ -37,20 +37,31 @@
       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")
+          @commander.remove_command("resque", "HUP").should.be.true
         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)
+          @commander.remove_command("resque", nil).should.be.true
         end
       end
+
+      # describe "when a worker is not found" do
+      #   before do
+      #     @commander = Invoker::Commander.new()
+      #     @commander.workers.expects(:[]).returns(OpenStruct.new(:pid => "bogus"))
+      #   end
+
+      #   it "should return false" do
+          
+      #   end
+      # end
     end
 
     describe "when no worker is found" do
       before do
         @commander = Invoker::Commander.new()
@@ -67,14 +78,19 @@
 
   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()
+      Invoker.const_set(:COMMANDER, @commander)
     end
 
+    after do
+      Invoker.send(:remove_const,:COMMANDER)
+    end
+
     it "should populate workers and open_pipes" do
-      @commander.reactor.expects(:start).returns(true)
+      @commander.expects(:start_event_loop)
       @commander.start_manager()
       @commander.open_pipes.should.not.be.empty
       @commander.workers.should.not.be.empty
 
       worker = @commander.workers['sleep']
@@ -84,9 +100,35 @@
       worker.color.should.equal "green"
 
 
       pipe_end_worker = @commander.open_pipes[worker.pipe_end.fileno]
       pipe_end_worker.should.not.equal nil
+    end
+  end
+
+  describe "#runnables" do
+    before do
+      @commander = Invoker::Commander.new()
+    end
+
+    it "should run runnables in reactor tick with one argument" do
+      @commander.on_next_tick("foo") { |cmd| add_command_by_label(cmd) }
+      @commander.expects(:add_command_by_label).returns(true)
+      @commander.run_runnables()
+    end
+
+    it "should run runnables with multiple args" do
+      @commander.on_next_tick("foo", "bar", "baz") { |t1,*rest|
+        remove_command(t1, rest)
+      }
+      @commander.expects(:remove_command).with("foo", ["bar", "baz"]).returns(true)
+      @commander.run_runnables()
+    end
+
+    it "should run runnable with no args" do
+      @commander.on_next_tick() { hello() }
+      @commander.expects(:hello).returns(true)
+      @commander.run_runnables()
     end
   end
 
 end