require 'rails_helper'

module Kuroko2::Workflow::Task
  describe Queue do
    describe '#execute' do
      subject { token.context['QUEUE'] }

      let(:token) { build(:token, script: 'queue:') }
      let(:queue) { Kuroko2::Execution::DEFAULT_QUEUE }

      before do
        Kuroko2::Worker.create!(hostname: 'test', worker_id: 1, queue: queue, working: true)
      end

      context 'valid case' do
        before { Kuroko2::Workflow::Task::Queue.new(node, token).execute }

        context 'with default queue' do
          let(:node) { Kuroko2::Workflow::Node.new(:queue) }

          it { is_expected.to eq queue }
        end

        context 'with given queue' do
          let(:queue) { 'queue_name' }
          let(:node) { Kuroko2::Workflow::Node.new(:queue, queue) }

          it { is_expected.to eq queue }
        end
      end

      context 'with default queue' do
        let(:node) { Kuroko2::Workflow::Node.new(:queue, '@default') }
        it { expect { Kuroko2::Workflow::Task::Queue.new(node, token).validate }.not_to raise_error }
      end

      context 'with valid queue' do
        before { create(:worker, queue: 'myqueue') }
        let(:node) { Kuroko2::Workflow::Node.new(:queue, 'myqueue') }
        it { expect { Kuroko2::Workflow::Task::Queue.new(node, token).validate }.not_to raise_error }
      end

      context 'with invalid queue' do
        let(:node) { Kuroko2::Workflow::Node.new(:queue, '!invalid!') }

        it { expect { Kuroko2::Workflow::Task::Queue.new(node, token).validate }.to raise_error(Kuroko2::Workflow::AssertionError) }
      end

      context 'with no existance queue' do
        let(:node) { Kuroko2::Workflow::Node.new(:queue, 'invalid') }

        it { expect { Kuroko2::Workflow::Task::Queue.new(node, token).validate }.to raise_error(Kuroko2::Workflow::AssertionError) }
      end
    end
  end
end