require 'helper'

class TestManager < MiniTest::Unit::TestCase

  def setup
    @manager = Sideband::Manager.new
  end

  def test_has_queue
    assert_kind_of Sideband::Queue, @manager.queue
  end

  def test_has_thread
    assert_kind_of Sideband::Thread, @manager.thread
  end

  def test_can_queue_and_process_proc
    work = 'work'
    @manager.queue << -> { work = 'finished' }
    sleep 0.1
    assert_equal 'finished', work 
  end

  def test_can_queue_and_process_worker
    worker = EmailWorker.new
    assert_equal 'work', worker.work
    @manager.queue << worker
    sleep 0.1
    assert_equal 'finished', worker.work 
  end

  def test_fork_handling
    queue  = @manager.queue
    thread = @manager.thread

    Process.stub(:pid, Process.pid + 1) do
      @manager.queue << -> { 'work' }
      refute_equal queue,  @manager.queue
      refute_equal thread, @manager.thread
    end
  end

  def test_killed
    @manager.kill
    assert_nil @manager.queue
    assert_nil @manager.thread
  end

end