pipeline_spec.rb 38.1 KB
Newer Older
D
Douwe Maan 已提交
1 2
require 'spec_helper'

3
describe Ci::Pipeline, :mailer do
4
  let(:user) { create(:user) }
5
  set(:project) { create(:project) }
6 7 8 9

  let(:pipeline) do
    create(:ci_empty_pipeline, status: :created, project: project)
  end
D
Douwe Maan 已提交
10

K
Kamil Trzcinski 已提交
11
  it { is_expected.to belong_to(:project) }
12
  it { is_expected.to belong_to(:user) }
13
  it { is_expected.to belong_to(:auto_canceled_by) }
14
  it { is_expected.to belong_to(:pipeline_schedule) }
15

16
  it { is_expected.to have_many(:statuses) }
K
Kamil Trzcinski 已提交
17
  it { is_expected.to have_many(:trigger_requests) }
S
init  
Shinya Maeda 已提交
18
  it { is_expected.to have_many(:variables) }
D
Dmitriy Zaporozhets 已提交
19
  it { is_expected.to have_many(:builds) }
20
  it { is_expected.to have_many(:auto_canceled_pipelines) }
21
  it { is_expected.to have_many(:auto_canceled_jobs) }
22

23 24
  it { is_expected.to validate_presence_of(:sha) }
  it { is_expected.to validate_presence_of(:status) }
D
Douwe Maan 已提交
25

D
Dmitriy Zaporozhets 已提交
26 27 28
  it { is_expected.to respond_to :git_author_name }
  it { is_expected.to respond_to :git_author_email }
  it { is_expected.to respond_to :short_sha }
D
Douwe Maan 已提交
29

30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
  describe '#source' do
    context 'when creating new pipeline' do
      let(:pipeline) do
        build(:ci_empty_pipeline, status: :created, project: project, source: nil)
      end

      it "prevents from creating an object" do
        expect(pipeline).not_to be_valid
      end
    end

    context 'when updating existing pipeline' do
      before do
        pipeline.update_attribute(:source, nil)
      end

      it "object is valid" do
        expect(pipeline).to be_valid
      end
    end
  end

52 53 54 55 56 57 58 59
  describe '#block' do
    it 'changes pipeline status to manual' do
      expect(pipeline.block).to be true
      expect(pipeline.reload).to be_manual
      expect(pipeline.reload).to be_blocked
    end
  end

60
  describe '#valid_commit_sha' do
D
Douwe Maan 已提交
61 62
    context 'commit.sha can not start with 00000000' do
      before do
63 64
        pipeline.sha = '0' * 40
        pipeline.valid_commit_sha
D
Douwe Maan 已提交
65 66
      end

67
      it('commit errors should not be empty') { expect(pipeline.errors).not_to be_empty }
D
Douwe Maan 已提交
68 69 70
    end
  end

71
  describe '#short_sha' do
72
    subject { pipeline.short_sha }
D
Douwe Maan 已提交
73

D
Dmitriy Zaporozhets 已提交
74 75 76
    it 'has 8 items' do
      expect(subject.size).to eq(8)
    end
77
    it { expect(pipeline.sha).to start_with(subject) }
D
Douwe Maan 已提交
78 79
  end

80
  describe '#retried' do
81
    subject { pipeline.retried }
K
Kamil Trzcinski 已提交
82 83

    before do
84 85
      @build1 = create(:ci_build, pipeline: pipeline, name: 'deploy', retried: true)
      @build2 = create(:ci_build, pipeline: pipeline, name: 'deploy')
K
Kamil Trzcinski 已提交
86 87 88
    end

    it 'returns old builds' do
89
      is_expected.to contain_exactly(@build1)
K
Kamil Trzcinski 已提交
90 91 92
    end
  end

D
Douwe Maan 已提交
93
  describe "coverage" do
94
    let(:project) { create(:project, build_coverage_regex: "/.*/") }
95
    let(:pipeline) { create(:ci_empty_pipeline, project: project) }
D
Douwe Maan 已提交
96 97

    it "calculates average when there are two builds with coverage" do
98 99
      create(:ci_build, name: "rspec", coverage: 30, pipeline: pipeline)
      create(:ci_build, name: "rubocop", coverage: 40, pipeline: pipeline)
100
      expect(pipeline.coverage).to eq("35.00")
D
Douwe Maan 已提交
101 102 103
    end

    it "calculates average when there are two builds with coverage and one with nil" do
104 105 106
      create(:ci_build, name: "rspec", coverage: 30, pipeline: pipeline)
      create(:ci_build, name: "rubocop", coverage: 40, pipeline: pipeline)
      create(:ci_build, pipeline: pipeline)
107
      expect(pipeline.coverage).to eq("35.00")
D
Douwe Maan 已提交
108 109 110
    end

    it "calculates average when there are two builds with coverage and one is retried" do
111 112 113
      create(:ci_build, name: "rspec", coverage: 30, pipeline: pipeline)
      create(:ci_build, name: "rubocop", coverage: 30, pipeline: pipeline, retried: true)
      create(:ci_build, name: "rubocop", coverage: 40, pipeline: pipeline)
114
      expect(pipeline.coverage).to eq("35.00")
D
Douwe Maan 已提交
115 116 117
    end

    it "calculates average when there is one build without coverage" do
118
      FactoryGirl.create(:ci_build, pipeline: pipeline)
119
      expect(pipeline.coverage).to be_nil
D
Douwe Maan 已提交
120 121
    end
  end
K
Kamil Trzcinski 已提交
122 123

  describe '#retryable?' do
124
    subject { pipeline.retryable? }
K
Kamil Trzcinski 已提交
125 126 127

    context 'no failed builds' do
      before do
128
        create_build('rspec', 'success')
K
Kamil Trzcinski 已提交
129 130
      end

131
      it 'is not retryable' do
K
Kamil Trzcinski 已提交
132 133
        is_expected.to be_falsey
      end
