Class: RSpec::Sidekiq::Matchers::BeDelayed

Inherits:
Object
  • Object
show all
Defined in:
lib/rspec/sidekiq/matchers/be_delayed.rb

Instance Method Summary collapse

Constructor Details

#initialize(*expected_arguments) ⇒ BeDelayed

Returns a new instance of BeDelayed.



13
14
15
16
17
18
19
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 13

def initialize(*expected_arguments)
  raise <<~MSG if RSpec::Sidekiq.configuration.sidekiq_gte_7?
    Use of the be_delayed matcher with Sidekiq 7+ is not possible. Try refactoring to a Sidekiq Job with `perform_at` or `perform_in` and the `have_enqueued_sidekiq_job` matcher
  MSG

  @expected_arguments = expected_arguments
end

Instance Method Details

#description ⇒ Object 



21
22
23
24
25
26
27
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 21

def description
  description = 'be delayed'
  description += " for #{@expected_interval} seconds" if @expected_interval
  description += " until #{@expected_time}" if @expected_time
  description += " with arguments #{@expected_arguments}" unless @expected_arguments.empty?
  description
end

#failure_message ⇒ Object 



29
30
31
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 29

def failure_message
  "expected #{@expected_method_receiver}.#{@expected_method.name} to " + description
end

#failure_message_when_negated ⇒ Object 



56
57
58
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 56

def failure_message_when_negated
  "expected #{@expected_method_receiver}.#{@expected_method.name} to not " + description
end

#for(interval) ⇒ Object 



33
34
35
36
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 33

def for(interval)
  @expected_interval = interval
  self
end

#matches?(expected_method) ⇒ Boolean

Returns:

  • (Boolean) 


38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 38

def matches?(expected_method)
  @expected_method = expected_method
  @expected_method_receiver = @expected_method.is_a?(UnboundMethod) ? @expected_method.owner : @expected_method.receiver

  find_job @expected_method, @expected_arguments do |job|
    if @expected_interval
      created_enqueued_at = job['enqueued_at'] || job['created_at']
      return job['at'].to_i == Time.at(created_enqueued_at.to_f + @expected_interval.to_f).to_i
    elsif @expected_time
      return job['at'].to_i == @expected_time.to_i
    else
      return true
    end
  end

  false
end

#until(time) ⇒ Object 



60
61
62
63
 
# File 'lib/rspec/sidekiq/matchers/be_delayed.rb', line 60

def until(time)
  @expected_time = time
  self
end