diff options
Diffstat (limited to 'spec/services/ci/enqueue_job_service_spec.rb')
-rw-r--r-- | spec/services/ci/enqueue_job_service_spec.rb | 81 |
1 files changed, 81 insertions, 0 deletions
diff --git a/spec/services/ci/enqueue_job_service_spec.rb b/spec/services/ci/enqueue_job_service_spec.rb new file mode 100644 index 00000000000..c2bb0bb2bb5 --- /dev/null +++ b/spec/services/ci/enqueue_job_service_spec.rb @@ -0,0 +1,81 @@ +# frozen_string_literal: true + +require 'spec_helper' + +RSpec.describe Ci::EnqueueJobService, '#execute', feature_category: :continuous_integration do + let_it_be(:project) { create(:project) } + let(:user) { create(:user, developer_projects: [project]) } + let(:pipeline) { create(:ci_pipeline, project: project) } + let(:build) { create(:ci_build, :manual, pipeline: pipeline) } + + let(:service) do + described_class.new(build, current_user: user) + end + + subject(:execute) { service.execute } + + it 'assigns the user to the job' do + expect { execute }.to change { build.reload.user }.to(user) + end + + it 'calls enqueue!' do + expect(build).to receive(:enqueue!) + execute + end + + it 'calls Ci::ResetSkippedJobsService' do + expect_next_instance_of(Ci::ResetSkippedJobsService) do |service| + expect(service).to receive(:execute).with(build) + end + + execute + end + + it 'returns the job' do + expect(execute).to eq(build) + end + + context 'when variables are supplied' do + let(:job_variables) do + [{ key: 'first', secret_value: 'first' }, + { key: 'second', secret_value: 'second' }] + end + + let(:service) do + described_class.new(build, current_user: user, variables: job_variables) + end + + it 'assigns the variables to the job' do + execute + expect(build.reload.job_variables.map(&:key)).to contain_exactly('first', 'second') + end + end + + context 'when the job transition is invalid' do + let(:bridge) { create(:ci_bridge, :failed, pipeline: pipeline, project: project) } + + let(:service) do + described_class.new(bridge, current_user: user) + end + + it 'raises StateMachines::InvalidTransition' do + expect { execute }.to raise_error StateMachines::InvalidTransition + end + end + + context 'when a transition block is supplied' do + let(:bridge) { create(:ci_bridge, :playable, pipeline: pipeline) } + + let(:service) do + described_class.new(bridge, current_user: user) + end + + subject(:execute) { service.execute(&:pending!) } + + it 'calls the transition block instead of enqueue!' do + expect(bridge).to receive(:pending!) + expect(bridge).not_to receive(:enqueue!) + execute + end + end +end |