Contents

require 'spec_helper'

RSpec.describe 'ActiveJob routines' do

  context 'default configuration' do
    class LaterRoutine
      lev_routine active_job_enqueue_options: { queue: :something_else }, use_jobba: true

      protected
      def exec; end
    end

    it 'can perform routines later' do
      expect {
        LaterRoutine.perform_later
      }.to change { ActiveJob::Base.queue_adapter.enqueued_jobs.count }.by(1)
    end

    it 'can have the default queue name overridden in the class definition' do
      ActiveJob::Base.queue_adapter.enqueued_jobs.clear

      LaterRoutine.perform_later

      queue_name = ActiveJob::Base.queue_adapter.enqueued_jobs.first[:queue]

      expect(queue_name).to eq('something_else')
    end

    it 'can have the default queue name overridden using the set method' do
      ActiveJob::Base.queue_adapter.enqueued_jobs.clear

      LaterRoutine.set(queue: 'whoa').perform_later

      queue_name = ActiveJob::Base.queue_adapter.enqueued_jobs.first[:queue]

      expect(queue_name).to eq('whoa')
    end
  end

  context 'exception raised' do
    before { ::ActiveJob::Base.queue_adapter = :inline }
    after { ::ActiveJob::Base.queue_adapter = :test }

    class ExceptionalRoutine
      lev_routine use_jobba: true

      protected
      def exec
        raise TypeError, 'howdy there'
      end
    end

    it 'lets exception escape, job is failed and has error details' do
      Jobba.all.delete_all!

      expect{
        ExceptionalRoutine.perform_later
      }.to raise_error(TypeError)

      status = Jobba.all.run.to_a.first

      expect(status).to be_failed

      error = status.errors.first

      expect(error["code"]).to eq "exception"
      expect(error["message"]).to eq "howdy there"
      expect(error["data"]).to be_a String
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
lev-12.1.0	spec/active_job_routines_spec.rb
lev-12.0.0	spec/active_job_routines_spec.rb
lev-11.0.0	spec/active_job_routines_spec.rb
lev-10.1.0	spec/active_job_routines_spec.rb
lev-10.0.0	spec/active_job_routines_spec.rb
lev-9.0.4	spec/active_job_routines_spec.rb
lev-9.0.3	spec/active_job_routines_spec.rb
lev-9.0.2	spec/active_job_routines_spec.rb
lev-9.0.1	spec/active_job_routines_spec.rb
lev-9.0.0	spec/active_job_routines_spec.rb