0
@@ -304,10 +304,9 @@ module God
0
     #
0
     ###########################################################################
0
     
0
-    # Asynchronously evaluate and handle the given poll condition. Handles logging
0
+    # Evaluate and handle the given poll condition. Handles logging
0
     # notifications, and moving to the new state if necessary
0
     #   +condition+ is the Condition to handle
0
-    #   +phase+ is the phase of the Watch that should be matched
0
     #
0
     # Returns nothing
0
     def handle_poll(condition)
0
@@ -319,6 +318,7 @@ module God
0
       
0
       # log
0
       # messages = self.log_line(self, metric, condition, result)
0
+      messages = []
0
       
0
       # notify
0
       if condition.notify && self.trigger?(metric, result)
0
@@ -367,6 +367,7 @@ module God
0
       
0
       # log
0
       # messages = self.log_line(self, metric, condition, true)
0
+      messages = []
0
       
0
       # notify
0
       if condition.notify && self.trigger?(metric, true)

0
@@ -1,4 +1,4 @@
0
-('01'..'20').each do |i|
0
+('01'..'40').each do |i|
0
   God.watch do |w|
0
     w.name = "stress-#{i}"
0
     w.start = "ruby " + File.join(File.dirname(__FILE__), *%w[simple_server.rb])

0
@@ -2,7 +2,19 @@ require File.dirname(__FILE__) + '/helper'
0
 
0
 class TestTask < Test::Unit::TestCase
0
   def setup
0
+    God::Socket.stubs(:new).returns(true)
0
     God.internal_init
0
+    God.reset
0
+    
0
+    God.watch do |w|
0
+      w.name = 'foo'
0
+      w.start = 'bar'
0
+      w.interval = 10
0
+    end
0
+    
0
+    @watch = God.watches['foo']
0
+    
0
+    
0
     @task = Task.new
0
     @task.name = 'foo'
0
     @task.valid_states = [:foo, :bar]
0
@@ -92,4 +104,171 @@ class TestTask < Test::Unit::TestCase
0
     @task.driver.expects(:message).with(:action, [:foo, nil])
0
     @task.action(:foo, nil)
0
   end
0
+  
0
+  # attach
0
+  
0
+  def test_attach_should_schedule_for_poll_condition
0
+    c = Conditions::FakePollCondition.new
0
+    @task.driver.expects(:schedule).with(c, 0)
0
+    @task.attach(c)
0
+  end
0
+  
0
+  def test_attach_should_regsiter_for_event_condition
0
+    c = Conditions::FakeEventCondition.new
0
+    c.expects(:register)
0
+    @task.attach(c)
0
+  end
0
+  
0
+  # detach
0
+  
0
+  def test_detach_should_reset_poll_condition
0
+    c = Conditions::FakePollCondition.new
0
+    c.expects(:reset)
0
+    c.expects(:deregister).never
0
+    @task.detach(c)
0
+  end
0
+  
0
+  def test_detach_should_deregister_event_conditions
0
+    c = Conditions::FakeEventCondition.new
0
+    c.expects(:deregister).once
0
+    @task.detach(c)
0
+  end
0
+  
0
+  # trigger
0
+  
0
+  def test_trigger_should_send_message_to_driver
0
+    c = Conditions::FakePollCondition.new
0
+    @task.driver.expects(:message).with(:handle_event, [c])
0
+    @task.trigger(c)
0
+  end
0
+  
0
+  # handle_poll
0
+  
0
+  def test_handle_poll_no_change_should_reschedule
0
+    c = Conditions::FakePollCondition.new
0
+    c.watch = @task
0
+    c.interval = 10
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    c.expects(:test).returns(false)
0
+    @task.driver.expects(:schedule)
0
+    
0
+    no_stdout do
0
+      @task.handle_poll(c)
0
+    end
0
+  end
0
+  
0
+  def test_handle_poll_change_should_move
0
+    c = Conditions::FakePollCondition.new
0
+    c.watch = @task
0
+    c.interval = 10
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    c.expects(:test).returns(true)
0
+    @task.expects(:move).with(:up)
0
+    
0
+    no_stdout do
0
+      @task.handle_poll(c)
0
+    end
0
+  end
0
+  
0
+  def test_handle_poll_should_use_overridden_transition
0
+    c = Conditions::Tries.new
0
+    c.watch = @task
0
+    c.times = 1
0
+    c.transition = :start
0
+    c.prepare
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    @task.expects(:move).with(:start)
0
+    
0
+    no_stdout do
0
+      @task.handle_poll(c)
0
+    end
0
+  end
0
+  
0
+  def test_handle_poll_should_notify_if_triggering
0
+    c = Conditions::FakePollCondition.new
0
+    c.watch = @task
0
+    c.interval = 10
0
+    c.notify = 'tom'
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    c.expects(:test).returns(true)
0
+    @task.expects(:notify)
0
+    
0
+    no_stdout do
0
+      @task.handle_poll(c)
0
+    end
0
+  end
0
+  
0
+  def test_handle_poll_should_not_notify_if_not_triggering
0
+    c = Conditions::FakePollCondition.new
0
+    c.watch = @task
0
+    c.interval = 10
0
+    c.notify = 'tom'
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    c.expects(:test).returns(false)
0
+    @task.expects(:notify).never
0
+    
0
+    no_stdout do
0
+      @task.handle_poll(c)
0
+    end
0
+  end
0
+  
0
+  # handle_event
0
+  
0
+  def test_handle_event_should_move
0
+    c = Conditions::FakeEventCondition.new
0
+    c.watch = @task
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    @task.expects(:move).with(:up)
0
+    
0
+    no_stdout do
0
+      @task.handle_event(c)
0
+    end
0
+  end
0
+  
0
+  def test_handle_event_should_notify_if_triggering
0
+    c = Conditions::FakeEventCondition.new
0
+    c.watch = @task
0
+    c.notify = 'tom'
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    @task.expects(:notify)
0
+    
0
+    no_stdout do
0
+      @task.handle_event(c)
0
+    end
0
+  end
0
+  
0
+  def test_handle_event_should_not_notify_if_no_notify_set
0
+    c = Conditions::FakeEventCondition.new
0
+    c.watch = @task
0
+    
0
+    m = Metric.new(@task, {true => :up})
0
+    @task.directory[c] = m
0
+    
0
+    @task.expects(:notify).never
0
+    
0
+    no_stdout do
0
+      @task.handle_event(c)
0
+    end
0
+  end
0
 end
0
\ No newline at end of file