mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Added inline testing functionality.
Allows sidekiq jobs to run inline in test mode without having to modify the production code. In other words production code can still call the `perform_async` method and tests can still verify that functionality is run inline.
This commit is contained in:
parent
e187706f4f
commit
c4e6fae37c
2 changed files with 112 additions and 0 deletions
37
lib/sidekiq/testing/inline.rb
Normal file
37
lib/sidekiq/testing/inline.rb
Normal file
|
@ -0,0 +1,37 @@
|
|||
module Sidekiq
|
||||
module Worker
|
||||
|
||||
##
|
||||
# The Sidekiq inline infrastructure overrides the perform_async so that it
|
||||
# actually calls perform instead. This allows workers to be run inline in a
|
||||
# testing environment.
|
||||
#
|
||||
# This is similar to `Resque.inline = true` functionality.
|
||||
#
|
||||
# Example:
|
||||
#
|
||||
# require 'sidekiq/testing/inline'
|
||||
#
|
||||
# $external_variable = 0
|
||||
#
|
||||
# class ExternalWorker
|
||||
# include Sidekiq::Worker
|
||||
#
|
||||
# def perform
|
||||
# $external_variable = 1
|
||||
# end
|
||||
# end
|
||||
#
|
||||
# assert_equal 0, $external_variable
|
||||
# ExternalWorker.perform_async
|
||||
# assert_equal 1, $external_variable
|
||||
#
|
||||
module ClassMethods
|
||||
alias_method :perform_async_old, :perform_async
|
||||
def perform_async(*args)
|
||||
new.perform(*args)
|
||||
true
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
75
test/test_testing_inline.rb
Normal file
75
test/test_testing_inline.rb
Normal file
|
@ -0,0 +1,75 @@
|
|||
require 'helper'
|
||||
require 'sidekiq'
|
||||
require 'sidekiq/worker'
|
||||
require 'active_record'
|
||||
require 'action_mailer'
|
||||
require 'sidekiq/rails'
|
||||
require 'sidekiq/extensions/action_mailer'
|
||||
require 'sidekiq/extensions/active_record'
|
||||
|
||||
Sidekiq.hook_rails!
|
||||
|
||||
class TestInline < MiniTest::Unit::TestCase
|
||||
describe 'sidekiq inline testing' do
|
||||
class InlineError < RuntimeError; end
|
||||
|
||||
class InlineWorker
|
||||
include Sidekiq::Worker
|
||||
def perform(pass)
|
||||
raise InlineError unless pass
|
||||
end
|
||||
end
|
||||
|
||||
class InlineFooMailer < ActionMailer::Base
|
||||
def bar(str)
|
||||
raise InlineError
|
||||
end
|
||||
end
|
||||
|
||||
class InlineFooModel < ActiveRecord::Base
|
||||
def self.bar(str)
|
||||
raise InlineError
|
||||
end
|
||||
end
|
||||
|
||||
before do
|
||||
load 'sidekiq/testing/inline.rb'
|
||||
end
|
||||
|
||||
after do
|
||||
Sidekiq::Worker::ClassMethods.class_eval do
|
||||
remove_method :perform_async
|
||||
alias_method :perform_async, :perform_async_old
|
||||
remove_method :perform_async_old
|
||||
end
|
||||
end
|
||||
|
||||
it 'stubs the async call when in testing mode' do
|
||||
assert InlineWorker.perform_async(true)
|
||||
|
||||
assert_raises InlineError do
|
||||
InlineWorker.perform_async(false)
|
||||
end
|
||||
end
|
||||
|
||||
it 'stubs the delay call on mailers' do
|
||||
assert_raises InlineError do
|
||||
InlineFooMailer.delay.bar('three')
|
||||
end
|
||||
end
|
||||
|
||||
it 'stubs the delay call on models' do
|
||||
assert_raises InlineError do
|
||||
InlineFooModel.delay.bar('three')
|
||||
end
|
||||
end
|
||||
|
||||
it 'stubs the enqueue call when in testing mode' do
|
||||
assert Sidekiq::Client.enqueue(InlineWorker, true)
|
||||
|
||||
assert_raises InlineError do
|
||||
Sidekiq::Client.enqueue(InlineWorker, false)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
Loading…
Add table
Reference in a new issue