require File.dirname(__FILE__) + '/test_helper.rb'

context "the remote runner" do
  specify "should be able to invoke a task on a worker" do
    Util.any_instance.stubs(:echo).with("hello")
    Workling::Remote.run(:util, :echo, "hello")
  end
  
  specify "should invoke the dispatcher set up in Workling::Remote.dispatcher" do
    clazz, method, options = :util, :echo, { :message => "somebody_came@along.com" }
    old_dispatcher = Workling::Remote.dispatcher
    dispatcher = mock
    dispatcher.expects(:run).with(clazz, method, options)
    Workling::Remote.dispatcher = dispatcher
    Workling::Remote.run(clazz, method, options)
    Workling::Remote.dispatcher = old_dispatcher # set back to whence we came
  end
  
  specify "should, when being tested, use the default remote runner by when no runner was explicitly set. " do
    Workling::Remote.dispatcher.class.should.equal Workling.default_runner.class
  end
  
  specify "should raise a Workling::WorklingNotFoundError if it is invoked with a worker key that canont be constantized" do
    should.raise Workling::WorklingNotFoundError do
      Workling::Remote.run(:quatsch_mit_sosse, :fiddle_di_liddle)
    end
  end
  
  specify "should raise a Workling::WorklingNotFoundError if it is invoked with a valid worker key but the method is not defined on that worker" do
    dispatcher = Workling::Remote.dispatcher
    Workling::Remote.dispatcher = Workling::Remote::Runners::NotRemoteRunner.new
    
    should.raise Workling::WorklingNotFoundError do
      Workling::Remote.run(:util, :sau_sack)
    end
    
    Workling::Remote.dispatcher = dispatcher
  end
  
  specify "should invoke work when called in this way: YourWorkling.asynch_your_method(options)" do
    Util.any_instance.expects(:echo).once
    Util.asynch_echo
  end
  
  specify "should invoke work with the arguments intact when called in this way: YourWorkling.asynch_your_method(options)" do
    stuffing = { :description => "toasted breadcrumbs with dill" }
    Util.any_instance.expects(:stuffing).with(stuffing).once
    Util.asynch_stuffing(stuffing)
  end
end