Contents

require 'spec_helper'

describe Taskinator::CreateProcessWorker do

  let(:definition) { MockDefinition.create }
  let(:uuid) { SecureRandom.uuid }
  let(:args) { {:foo => :bar} }

  subject { Taskinator::CreateProcessWorker.new(definition.name, uuid, Taskinator::Persistence.serialize(:foo => :bar)) }

  describe "#initialize" do
    it {
      expect(subject.definition).to eq(definition)
    }

    it {
      Taskinator::CreateProcessWorker.new(definition.name, uuid, Taskinator::Persistence.serialize(:foo => :bar))
      expect(subject.definition).to eq(definition)
    }

    it {
      MockDefinition.const_set(definition.name, definition)
      Taskinator::CreateProcessWorker.new("MockDefinition::#{definition.name}", uuid, Taskinator::Persistence.serialize(:foo => :bar))
      expect(subject.definition).to eq(definition)
    }

    it {
      expect {
        Taskinator::CreateProcessWorker.new("NonExistent", uuid, Taskinator::Persistence.serialize(:foo => :bar))
      }.to raise_error(NameError)
    }

    it {
      expect(subject.uuid).to eq(uuid)
    }

    it {
      expect(subject.args).to eq(args)
    }
  end

  describe "#perform" do
    it "should create the process" do
      expect(definition).to receive(:_create_process_).with(false, *args, :uuid => uuid).and_return(double('process', :enqueue! => nil))
      subject.perform
    end

    it "should enqueue the process" do
      expect_any_instance_of(Taskinator::Process).to receive(:enqueue!)
      subject.perform
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
taskinator-0.3.1	spec/taskinator/create_process_worker_spec.rb
taskinator-0.3.0	spec/taskinator/create_process_worker_spec.rb
taskinator-0.2.0	spec/taskinator/create_process_worker_spec.rb