Split spec for ee

spec/services/ci/pipeline_trigger_service_spec.rb

@@ -80,89 +80,4 @@ describe Ci::PipelineTriggerService, services: true do
       end
     end
   end
-
-  describe '#execute EE' do
-    let(:user) { create(:user) }
-    let!(:pipeline) { create(:ci_empty_pipeline, project: project) }
-    let(:job) { create(:ci_build, :running, pipeline: pipeline, user: user) }
-    let(:result) { described_class.new(project, user, params).execute }
-
-    before do
-      project.add_developer(user)
-    end
-
-    context 'when job user does not have a permission to read a project' do
-      let(:params) { { token: job.token, ref: 'master', variables: nil } }
-      let(:job) { create(:ci_build, pipeline: pipeline, user: create(:user)) }
-
-      it 'does nothing' do
-        expect { result }.not_to change { Ci::Pipeline.count }
-      end
-    end
-
-    context 'when job is not running' do
-      let(:params) { { token: job.token, ref: 'master', variables: nil } }
-      let(:job) { create(:ci_build, :success, pipeline: pipeline, user: user) }
-
-      it 'does nothing' do
-        expect { result }.not_to change { Ci::Pipeline.count }
-        expect(result[:message]).to eq('400 Job has to be running')
-      end
-    end
-
-    context 'when params have an existsed job token' do
-      context 'when params have an existsed ref' do
-        let(:params) { { token: job.token, ref: 'master', variables: nil } }
-
-        it 'triggers a pipeline' do
-          expect { result }.to change { Ci::Pipeline.count }.by(1)
-          expect(result[:pipeline].ref).to eq('master')
-          expect(result[:pipeline].project).to eq(project)
-          expect(result[:pipeline].user).to eq(job.user)
-          expect(result[:status]).to eq(:success)
-        end
-
-        context 'when commit message has [ci skip]' do
-          before do
-            allow_any_instance_of(Ci::Pipeline).to receive(:git_commit_message) { '[ci skip]' }
-          end
-
-          it 'ignores [ci skip] and create as general' do
-            expect { result }.to change { Ci::Pipeline.count }.by(1)
-            expect(result[:status]).to eq(:success)
-          end
-        end
-
-        context 'when params have a variable' do
-          let(:params) { { token: job.token, ref: 'master', variables: variables } }
-          let(:variables) { { 'AAA' => 'AAA123' } }
-
-          it 'has a variable' do
-            expect { result }.to change { Ci::PipelineVariable.count }.by(1)
-                             .and change { Ci::Sources::Pipeline.count }.by(1)
-            expect(result[:pipeline].variables.map { |v| { v.key => v.value } }.first).to eq(variables)
-            expect(job.sourced_pipelines.last.pipeline_id).to eq(result[:pipeline].id)
-          end
-        end
-      end
-
-      context 'when params have a non-existsed ref' do
-        let(:params) { { token: job.token, ref: 'invalid-ref', variables: nil } }
-
-        it 'does not job a pipeline' do
-          expect { result }.not_to change { Ci::Pipeline.count }
-          expect(result[:http_status]).to eq(400)
-        end
-      end
-    end
-
-    context 'when params have a non-existsed trigger token' do
-      let(:params) { { token: 'invalid-token', ref: nil, variables: nil } }
-
-      it 'does not trigger a pipeline' do
-        expect { result }.not_to change { Ci::Pipeline.count }
-        expect(result).to be_nil
-      end
-    end
-  end
 end

spec/services/ee/ci/pipeline_trigger_service_spec.rb

+require 'spec_helper'
+
+describe Ci::PipelineTriggerService, services: true do
+  let(:project) { create(:project, :repository) }
+
+  before do
+    stub_ci_pipeline_to_return_yaml_file
+  end
+
+  describe '#execute' do
+    let(:user) { create(:user) }
+    let!(:pipeline) { create(:ci_empty_pipeline, project: project) }
+    let(:job) { create(:ci_build, :running, pipeline: pipeline, user: user) }
+    let(:result) { described_class.new(project, user, params).execute }
+
+    before do
+      project.add_developer(user)
+    end
+
+    context 'when job user does not have a permission to read a project' do
+      let(:params) { { token: job.token, ref: 'master', variables: nil } }
+      let(:job) { create(:ci_build, pipeline: pipeline, user: create(:user)) }
+
+      it 'does nothing' do
+        expect { result }.not_to change { Ci::Pipeline.count }
+      end
+    end
+
+    context 'when job is not running' do
+      let(:params) { { token: job.token, ref: 'master', variables: nil } }
+      let(:job) { create(:ci_build, :success, pipeline: pipeline, user: user) }
+
+      it 'does nothing' do
+        expect { result }.not_to change { Ci::Pipeline.count }
+        expect(result[:message]).to eq('400 Job has to be running')
+      end
+    end
+
+    context 'when params have an existsed job token' do
+      context 'when params have an existsed ref' do
+        let(:params) { { token: job.token, ref: 'master', variables: nil } }
+
+        it 'triggers a pipeline' do
+          expect { result }.to change { Ci::Pipeline.count }.by(1)
+          expect(result[:pipeline].ref).to eq('master')
+          expect(result[:pipeline].project).to eq(project)
+          expect(result[:pipeline].user).to eq(job.user)
+          expect(result[:status]).to eq(:success)
+        end
+
+        context 'when commit message has [ci skip]' do
+          before do
+            allow_any_instance_of(Ci::Pipeline).to receive(:git_commit_message) { '[ci skip]' }
+          end
+
+          it 'ignores [ci skip] and create as general' do
+            expect { result }.to change { Ci::Pipeline.count }.by(1)
+            expect(result[:status]).to eq(:success)
+          end
+        end
+
+        context 'when params have a variable' do
+          let(:params) { { token: job.token, ref: 'master', variables: variables } }
+          let(:variables) { { 'AAA' => 'AAA123' } }
+
+          it 'has a variable' do
+            expect { result }.to change { Ci::PipelineVariable.count }.by(1)
+                             .and change { Ci::Sources::Pipeline.count }.by(1)
+            expect(result[:pipeline].variables.map { |v| { v.key => v.value } }.first).to eq(variables)
+            expect(job.sourced_pipelines.last.pipeline_id).to eq(result[:pipeline].id)
+          end
+        end
+      end
+
+      context 'when params have a non-existsed ref' do
+        let(:params) { { token: job.token, ref: 'invalid-ref', variables: nil } }
+
+        it 'does not job a pipeline' do
+          expect { result }.not_to change { Ci::Pipeline.count }
+          expect(result[:http_status]).to eq(400)
+        end
+      end
+    end
+
+    context 'when params have a non-existsed trigger token' do
+      let(:params) { { token: 'invalid-token', ref: nil, variables: nil } }
+
+      it 'does not trigger a pipeline' do
+        expect { result }.not_to change { Ci::Pipeline.count }
+        expect(result).to be_nil
+      end
+    end
+  end
+end