Welcome to mirror list, hosted at ThFree Co, Russian Federation.

parent_child_pipeline_spec.rb « create_pipeline_service « ci « services « spec - gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
blob: b4071d1b0feae965bdbcb8546d3b9b8d32fb293f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
# frozen_string_literal: true

require 'spec_helper'

describe Ci::CreatePipelineService, '#execute' do
  let_it_be(:project) { create(:project, :repository) }
  let_it_be(:user) { create(:user) }
  let(:ref_name) { 'master' }

  let(:service) do
    params = { ref: ref_name,
               before: '00000000',
               after: project.commit.id,
               commits: [{ message: 'some commit' }] }

    described_class.new(project, user, params)
  end

  before do
    project.add_developer(user)
    stub_ci_pipeline_to_return_yaml_file
  end

  describe 'child pipeline triggers' do
    before do
      stub_ci_pipeline_yaml_file <<~YAML
        test:
          script: rspec

        deploy:
          variables:
            CROSS: downstream
          stage: deploy
          trigger:
            include:
              - local: path/to/child.yml
      YAML
    end

    it 'creates bridge jobs correctly' do
      pipeline = create_pipeline!

      test = pipeline.statuses.find_by(name: 'test')
      bridge = pipeline.statuses.find_by(name: 'deploy')

      expect(pipeline).to be_persisted
      expect(test).to be_a Ci::Build
      expect(bridge).to be_a Ci::Bridge
      expect(bridge.stage).to eq 'deploy'
      expect(pipeline.statuses).to match_array [test, bridge]
      expect(bridge.options).to eq(
        'trigger' => { 'include' => [{ 'local' => 'path/to/child.yml' }] }
      )
      expect(bridge.yaml_variables)
        .to include(key: 'CROSS', value: 'downstream', public: true)
    end
  end

  describe 'child pipeline triggers' do
    context 'when YAML is valid' do
      before do
        stub_ci_pipeline_yaml_file <<~YAML
          test:
            script: rspec

          deploy:
            variables:
              CROSS: downstream
            stage: deploy
            trigger:
              include:
                - local: path/to/child.yml
        YAML
      end

      it 'creates bridge jobs correctly' do
        pipeline = create_pipeline!

        test = pipeline.statuses.find_by(name: 'test')
        bridge = pipeline.statuses.find_by(name: 'deploy')

        expect(pipeline).to be_persisted
        expect(test).to be_a Ci::Build
        expect(bridge).to be_a Ci::Bridge
        expect(bridge.stage).to eq 'deploy'
        expect(pipeline.statuses).to match_array [test, bridge]
        expect(bridge.options).to eq(
          'trigger' => { 'include' => [{ 'local' => 'path/to/child.yml' }] }
        )
        expect(bridge.yaml_variables)
          .to include(key: 'CROSS', value: 'downstream', public: true)
      end
    end

    context 'when YAML is invalid' do
      let(:config) do
        {
          test: { script: 'rspec' },
          deploy: {
            trigger: { include: included_files }
          }
        }
      end

      let(:included_files) do
        Array.new(include_max_size + 1) do |index|
          { local: "file#{index}.yml" }
        end
      end

      let(:include_max_size) do
        Gitlab::Ci::Config::Entry::Trigger::ComplexTrigger::SameProjectTrigger::INCLUDE_MAX_SIZE
      end

      before do
        stub_ci_pipeline_yaml_file(YAML.dump(config))
      end

      it 'returns errors' do
        pipeline = create_pipeline!

        expect(pipeline.errors.full_messages.first).to match(/trigger:include config is too long/)
        expect(pipeline.failure_reason).to eq 'config_error'
        expect(pipeline).to be_persisted
        expect(pipeline.status).to eq 'failed'
      end
    end
  end

  def create_pipeline!
    service.execute(:push)
  end
end