Contents

# frozen_string_literal: true

require 'timecop'
require 'queue-bus'
require 'adapter/support'

reset_test_adapter

module QueueBus
  class Runner
    def self.value
      @value ||= 0
    end

    def self.attributes
      @attributes
    end

    def self.run(attrs)
      @value ||= 0
      @value += 1
      @attributes = attrs
    end

    def self.reset
      @value = nil
      @attributes = nil
    end
  end

  class Runner1 < Runner
  end

  class Runner2 < Runner
  end
end

def test_sub(event_name, queue = 'default')
  matcher = { 'bus_event_type' => event_name }
  QueueBus::Subscription.new(queue, event_name, '::QueueBus::Rider', matcher, nil)
end

def test_list(*args)
  out = QueueBus::SubscriptionList.new
  args.each do |sub|
    out.add(sub)
  end
  out
end

RSpec.configure do |config|
  config.mock_with :rspec do |c|
    c.syntax = :expect
  end

  config.expect_with :rspec do |c|
    c.syntax = :expect
  end

  config.before(:each) do
    reset_test_adapter
  end

  config.after(:each) do
    begin
      QueueBus.redis(&:flushall)
    rescue RuntimeError # rubocop:disable Lint/HandleExceptions
      # We raise if redis isn't there.
    end
    QueueBus.send(:reset)
    QueueBus::Runner1.reset
    QueueBus::Runner2.reset
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
queue-bus-0.9.0	spec/spec_helper.rb
queue-bus-0.8.1	spec/spec_helper.rb
queue-bus-0.8.0	spec/spec_helper.rb
queue-bus-0.7.0	spec/spec_helper.rb