134 135 136 137 138 139 140 141 142 143

      context 'one canceled job' do
        before do
          create_build('rubocop', 'canceled')
        end

        it 'is retryable' do
          is_expected.to be_truthy
        end
      end
K
Kamil Trzcinski 已提交
144 145 146 147
    end

    context 'with failed builds' do
      before do
148 149
        create_build('rspec', 'running')
        create_build('rubocop', 'failed')
K
Kamil Trzcinski 已提交
150 151
      end

152
      it 'is retryable' do
K
Kamil Trzcinski 已提交
153 154 155
        is_expected.to be_truthy
      end
    end
156 157 158 159

    def create_build(name, status)
      create(:ci_build, name: name, status: status, pipeline: pipeline)
    end
K
Kamil Trzcinski 已提交
160 161
  end

162 163 164 165 166 167 168 169 170 171 172 173
  describe '#predefined_variables' do
    subject { pipeline.predefined_variables }

    it { is_expected.to be_an(Array) }

    it 'includes the defined keys' do
      keys = subject.map { |v| v[:key] }

      expect(keys).to include('CI_PIPELINE_ID', 'CI_CONFIG_PATH', 'CI_PIPELINE_SOURCE')
    end
  end

174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210
  describe '#auto_canceled?' do
    subject { pipeline.auto_canceled? }

    context 'when it is canceled' do
      before do
        pipeline.cancel
      end

      context 'when there is auto_canceled_by' do
        before do
          pipeline.update(auto_canceled_by: create(:ci_empty_pipeline))
        end

        it 'is auto canceled' do
          is_expected.to be_truthy
        end
      end

      context 'when there is no auto_canceled_by' do
        it 'is not auto canceled' do
          is_expected.to be_falsey
        end
      end

      context 'when it is retried and canceled manually' do
        before do
          pipeline.enqueue
          pipeline.cancel
        end

        it 'is not auto canceled' do
          is_expected.to be_falsey
        end
      end
    end
  end

211
  describe 'pipeline stages' do
K
Kamil Trzcinski 已提交
212
    before do
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237
      create(:commit_status, pipeline: pipeline,
                             stage: 'build',
                             name: 'linux',
                             stage_idx: 0,
                             status: 'success')

      create(:commit_status, pipeline: pipeline,
                             stage: 'build',
                             name: 'mac',
                             stage_idx: 0,
                             status: 'failed')

      create(:commit_status, pipeline: pipeline,
                             stage: 'deploy',
                             name: 'staging',
                             stage_idx: 2,
                             status: 'running')

      create(:commit_status, pipeline: pipeline,
                             stage: 'test',
                             name: 'rspec',
                             stage_idx: 1,
                             status: 'success')
    end

238 239 240 241 242 243
    describe '#stage_seeds' do
      let(:pipeline) do
        create(:ci_pipeline, config: { rspec: { script: 'rake' } })
      end

      it 'returns preseeded stage seeds object' do
244 245
        expect(pipeline.stage_seeds).to all(be_a Gitlab::Ci::Stage::Seed)
        expect(pipeline.stage_seeds.count).to eq 1
246 247 248
      end
    end

249 250
    describe '#legacy_stages' do
      subject { pipeline.legacy_stages }
251 252 253 254 255

      context 'stages list' do
        it 'returns ordered list of stages' do
          expect(subject.map(&:name)).to eq(%w[build test deploy])
        end
256 257
      end

258 259 260 261
      context 'stages with statuses' do
        let(:statuses) do
          subject.map { |stage| [stage.name, stage.status] }
        end
262

263
        it 'returns list of stages with correct statuses' do
D
Douwe Maan 已提交
264 265 266
          expect(statuses).to eq([%w(build failed),
                                  %w(test success),
                                  %w(deploy running)])
267
        end
K
Kamil Trzcinski 已提交
268

269
        context 'when commit status is retried' do
270 271 272 273 274 275
          before do
            create(:commit_status, pipeline: pipeline,
                                   stage: 'build',
                                   name: 'mac',
                                   stage_idx: 0,
                                   status: 'success')
276 277

            pipeline.process!
278 279 280
          end

          it 'ignores the previous state' do
D
Douwe Maan 已提交
281 282 283
            expect(statuses).to eq([%w(build success),
                                    %w(test success),
                                    %w(deploy running)])
284
          end
285 286
        end
      end
287 288 289 290 291 292 293 294 295 296 297 298

      context 'when there is a stage with warnings' do
        before do
          create(:commit_status, pipeline: pipeline,
                                 stage: 'deploy',
                                 name: 'prod:2',
                                 stage_idx: 2,
                                 status: 'failed',
                                 allow_failure: true)
        end

        it 'populates stage with correct number of warnings' do
299
          deploy_stage = pipeline.legacy_stages.third
300 301 302 303 304

          expect(deploy_stage).not_to receive(:statuses)
          expect(deploy_stage).to have_warnings
        end
      end
305
    end
306

307 308 309
    describe '#stages_count' do
      it 'returns a valid number of stages' do
        expect(pipeline.stages_count).to eq(3)
310
      end
311
    end
312

313
    describe '#stages_names' do
314
      it 'returns a valid names of stages' do
315
        expect(pipeline.stages_names).to eq(%w(build test deploy))
316
      end
K
Kamil Trzcinski 已提交
317 318 319
    end
  end

320 321
  describe '#legacy_stage' do
    subject { pipeline.legacy_stage('test') }
K
Kamil Trzcinski 已提交
322 323

    context 'with status in stage' do
K
Kamil Trzcinski 已提交
324 325
      before do
        create(:commit_status, pipeline: pipeline, stage: 'test')
K
Kamil Trzcinski 已提交
326
      end
K
Kamil Trzcinski 已提交
327

328
      it { expect(subject).to be_a Ci::LegacyStage }
329 330
      it { expect(subject.name).to eq 'test' }
      it { expect(subject.statuses).not_to be_empty }
