Contents

require_relative '../spec_helper'

module Kamerling describe TaskDispatcher do
  describe '#dispatch' do
    it 'dispatches tasks to free clients and marks them as busy' do
      addr    = fake :addr
      client  = fake :client, addr: addr, uuid: UUID['16B client  UUID']
      project = fake :project, uuid: UUID['16B project UUID']
      task    = fake :task, data: 'data', uuid: UUID['16B task    UUID']
      repos   = fake :repos, as: :class, projects: [project]
      stub(repos).next_task_for(project) { task }
      stub(repos).free_clients_for(project) { [client] }
      net_dispatcher = fake :net_dispatcher, as: :class

      TaskDispatcher.new(net_dispatcher: net_dispatcher, repos: repos).dispatch

      header = "DATA#{"\0" * 12}16B client  UUID16B project UUID16B task    "
      net_dispatcher.must_have_received :dispatch, [addr, header + 'UUIDdata']
      client.must_have_received :busy=, [true]
      repos.must_have_received :<<, [client]
    end
  end
end end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
kamerling-0.0.2	spec/kamerling/task_dispatcher_spec.rb