# frozen_string_literal: true

require 'spec_helper'

module QueueBus
  module Adapters
    class TestOne
    end
  end
end

describe 'QueueBus config' do
  it 'should set the default app key' do
    expect(QueueBus.default_app_key).to eq(nil)

    QueueBus.default_app_key = 'my_app'
    expect(QueueBus.default_app_key).to eq('my_app')

    QueueBus.default_app_key = 'something here'
    expect(QueueBus.default_app_key).to eq('something_here')
  end

  it 'should set the default queue' do
    expect(QueueBus.default_queue).to eq(nil)

    QueueBus.default_queue = 'my_queue'
    expect(QueueBus.default_queue).to eq('my_queue')
  end

  it 'should set the local mode' do
    expect(QueueBus.local_mode).to eq(nil)
    QueueBus.local_mode = :standalone
    expect(QueueBus.local_mode).to eq(:standalone)
  end

  it 'should set the hostname' do
    expect(QueueBus.hostname).not_to eq(nil)
    QueueBus.hostname = 'whatever'
    expect(QueueBus.hostname).to eq('whatever')
  end

  it 'should set before_publish callback' do
    QueueBus.before_publish = ->(_attributes) { 42 }
    expect(QueueBus.before_publish_callback({})).to eq(42)
  end

  it 'should use the default Redis connection' do
    expect(QueueBus.redis { |redis| redis }).not_to eq(nil)
  end

  it 'should default to given adapter' do
    expect(QueueBus.adapter.is_a?(adapter_under_test_class)).to eq(true)

    # and should raise if already set
    expect do
      QueueBus.adapter = :data
    end.to raise_error('Adapter already set to QueueBus::Adapters::Sidekiq')
  end

  context 'with a fresh load' do
    before(:each) do
      QueueBus.send(:reset)
    end

    it 'should be able to be set to resque' do
      QueueBus.adapter = adapter_under_test_symbol
      expect(QueueBus.adapter.is_a?(adapter_under_test_class)).to eq(true)

      # and should raise if already set
      expect do
        QueueBus.adapter = :data
      end.to raise_error('Adapter already set to QueueBus::Adapters::Sidekiq')
    end

    it 'should be able to be set to something else' do
      QueueBus.adapter = :test_one
      expect(QueueBus.adapter.is_a?(QueueBus::Adapters::TestOne)).to eq(true)
    end
  end
end