K
Kamil Trzcinski 已提交
331 332 333
    end

    context 'without status in stage' do
K
Kamil Trzcinski 已提交
334 335 336
      before do
        create(:commit_status, pipeline: pipeline, stage: 'build')
      end
K
Kamil Trzcinski 已提交
337 338 339 340 341 342 343

      it 'return stage object' do
        is_expected.to be_nil
      end
    end
  end

344
  describe 'state machine' do
345
    let(:current) { Time.now.change(usec: 0) }
346 347 348
    let(:build) { create_build('build1', queued_at: 0) }
    let(:build_b) { create_build('build2', queued_at: 0) }
    let(:build_c) { create_build('build3', queued_at: 0) }
K
Kamil Trzcinski 已提交
349

350
    describe '#duration' do
351 352 353 354 355 356 357 358
      context 'when multiple builds are finished' do
        before do
          travel_to(current + 30) do
            build.run!
            build.success!
            build_b.run!
            build_c.run!
          end
L
Lin Jen-Shin 已提交
359

360 361 362 363 364 365 366
          travel_to(current + 40) do
            build_b.drop!
          end

          travel_to(current + 70) do
            build_c.success!
          end
367
        end
368

369 370 371 372
        it 'matches sum of builds duration' do
          pipeline.reload

          expect(pipeline.duration).to eq(40)
373
        end
374 375
      end

376 377
      context 'when pipeline becomes blocked' do
        let!(:build) { create_build('build:1') }
378
        let!(:action) { create_build('manual:action', :manual) }
379

380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395
        before do
          travel_to(current + 1.minute) do
            build.run!
          end

          travel_to(current + 5.minutes) do
            build.success!
          end
        end

        it 'recalculates pipeline duration' do
          pipeline.reload

          expect(pipeline).to be_manual
          expect(pipeline.duration).to eq 4.minutes
        end
396
      end
K
Kamil Trzcinski 已提交
397 398
    end

399 400 401
    describe '#started_at' do
      it 'updates on transitioning to running' do
        build.run
K
Kamil Trzcinski 已提交
402

403 404 405
        expect(pipeline.reload.started_at).not_to be_nil
      end

406
      it 'does not update on transitioning to success' do
407 408 409
        build.success

        expect(pipeline.reload.started_at).to be_nil
K
Kamil Trzcinski 已提交
410 411 412
      end
    end

413 414 415
    describe '#finished_at' do
      it 'updates on transitioning to success' do
        build.success
K
Kamil Trzcinski 已提交
416

417
        expect(pipeline.reload.finished_at).not_to be_nil
K
Kamil Trzcinski 已提交
418 419
      end

420
      it 'does not update on transitioning to running' do
421 422 423
        build.run

        expect(pipeline.reload.finished_at).to be_nil
K
Kamil Trzcinski 已提交
424 425
      end
    end
426

427
    describe 'merge request metrics' do
428
      let(:project) { create(:project, :repository) }
429 430 431
      let(:pipeline) { FactoryGirl.create(:ci_empty_pipeline, status: 'created', project: project, ref: 'master', sha: project.repository.commit('master').id) }
      let!(:merge_request) { create(:merge_request, source_project: project, source_branch: pipeline.ref) }

432 433 434
      before do
        expect(PipelineMetricsWorker).to receive(:perform_async).with(pipeline.id)
      end
435

436 437 438
      context 'when transitioning to running' do
        it 'schedules metrics workers' do
          pipeline.run
439 440 441 442
        end
      end

      context 'when transitioning to success' do
443 444
        it 'schedules metrics workers' do
          pipeline.succeed
445 446 447
        end
      end
    end
448

449
    describe 'pipeline caching' do
450 451
      it 'performs ExpirePipelinesCacheWorker' do
        expect(ExpirePipelineCacheWorker).to receive(:perform_async).with(pipeline.id)
T
Toon Claes 已提交
452 453 454 455 456

        pipeline.cancel
      end
    end

457 458
    def create_build(name, *traits, queued_at: current, started_from: 0, **opts)
      create(:ci_build, *traits,
L
Lin Jen-Shin 已提交
459 460
             name: name,
             pipeline: pipeline,
461
             queued_at: queued_at,
462 463
             started_at: queued_at + started_from,
             **opts)
L
Lin Jen-Shin 已提交
464
    end
K
Kamil Trzcinski 已提交
465
  end
K
Kamil Trzcinski 已提交
466 467

  describe '#branch?' do
468
    subject { pipeline.branch? }
K
Kamil Trzcinski 已提交
469 470 471

    context 'is not a tag' do
      before do
472
        pipeline.tag = false
K
Kamil Trzcinski 已提交
473 474 475 476 477 478 479 480 481
      end

      it 'return true when tag is set to false' do
        is_expected.to be_truthy
      end
    end

    context 'is not a tag' do
      before do
482
        pipeline.tag = true
K
Kamil Trzcinski 已提交
483 484 485 486 487 488 489
      end

      it 'return false when tag is set to true' do
        is_expected.to be_falsey
      end
    end
  end
490

491
  context 'with non-empty project' do
492
    let(:project) { create(:project, :repository) }
493 494 495 496 497 498 499

    let(:pipeline) do
      create(:ci_pipeline,
             project: project,
             ref: project.default_branch,
             sha: project.commit.sha)
    end
500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520

    describe '#latest?' do
      context 'with latest sha' do
        it 'returns true' do
          expect(pipeline).to be_latest
        end
      end

      context 'with not latest sha' do
        before do
          pipeline.update(
            sha: project.commit("#{project.default_branch}~1").sha)
        end

        it 'returns false' do
          expect(pipeline).not_to be_latest
        end
      end
    end
  end

