spec_helper.rb

# Encoding: utf-8

begin
  # use `bundle install --standalone' to get this...
  require_relative '../bundle/bundler/setup'
rescue LoadError
  # fall back to regular bundler if the developer hasn't bundled standalone
  require 'bundler'
  Bundler.setup
end

require 'rspec/fire'

module QlessSpecHelpers
  def with_env_vars(vars)
    original = ENV.to_hash
    vars.each { |k, v| ENV[k] = v }

    begin
      yield
    ensure
      ENV.replace(original)
    end
  end

  def redis_config
    return @redis_config unless @redis_config.nil?
    if File.exist?('./spec/redis.config.yml')
      @redis_config = YAML.load_file('./spec/redis.config.yml')
    else
      @redis_config = {}
    end
  end

  def redis_url
    return 'redis://localhost:6379/0' if redis_config.empty?
    redis_config.tap do |c|
      "redis://#{c[:host]}:#{c[:port]}/#{c.fetch(:db, 0)}"
    end
  end

  def clear_qless_memoization
    Qless.instance_eval do
      instance_variables.each do |ivar|
        remove_instance_variable(ivar)
      end
    end
  end
end

RSpec.configure do |c|
  c.treat_symbols_as_metadata_keys_with_true_values = true
  c.filter_run :f
  c.run_all_when_everything_filtered = true
  c.include RSpec::Fire
  c.include QlessSpecHelpers

  c.before(:each, :js) do
    pending 'Skipping JS test because JS tests have been flaky on Travis.'
  end if ENV['TRAVIS']
end

shared_context 'redis integration', :integration do
  def new_client
    Qless::Client.new(redis_config)
  end

  def new_redis
    Redis.new(redis_config)
  end

  # A qless client subject to the redis configuration
  let(:client) { new_client }
  # A plain redis client with the same redis configuration
  let(:redis)  { new_redis }

  # Ensure we've got an empty redis database and remove any old scripts
  before(:each) do
    pending 'Must start with empty Redis DB' if redis.keys('*').length > 0
    redis.script(:flush)
  end

  # Empty the redis DB after we're done
  after(:each) do
    redis.flushdb
  end
end

# This context kills all the non-main threads and ensure they're cleaned up
shared_context 'stops all non-main threads', :uses_threads do
  after(:each) do
    # We're going to kill all the non-main threads
    threads = Thread.list - [Thread.main]
    threads.each(&:kill)
    threads.each(&:join)
  end
end