521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537
  describe '#manual_actions' do
    subject { pipeline.manual_actions }

    it 'when none defined' do
      is_expected.to be_empty
    end

    context 'when action defined' do
      let!(:manual) { create(:ci_build, :manual, pipeline: pipeline, name: 'deploy') }

      it 'returns one action' do
        is_expected.to contain_exactly(manual)
      end

      context 'there are multiple of the same name' do
        let!(:manual2) { create(:ci_build, :manual, pipeline: pipeline, name: 'deploy') }

538 539 540 541
        before do
          manual.update(retried: true)
        end

542 543 544 545 546 547
        it 'returns latest one' do
          is_expected.to contain_exactly(manual2)
        end
      end
    end
  end
548

549
  describe '#has_kubernetes_active?' do
550
    context 'when kubernetes is active' do
551
      let(:project) { create(:kubernetes_project) }
552 553

      it 'returns true' do
554
        expect(pipeline).to have_kubernetes_active
555 556 557
      end
    end

558
    context 'when kubernetes is not active' do
559
      it 'returns false' do
560
        expect(pipeline).not_to have_kubernetes_active
561 562 563 564
      end
    end
  end

565
  describe '#has_stage_seeds?' do
566
    context 'when pipeline has stage seeds' do
567
      subject { build(:ci_pipeline_with_one_job) }
568

569
      it { is_expected.to have_stage_seeds }
570 571
    end

572
    context 'when pipeline does not have stage seeds' do
573 574
      subject { create(:ci_pipeline_without_jobs) }

575
      it { is_expected.not_to have_stage_seeds }
576 577 578
    end
  end

C
Connor Shea 已提交
579 580
  describe '#has_warnings?' do
    subject { pipeline.has_warnings? }
581 582 583

    context 'build which is allowed to fail fails' do
      before do
C
Connor Shea 已提交
584 585
        create :ci_build, :success, pipeline: pipeline, name: 'rspec'
        create :ci_build, :allowed_to_fail, :failed, pipeline: pipeline, name: 'rubocop'
586
      end
587

588 589 590 591 592 593 594
      it 'returns true' do
        is_expected.to be_truthy
      end
    end

    context 'build which is allowed to fail succeeds' do
      before do
C
Connor Shea 已提交
595 596
        create :ci_build, :success, pipeline: pipeline, name: 'rspec'
        create :ci_build, :allowed_to_fail, :success, pipeline: pipeline, name: 'rubocop'
597
      end
598

599 600 601 602
      it 'returns false' do
        is_expected.to be_falsey
      end
    end
C
Connor Shea 已提交
603 604 605 606 607 608 609 610 611 612 613 614

    context 'build is retried and succeeds' do
      before do
        create :ci_build, :success, pipeline: pipeline, name: 'rubocop'
        create :ci_build, :failed, pipeline: pipeline, name: 'rspec'
        create :ci_build, :success, pipeline: pipeline, name: 'rspec'
      end

      it 'returns false' do
        is_expected.to be_falsey
      end
    end
615
  end
616

617
  shared_context 'with some outdated pipelines' do
618 619 620 621 622 623 624 625 626 627 628 629 630
    before do
      create_pipeline(:canceled, 'ref', 'A')
      create_pipeline(:success, 'ref', 'A')
      create_pipeline(:failed, 'ref', 'B')
      create_pipeline(:skipped, 'feature', 'C')
    end

    def create_pipeline(status, ref, sha)
      create(:ci_empty_pipeline, status: status, ref: ref, sha: sha)
    end
  end

  describe '.latest' do
631
    include_context 'with some outdated pipelines'
632 633

    context 'when no ref is specified' do
634
      let(:pipelines) { described_class.latest.all }
635

636 637
      it 'returns the latest pipeline for the same ref and different sha' do
        expect(pipelines.map(&:sha)).to contain_exactly('A', 'B', 'C')
638 639
        expect(pipelines.map(&:status))
          .to contain_exactly('success', 'failed', 'skipped')
640 641 642 643
      end
    end

    context 'when ref is specified' do
644
      let(:pipelines) { described_class.latest('ref').all }
645

646 647
      it 'returns the latest pipeline for ref and different sha' do
        expect(pipelines.map(&:sha)).to contain_exactly('A', 'B')
648 649
        expect(pipelines.map(&:status))
          .to contain_exactly('success', 'failed')
650 651 652 653 654
      end
    end
  end

  describe '.latest_status' do
655
    include_context 'with some outdated pipelines'
656 657

    context 'when no ref is specified' do
658
      let(:latest_status) { described_class.latest_status }
659 660

      it 'returns the latest status for the same ref and different sha' do
661
        expect(latest_status).to eq(described_class.latest.status)
L
Lin Jen-Shin 已提交
662
        expect(latest_status).to eq('failed')
663 664 665 666
      end
    end

    context 'when ref is specified' do
667
      let(:latest_status) { described_class.latest_status('ref') }
668 669

      it 'returns the latest status for ref and different sha' do
670
        expect(latest_status).to eq(described_class.latest_status('ref'))
L
Lin Jen-Shin 已提交
671
        expect(latest_status).to eq('failed')
672 673 674 675
      end
    end
  end

676 677 678 679 680 681 682 683
  describe '.latest_successful_for' do
    include_context 'with some outdated pipelines'

    let!(:latest_successful_pipeline) do
      create_pipeline(:success, 'ref', 'D')
    end

    it 'returns the latest successful pipeline' do
684 685
      expect(described_class.latest_successful_for('ref'))
        .to eq(latest_successful_pipeline)
686 687 688
    end
  end

689 690 691 692 693 694 695 696 697 698 699 700 701
  describe '.latest_successful_for_refs' do
    include_context 'with some outdated pipelines'

    let!(:latest_successful_pipeline1) { create_pipeline(:success, 'ref1', 'D') }
    let!(:latest_successful_pipeline2) { create_pipeline(:success, 'ref2', 'D') }

    it 'returns the latest successful pipeline for both refs' do
      refs = %w(ref1 ref2 ref3)

      expect(described_class.latest_successful_for_refs(refs)).to eq({ 'ref1' => latest_successful_pipeline1, 'ref2' => latest_successful_pipeline2 })
    end
  end

702 703 704 705 706 707
  describe '.internal_sources' do
    subject { described_class.internal_sources }

    it { is_expected.to be_an(Array) }
  end

708
  describe '#status' do
709 710 711
    let(:build) do
      create(:ci_build, :created, pipeline: pipeline, name: 'test')
    end
712 713 714 715

    subject { pipeline.reload.status }

    context 'on queuing' do
716 717 718
      before do
        build.enqueue
      end
719 720 721 722 723 724

      it { is_expected.to eq('pending') }
    end

    context 'on run' do
      before do
725
        build.enqueue
726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752
        build.run
      end

      it { is_expected.to eq('running') }
    end

    context 'on drop' do
      before do
        build.drop
      end

      it { is_expected.to eq('failed') }
    end

    context 'on success' do
      before do
        build.success
      end

      it { is_expected.to eq('success') }
    end

    context 'on cancel' do
      before do
        build.cancel
      end

753 754 755 756 757 758 759
      context 'when build is pending' do
        let(:build) do
          create(:ci_build, :pending, pipeline: pipeline)
        end

        it { is_expected.to eq('canceled') }
      end
760
    end
761 762 763

    context 'on failure and build retry' do
      before do
S
Shinya Maeda 已提交
764 765
        stub_not_protect_default_branch

766
        build.drop
767
        project.add_developer(user)
768 769

        Ci::Build.retry(build, user)
770 771 772 773 774 775 776 777
      end

      # We are changing a state: created > failed > running
      # Instead of: created > failed > pending
      # Since the pipeline already run, so it should not be pending anymore

      it { is_expected.to eq('running') }
    end
778
  end
779

780 781 782 783
  describe '#ci_yaml_file_path' do
    subject { pipeline.ci_yaml_file_path }

    it 'returns the path from project' do
784
      allow(pipeline.project).to receive(:ci_config_path) { 'custom/path' }
785 786 787 788 789

      is_expected.to eq('custom/path')
    end

    it 'returns default when custom path is nil' do
790
      allow(pipeline.project).to receive(:ci_config_path) { nil }
791 792 793 794 795

      is_expected.to eq('.gitlab-ci.yml')
    end

    it 'returns default when custom path is empty' do
796
      allow(pipeline.project).to receive(:ci_config_path) { '' }
797 798 799 800 801

      is_expected.to eq('.gitlab-ci.yml')
    end
  end

802 803 804
  describe '#detect_ci_yaml_file' do
    context 'when the repo has a config file' do
      it 'returns that configuration' do
805 806
        allow(pipeline.project.repository).to receive(:gitlab_ci_yml_for)
          .and_return('config')
807

808 809
        expect(pipeline.detect_ci_yaml_file).to be_a(String)
        expect(pipeline.repository_source?).to be(true)
810
      end
811 812 813 814
    end

    context 'when the repo does not have a config file' do
      let(:implied_yml) { Gitlab::Template::GitlabCiYmlTemplate.find('Auto-DevOps').content }
815

816
      context 'auto devops enabled' do
817 818 819 820
        before do
          allow_any_instance_of(ApplicationSetting)
            .to receive(:auto_devops_enabled?) { true }
        end
821

822
        it 'returns the implied ci file' do
823 824
          allow(pipeline.project).to receive(:ci_config_path) { 'custom' }

825 826
          expect(pipeline.detect_ci_yaml_file).to eq(implied_yml)
          expect(pipeline.auto_devops_source?).to be(true)
827
        end
828 829 830
      end
    end
  end
831

832 833
  describe '#ci_yaml_file' do
    let(:implied_yml) { Gitlab::Template::GitlabCiYmlTemplate.find('Auto-DevOps').content }
834

835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852
    before { pipeline.detect_ci_yaml_file }

    context 'the source is unknown' do
      before { pipeline.unknown_source! }

      it 'returns the configuration if found' do
        allow(pipeline.project.repository).to receive(:gitlab_ci_yml_for)
          .and_return('config')

        expect(pipeline.ci_yaml_file).to be_a(String)
        expect(pipeline.ci_yaml_file).not_to eq(implied_yml)
        expect(pipeline.yaml_errors).to be_nil
      end

      it 'sets yaml errors if not found' do
        expect(pipeline.ci_yaml_file).to be_nil
        expect(pipeline.yaml_errors)
            .to start_with('Failed to load CI/CD config file')
853 854 855
      end
    end

856 857
    context 'the source is the repository' do
      before { pipeline.repository_source! }
858

859 860 861 862 863 864 865
      it 'returns the configuration if found' do
        allow(pipeline.project.repository).to receive(:gitlab_ci_yml_for)
          .and_return('config')

        expect(pipeline.ci_yaml_file).to be_a(String)
        expect(pipeline.ci_yaml_file).not_to eq(implied_yml)
        expect(pipeline.yaml_errors).to be_nil
866
      end
867
    end
868

869 870
    context 'when the source is auto_devops_source' do
      before { pipeline.auto_devops_source! }
871

872 873 874 875 876 877
      it 'finds the implied config' do
        allow_any_instance_of(ApplicationSetting)
          .to receive(:auto_devops_enabled?) { true }

        expect(pipeline.ci_yaml_file).to eq(implied_yml)
        expect(pipeline.yaml_errors).to be_nil
878
      end
879 880 881
    end
  end

882
  describe '#detailed_status' do
883 884
    subject { pipeline.detailed_status(user) }

885 886 887 888
    context 'when pipeline is created' do
      let(:pipeline) { create(:ci_pipeline, status: :created) }

      it 'returns detailed status for created pipeline' do
889
        expect(subject.text).to eq 'created'
890 891 892 893 894 895 896
      end
    end

    context 'when pipeline is pending' do
      let(:pipeline) { create(:ci_pipeline, status: :pending) }

      it 'returns detailed status for pending pipeline' do
897
        expect(subject.text).to eq 'pending'
898 899 900 901 902 903 904
      end
    end

    context 'when pipeline is running' do
      let(:pipeline) { create(:ci_pipeline, status: :running) }

      it 'returns detailed status for running pipeline' do
905
        expect(subject.text).to eq 'running'
906 907 908 909 910 911 912
      end
    end

    context 'when pipeline is successful' do
      let(:pipeline) { create(:ci_pipeline, status: :success) }

      it 'returns detailed status for successful pipeline' do
913
        expect(subject.text).to eq 'passed'
914 915 916 917 918 919 920
      end
    end

    context 'when pipeline is failed' do
      let(:pipeline) { create(:ci_pipeline, status: :failed) }

      it 'returns detailed status for failed pipeline' do
921
        expect(subject.text).to eq 'failed'
922 923 924 925 926 927 928
      end
    end

    context 'when pipeline is canceled' do
      let(:pipeline) { create(:ci_pipeline, status: :canceled) }

      it 'returns detailed status for canceled pipeline' do
929
        expect(subject.text).to eq 'canceled'
930 931 932 933 934 935 936
      end
    end

    context 'when pipeline is skipped' do
      let(:pipeline) { create(:ci_pipeline, status: :skipped) }

      it 'returns detailed status for skipped pipeline' do
937
        expect(subject.text).to eq 'skipped'
938 939 940
      end
    end

941 942 943 944
    context 'when pipeline is blocked' do
      let(:pipeline) { create(:ci_pipeline, status: :manual) }

      it 'returns detailed status for blocked pipeline' do
945
        expect(subject.text).to eq 'blocked'
946 947 948
      end
    end

949 950 951 952 953 954 955 956
    context 'when pipeline is successful but with warnings' do
      let(:pipeline) { create(:ci_pipeline, status: :success) }

      before do
        create(:ci_build, :allowed_to_fail, :failed, pipeline: pipeline)
      end

      it 'retruns detailed status for successful pipeline with warnings' do
957
        expect(subject.label).to eq 'passed with warnings'
958 959 960 961
      end
    end
  end

962
  describe '#cancelable?' do
963 964
    %i[created running pending].each do |status0|
      context "when there is a build #{status0}" do
965
        before do
966
          create(:ci_build, status0, pipeline: pipeline)
967 968
        end

969 970 971
        it 'is cancelable' do
          expect(pipeline.cancelable?).to be_truthy
        end
972 973
      end

974
      context "when there is an external job #{status0}" do
975
        before do
976
          create(:generic_commit_status, status0, pipeline: pipeline)
977 978
        end

979 980 981
        it 'is cancelable' do
          expect(pipeline.cancelable?).to be_truthy
        end
982
      end
983

984
      %i[success failed canceled].each do |status1|
985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014
        context "when there are generic_commit_status jobs for #{status0} and #{status1}" do
          before do
            create(:generic_commit_status, status0, pipeline: pipeline)
            create(:generic_commit_status, status1, pipeline: pipeline)
          end

          it 'is cancelable' do
            expect(pipeline.cancelable?).to be_truthy
          end
        end

        context "when there are generic_commit_status and ci_build jobs for #{status0} and #{status1}" do
          before do
            create(:generic_commit_status, status0, pipeline: pipeline)
            create(:ci_build, status1, pipeline: pipeline)
          end

          it 'is cancelable' do
            expect(pipeline.cancelable?).to be_truthy
          end
        end

        context "when there are ci_build jobs for #{status0} and #{status1}" do
          before do
            create(:ci_build, status0, pipeline: pipeline)
            create(:ci_build, status1, pipeline: pipeline)
          end

          it 'is cancelable' do
            expect(pipeline.cancelable?).to be_truthy
1015
          end
1016 1017
        end
      end
1018 1019 1020 1021 1022 1023 1024 1025
    end

    %i[success failed canceled].each do |status|
      context "when there is a build #{status}" do
        before do
          create(:ci_build, status, pipeline: pipeline)
        end

1026 1027 1028
        it 'is not cancelable' do
          expect(pipeline.cancelable?).to be_falsey
        end
1029 1030 1031 1032 1033 1034 1035
      end

      context "when there is an external job #{status}" do
        before do
          create(:generic_commit_status, status, pipeline: pipeline)
        end

1036 1037 1038
        it 'is not cancelable' do
          expect(pipeline.cancelable?).to be_falsey
        end
1039 1040
      end
    end
1041 1042 1043 1044 1045 1046 1047 1048 1049 1050

    context 'when there is a manual action present in the pipeline' do
      before do
        create(:ci_build, :manual, pipeline: pipeline)
      end

      it 'is not cancelable' do
        expect(pipeline).not_to be_cancelable
      end
    end
1051 1052
  end

1053
  describe '#cancel_running' do
1054 1055
    let(:latest_status) { pipeline.statuses.pluck(:status) }

1056
    context 'when there is a running external job and a regular job' do
1057
      before do
1058
        create(:ci_build, :running, pipeline: pipeline)
1059 1060 1061 1062 1063 1064
        create(:generic_commit_status, :running, pipeline: pipeline)

        pipeline.cancel_running
      end

      it 'cancels both jobs' do
1065 1066 1067 1068
        expect(latest_status).to contain_exactly('canceled', 'canceled')
      end
    end

1069
    context 'when jobs are in different stages' do
1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080
      before do
        create(:ci_build, :running, stage_idx: 0, pipeline: pipeline)
        create(:ci_build, :running, stage_idx: 1, pipeline: pipeline)

        pipeline.cancel_running
      end

      it 'cancels both jobs' do
        expect(latest_status).to contain_exactly('canceled', 'canceled')
      end
    end
1081 1082 1083 1084 1085 1086 1087 1088 1089

    context 'when there are created builds present in the pipeline' do
      before do
        create(:ci_build, :running, stage_idx: 0, pipeline: pipeline)
        create(:ci_build, :created, stage_idx: 1, pipeline: pipeline)

        pipeline.cancel_running
      end

1090
      it 'cancels created builds' do
D
Douwe Maan 已提交
1091
        expect(latest_status).to eq %w(canceled canceled)
1092 1093
      end
    end
1094 1095 1096 1097 1098
  end

  describe '#retry_failed' do
    let(:latest_status) { pipeline.statuses.latest.pluck(:status) }

1099
    before do
S
Shinya Maeda 已提交
1100 1101
      stub_not_protect_default_branch

1102
      project.add_developer(user)
1103 1104
    end

1105 1106 1107 1108 1109
    context 'when there is a failed build and failed external status' do
      before do
        create(:ci_build, :failed, name: 'build', pipeline: pipeline)
        create(:generic_commit_status, :failed, name: 'jenkins', pipeline: pipeline)

1110
        pipeline.retry_failed(user)
1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122
      end

      it 'retries only build' do
        expect(latest_status).to contain_exactly('pending', 'failed')
      end
    end

    context 'when builds are in different stages' do
      before do
        create(:ci_build, :failed, name: 'build', stage_idx: 0, pipeline: pipeline)
        create(:ci_build, :failed, name: 'jenkins', stage_idx: 1, pipeline: pipeline)

1123
        pipeline.retry_failed(user)
1124 1125 1126
      end

      it 'retries both builds' do
1127
        expect(latest_status).to contain_exactly('pending', 'created')
1128 1129 1130 1131 1132 1133 1134 1135
      end
    end

    context 'when there are canceled and failed' do
      before do
        create(:ci_build, :failed, name: 'build', stage_idx: 0, pipeline: pipeline)
        create(:ci_build, :canceled, name: 'jenkins', stage_idx: 1, pipeline: pipeline)

1136
        pipeline.retry_failed(user)
1137 1138 1139
      end

      it 'retries both builds' do
1140
        expect(latest_status).to contain_exactly('pending', 'created')
1141 1142 1143 1144
      end
    end
  end

1145
  describe '#execute_hooks' do
L
Lin Jen-Shin 已提交
1146 1147
    let!(:build_a) { create_build('a', 0) }
    let!(:build_b) { create_build('b', 1) }
K
Kamil Trzcinski 已提交
1148

1149 1150 1151 1152 1153
    let!(:hook) do
      create(:project_hook, project: project, pipeline_events: enabled)
    end

    before do
A
Alexander Randa 已提交
1154
      WebHookWorker.drain
1155 1156 1157 1158 1159
    end

    context 'with pipeline hooks enabled' do
      let(:enabled) { true }

K
Kamil Trzcinski 已提交
1160 1161 1162 1163
      before do
        WebMock.stub_request(:post, hook.url)
      end

1164
      context 'with multiple builds' do
K
Kamil Trzcinski 已提交
1165 1166
        context 'when build is queued' do
          before do
1167 1168
            build_a.enqueue
            build_b.enqueue
K
Kamil Trzcinski 已提交
1169
          end
1170

L
Lin Jen-Shin 已提交
1171
          it 'receives a pending event once' do
1172
            expect(WebMock).to have_requested_pipeline_hook('pending').once
K
Kamil Trzcinski 已提交
1173 1174
          end
        end
1175

K
Kamil Trzcinski 已提交
1176 1177
        context 'when build is run' do
          before do
1178
            build_a.enqueue
K
Kamil Trzcinski 已提交
1179
            build_a.run
1180
            build_b.enqueue
K
Kamil Trzcinski 已提交
1181 1182
            build_b.run
          end
1183

L
Lin Jen-Shin 已提交
1184
          it 'receives a running event once' do
1185
            expect(WebMock).to have_requested_pipeline_hook('running').once
K
Kamil Trzcinski 已提交
1186
          end
1187 1188
        end

K
Kamil Trzcinski 已提交
1189 1190 1191
        context 'when all builds succeed' do
          before do
            build_a.success
K
Kamil Trzcinski 已提交
1192 1193 1194

            # We have to reload build_b as this is in next stage and it gets triggered by PipelineProcessWorker
            build_b.reload.success
K
Kamil Trzcinski 已提交
1195 1196
          end

L
Lin Jen-Shin 已提交
1197
          it 'receives a success event once' do
1198
            expect(WebMock).to have_requested_pipeline_hook('success').once
K
Kamil Trzcinski 已提交
1199
          end
1200 1201
        end

L
Lin Jen-Shin 已提交
1202 1203 1204 1205 1206
        context 'when stage one failed' do
          before do
            build_a.drop
          end

L
Lin Jen-Shin 已提交
1207
          it 'receives a failed event once' do
L
Lin Jen-Shin 已提交
1208 1209 1210 1211
            expect(WebMock).to have_requested_pipeline_hook('failed').once
          end
        end

1212
        def have_requested_pipeline_hook(status)
K
Kamil Trzcinski 已提交
1213
          have_requested(:post, hook.url).with do |req|
1214 1215 1216 1217
            json_body = JSON.parse(req.body)
            json_body['object_attributes']['status'] == status &&
              json_body['builds'].length == 2
          end
1218
        end
1219
      end
1220 1221 1222 1223 1224
    end

    context 'with pipeline hooks disabled' do
      let(:enabled) { false }

K
Kamil Trzcinski 已提交
1225
      before do
1226 1227
        build_a.enqueue
        build_b.enqueue
K
Kamil Trzcinski 已提交
1228 1229
      end

1230 1231 1232 1233
      it 'did not execute pipeline_hook after touched' do
        expect(WebMock).not_to have_requested(:post, hook.url)
      end
    end
K
Kamil Trzcinski 已提交
1234

L
Lin Jen-Shin 已提交
1235 1236 1237 1238 1239 1240
    def create_build(name, stage_idx)
      create(:ci_build,
             :created,
             pipeline: pipeline,
             name: name,
             stage_idx: stage_idx)
K
Kamil Trzcinski 已提交
1241
    end
1242
  end
1243 1244

  describe "#merge_requests" do
1245
    let(:project) { create(:project) }
1246
    let(:pipeline) { create(:ci_empty_pipeline, status: 'created', project: project, ref: 'master', sha: 'a288a022a53a5a944fae87bcec6efc87b7061808') }
1247 1248

    it "returns merge requests whose `diff_head_sha` matches the pipeline's SHA" do
1249
      allow_any_instance_of(MergeRequest).to receive(:diff_head_sha) { 'a288a022a53a5a944fae87bcec6efc87b7061808' }
F
Felipe Artur 已提交
1250
      merge_request = create(:merge_request, source_project: project, head_pipeline: pipeline, source_branch: pipeline.ref)
1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267

      expect(pipeline.merge_requests).to eq([merge_request])
    end

    it "doesn't return merge requests whose source branch doesn't match the pipeline's ref" do
      create(:merge_request, source_project: project, source_branch: 'feature', target_branch: 'master')

      expect(pipeline.merge_requests).to be_empty
    end

    it "doesn't return merge requests whose `diff_head_sha` doesn't match the pipeline's SHA" do
      create(:merge_request, source_project: project, source_branch: pipeline.ref)
      allow_any_instance_of(MergeRequest).to receive(:diff_head_sha) { '97de212e80737a608d939f648d959671fb0a0142b' }

      expect(pipeline.merge_requests).to be_empty
    end
  end
1268

1269
  describe "#all_merge_requests" do
1270
    let(:project) { create(:project) }
1271
    let(:pipeline) { create(:ci_empty_pipeline, status: 'created', project: project, ref: 'master') }
1272

1273
    it "returns all merge requests having the same source branch" do
1274 1275 1276 1277 1278
      merge_request = create(:merge_request, source_project: project, source_branch: pipeline.ref)

      expect(pipeline.all_merge_requests).to eq([merge_request])
    end

1279
    it "doesn't return merge requests having a different source branch" do
1280 1281 1282 1283 1284 1285
      create(:merge_request, source_project: project, source_branch: 'feature', target_branch: 'master')

      expect(pipeline.all_merge_requests).to be_empty
    end
  end

1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297
  describe '#stuck?' do
    before do
      create(:ci_build, :pending, pipeline: pipeline)
    end

    context 'when pipeline is stuck' do
      it 'is stuck' do
        expect(pipeline).to be_stuck
      end
    end

    context 'when pipeline is not stuck' do
1298 1299 1300
      before do
        create(:ci_runner, :shared, :online)
      end
1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329

      it 'is not stuck' do
        expect(pipeline).not_to be_stuck
      end
    end
  end

  describe '#has_yaml_errors?' do
    context 'when pipeline has errors' do
      let(:pipeline) do
        create(:ci_pipeline, config: { rspec: nil })
      end

      it 'contains yaml errors' do
        expect(pipeline).to have_yaml_errors
      end
    end

    context 'when pipeline does not have errors' do
      let(:pipeline) do
        create(:ci_pipeline, config: { rspec: { script: 'rake test' } })
      end

      it 'does not containyaml errors' do
        expect(pipeline).not_to have_yaml_errors
      end
    end
  end

1330
  describe 'notifications when pipeline success or failed' do
1331
    let(:project) { create(:project, :repository) }
L
Lin Jen-Shin 已提交
1332 1333 1334 1335 1336 1337 1338 1339

    let(:pipeline) do
      create(:ci_pipeline,
             project: project,
             sha: project.commit('master').sha,
             user: create(:user))
    end

1340
    before do
1341 1342
      project.team << [pipeline.user, Gitlab::Access::DEVELOPER]

1343 1344
      pipeline.user.global_notification_setting
        .update(level: 'custom', failed_pipeline: true, success_pipeline: true)
S
Sean McGivern 已提交
1345

1346 1347 1348 1349
      perform_enqueued_jobs do
        pipeline.enqueue
        pipeline.run
      end
1350 1351 1352 1353
    end

    shared_examples 'sending a notification' do
      it 'sends an email' do
1354
        should_only_email(pipeline.user, kind: :bcc)
1355 1356 1357 1358 1359
      end
    end

    shared_examples 'not sending any notification' do
      it 'does not send any email' do
1360
        should_not_email_anyone
1361 1362 1363 1364 1365 1366
      end
    end

    context 'with success pipeline' do
      before do
        perform_enqueued_jobs do
L
Lin Jen-Shin 已提交
1367
          pipeline.succeed
1368 1369
        end
      end
L
Lin Jen-Shin 已提交
1370 1371

      it_behaves_like 'sending a notification'
1372 1373 1374 1375 1376
    end

    context 'with failed pipeline' do
      before do
        perform_enqueued_jobs do
1377 1378
          create(:ci_build, :failed, pipeline: pipeline)
          create(:generic_commit_status, :failed, pipeline: pipeline)
1379

1380
          pipeline.drop
1381 1382
        end
      end
L
Lin Jen-Shin 已提交
1383 1384

      it_behaves_like 'sending a notification'
1385 1386 1387 1388 1389 1390 1391 1392
    end

    context 'with skipped pipeline' do
      before do
        perform_enqueued_jobs do
          pipeline.skip
        end
      end
L
Lin Jen-Shin 已提交
1393 1394

      it_behaves_like 'not sending any notification'
1395 1396 1397 1398 1399 1400 1401 1402
    end

    context 'with cancelled pipeline' do
      before do
        perform_enqueued_jobs do
          pipeline.cancel
        end
      end
L
Lin Jen-Shin 已提交
1403 1404

      it_behaves_like 'not sending any notification'
1405 1406
    end
  end
D
Douwe Maan 已提交
1407
end