pipeline_spec.rb 41.3 KB
Newer Older
Douwe Maan's avatar
Douwe Maan committed
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
Douwe Maan's avatar
Douwe Maan committed
10

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) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
17
  it { is_expected.to have_many(:trigger_requests) }
Shinya Maeda's avatar
init  
Shinya Maeda committed
18
  it { is_expected.to have_many(:variables) }
Dmitriy Zaporozhets's avatar
Dmitriy Zaporozhets committed
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) }
Douwe Maan's avatar
Douwe Maan committed
25

Dmitriy Zaporozhets's avatar
Dmitriy Zaporozhets committed
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 }
29
  it { is_expected.to delegate_method(:full_path).to(:project).with_prefix }
Douwe Maan's avatar
Douwe Maan committed
30

31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52
  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

53 54 55 56 57 58 59 60
  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

61
  describe '#valid_commit_sha' do
Douwe Maan's avatar
Douwe Maan committed
62 63
    context 'commit.sha can not start with 00000000' do
      before do
64 65
        pipeline.sha = '0' * 40
        pipeline.valid_commit_sha
Douwe Maan's avatar
Douwe Maan committed
66 67
      end

68
      it('commit errors should not be empty') { expect(pipeline.errors).not_to be_empty }
Douwe Maan's avatar
Douwe Maan committed
69 70 71
    end
  end

72
  describe '#short_sha' do
73
    subject { pipeline.short_sha }
Douwe Maan's avatar
Douwe Maan committed
74

Dmitriy Zaporozhets's avatar
Dmitriy Zaporozhets committed
75 76 77
    it 'has 8 items' do
      expect(subject.size).to eq(8)
    end
78
    it { expect(pipeline.sha).to start_with(subject) }
Douwe Maan's avatar
Douwe Maan committed
79 80
  end

81
  describe '#retried' do
82
    subject { pipeline.retried }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
83 84

    before do
85 86
      @build1 = create(:ci_build, pipeline: pipeline, name: 'deploy', retried: true)
      @build2 = create(:ci_build, pipeline: pipeline, name: 'deploy')
Kamil Trzcinski's avatar
Kamil Trzcinski committed
87 88 89
    end

    it 'returns old builds' do
90
      is_expected.to contain_exactly(@build1)
Kamil Trzcinski's avatar
Kamil Trzcinski committed
91 92 93
    end
  end

Douwe Maan's avatar
Douwe Maan committed
94
  describe "coverage" do
95
    let(:project) { create(:project, build_coverage_regex: "/.*/") }
96
    let(:pipeline) { create(:ci_empty_pipeline, project: project) }
Douwe Maan's avatar
Douwe Maan committed
97 98

    it "calculates average when there are two builds with coverage" do
99 100
      create(:ci_build, name: "rspec", coverage: 30, pipeline: pipeline)
      create(:ci_build, name: "rubocop", coverage: 40, pipeline: pipeline)
101
      expect(pipeline.coverage).to eq("35.00")
Douwe Maan's avatar
Douwe Maan committed
102 103 104
    end

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

    it "calculates average when there are two builds with coverage and one is retried" do
112 113 114
      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)
115
      expect(pipeline.coverage).to eq("35.00")
Douwe Maan's avatar
Douwe Maan committed
116 117 118
    end

    it "calculates average when there is one build without coverage" do
119
      FactoryGirl.create(:ci_build, pipeline: pipeline)
120
      expect(pipeline.coverage).to be_nil
Douwe Maan's avatar
Douwe Maan committed
121 122
    end
  end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
123 124

  describe '#retryable?' do
125
    subject { pipeline.retryable? }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
126 127 128

    context 'no failed builds' do
      before do
129
        create_build('rspec', 'success')
Kamil Trzcinski's avatar
Kamil Trzcinski committed
130 131
      end

132
      it 'is not retryable' do
Kamil Trzcinski's avatar
Kamil Trzcinski committed
133 134
        is_expected.to be_falsey
      end
135 136 137 138 139 140 141 142 143 144

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

        it 'is retryable' do
          is_expected.to be_truthy
        end
      end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
145 146 147 148
    end

    context 'with failed builds' do
      before do
149 150
        create_build('rspec', 'running')
        create_build('rubocop', 'failed')
Kamil Trzcinski's avatar
Kamil Trzcinski committed
151 152
      end

153
      it 'is retryable' do
Kamil Trzcinski's avatar
Kamil Trzcinski committed
154 155 156
        is_expected.to be_truthy
      end
    end
157 158 159 160

    def create_build(name, status)
      create(:ci_build, name: name, status: status, pipeline: pipeline)
    end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
161 162
  end

163 164 165 166 167 168 169 170 171 172 173 174
  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

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 211
  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

212
  describe 'pipeline stages' do
Kamil Trzcinski's avatar
Kamil Trzcinski committed
213
    before do
214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238
      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

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

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

250 251 252 253 254 255 256 257
    describe '#seeds_size' do
      let(:pipeline) { build(:ci_pipeline_with_one_job) }

      it 'returns number of jobs in stage seeds' do
        expect(pipeline.seeds_size).to eq 1
      end
    end

258 259
    describe '#legacy_stages' do
      subject { pipeline.legacy_stages }
260 261 262 263 264

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

267 268 269 270
      context 'stages with statuses' do
        let(:statuses) do
          subject.map { |stage| [stage.name, stage.status] }
        end
271

272
        it 'returns list of stages with correct statuses' do
Douwe Maan's avatar
Douwe Maan committed
273 274 275
          expect(statuses).to eq([%w(build failed),
                                  %w(test success),
                                  %w(deploy running)])
276
        end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
277

278
        context 'when commit status is retried' do
279 280 281 282 283 284
          before do
            create(:commit_status, pipeline: pipeline,
                                   stage: 'build',
                                   name: 'mac',
                                   stage_idx: 0,
                                   status: 'success')
285 286

            pipeline.process!
287 288 289
          end

          it 'ignores the previous state' do
Douwe Maan's avatar
Douwe Maan committed
290 291 292
            expect(statuses).to eq([%w(build success),
                                    %w(test success),
                                    %w(deploy running)])
293
          end
294 295
        end
      end
296 297 298 299 300 301 302 303 304 305 306 307

      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
308
          deploy_stage = pipeline.legacy_stages.third
309 310 311 312 313

          expect(deploy_stage).not_to receive(:statuses)
          expect(deploy_stage).to have_warnings
        end
      end
314
    end
315

316 317 318
    describe '#stages_count' do
      it 'returns a valid number of stages' do
        expect(pipeline.stages_count).to eq(3)
319
      end
320
    end
321

322
    describe '#stages_names' do
323
      it 'returns a valid names of stages' do
324
        expect(pipeline.stages_names).to eq(%w(build test deploy))
325
      end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
326 327 328
    end
  end

329 330
  describe '#legacy_stage' do
    subject { pipeline.legacy_stage('test') }
331 332

    context 'with status in stage' do
Kamil Trzcinski's avatar
Kamil Trzcinski committed
333 334
      before do
        create(:commit_status, pipeline: pipeline, stage: 'test')
335
      end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
336

337
      it { expect(subject).to be_a Ci::LegacyStage }
338 339
      it { expect(subject.name).to eq 'test' }
      it { expect(subject.statuses).not_to be_empty }
340 341 342
    end

    context 'without status in stage' do
Kamil Trzcinski's avatar
Kamil Trzcinski committed
343 344 345
      before do
        create(:commit_status, pipeline: pipeline, stage: 'build')
      end
346 347 348 349 350 351 352

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

353
  describe 'state machine' do
354
    let(:current) { Time.now.change(usec: 0) }
355 356 357
    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) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
358

359
    describe '#duration' do
360 361 362 363 364 365 366 367
      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
Lin Jen-Shin's avatar
Lin Jen-Shin committed
368

369 370 371 372 373 374 375
          travel_to(current + 40) do
            build_b.drop!
          end

          travel_to(current + 70) do
            build_c.success!
          end
376
        end
377

378 379 380 381
        it 'matches sum of builds duration' do
          pipeline.reload

          expect(pipeline.duration).to eq(40)
382
        end
383 384
      end

385 386
      context 'when pipeline becomes blocked' do
        let!(:build) { create_build('build:1') }
387
        let!(:action) { create_build('manual:action', :manual) }
388

389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404
        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
405
      end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
406 407
    end

408 409 410
    describe '#started_at' do
      it 'updates on transitioning to running' do
        build.run
Kamil Trzcinski's avatar
Kamil Trzcinski committed
411

412 413 414
        expect(pipeline.reload.started_at).not_to be_nil
      end

415
      it 'does not update on transitioning to success' do
416 417 418
        build.success

        expect(pipeline.reload.started_at).to be_nil
Kamil Trzcinski's avatar
Kamil Trzcinski committed
419 420 421
      end
    end

422 423 424
    describe '#finished_at' do
      it 'updates on transitioning to success' do
        build.success
Kamil Trzcinski's avatar
Kamil Trzcinski committed
425

426
        expect(pipeline.reload.finished_at).not_to be_nil
Kamil Trzcinski's avatar
Kamil Trzcinski committed
427 428
      end

429
      it 'does not update on transitioning to running' do
430 431 432
        build.run

        expect(pipeline.reload.finished_at).to be_nil
Kamil Trzcinski's avatar
Kamil Trzcinski committed
433 434
      end
    end
435

436
    describe 'merge request metrics' do
437
      let(:project) { create(:project, :repository) }
438 439 440
      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) }

441 442 443
      before do
        expect(PipelineMetricsWorker).to receive(:perform_async).with(pipeline.id)
      end
444

445 446 447
      context 'when transitioning to running' do
        it 'schedules metrics workers' do
          pipeline.run
448 449 450 451
        end
      end

      context 'when transitioning to success' do
452 453
        it 'schedules metrics workers' do
          pipeline.succeed
454 455 456
        end
      end
    end
457

458
    describe 'pipeline caching' do
459 460
      it 'performs ExpirePipelinesCacheWorker' do
        expect(ExpirePipelineCacheWorker).to receive(:perform_async).with(pipeline.id)
461 462 463 464 465

        pipeline.cancel
      end
    end

466 467
    def create_build(name, *traits, queued_at: current, started_from: 0, **opts)
      create(:ci_build, *traits,
Lin Jen-Shin's avatar
Lin Jen-Shin committed
468 469
             name: name,
             pipeline: pipeline,
470
             queued_at: queued_at,
471 472
             started_at: queued_at + started_from,
             **opts)
Lin Jen-Shin's avatar
Lin Jen-Shin committed
473
    end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
474
  end
Kamil Trzcinski's avatar
Kamil Trzcinski committed
475 476

  describe '#branch?' do
477
    subject { pipeline.branch? }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
478 479 480

    context 'is not a tag' do
      before do
481
        pipeline.tag = false
Kamil Trzcinski's avatar
Kamil Trzcinski committed
482 483 484 485 486 487 488 489 490
      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
491
        pipeline.tag = true
Kamil Trzcinski's avatar
Kamil Trzcinski committed
492 493 494 495 496 497 498
      end

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

500
  context 'with non-empty project' do
501
    let(:project) { create(:project, :repository) }
502 503 504 505 506 507 508

    let(:pipeline) do
      create(:ci_pipeline,
             project: project,
             ref: project.default_branch,
             sha: project.commit.sha)
    end
509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529

    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

530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546
  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') }

547 548 549 550
        before do
          manual.update(retried: true)
        end

551 552 553 554 555 556
        it 'returns latest one' do
          is_expected.to contain_exactly(manual2)
        end
      end
    end
  end
557

558
  describe '#has_kubernetes_active?' do
559
    context 'when kubernetes is active' do
560
      shared_examples 'same behavior between KubernetesService and Platform::Kubernetes' do
561 562 563 564 565 566 567 568
        it 'returns true' do
          expect(pipeline).to have_kubernetes_active
        end
      end

      context 'when user configured kubernetes from Integration > Kubernetes' do
        let(:project) { create(:kubernetes_project) }

569
        it_behaves_like 'same behavior between KubernetesService and Platform::Kubernetes'
570 571 572 573 574
      end

      context 'when user configured kubernetes from CI/CD > Clusters' do
        let!(:cluster) { create(:cluster, :project, :provided_by_gcp) }
        let(:project) { cluster.project }
575

576
        it_behaves_like 'same behavior between KubernetesService and Platform::Kubernetes'
577 578 579
      end
    end

580
    context 'when kubernetes is not active' do
581
      it 'returns false' do
582
        expect(pipeline).not_to have_kubernetes_active
583 584 585 586
      end
    end
  end

587
  describe '#has_stage_seeds?' do
588
    context 'when pipeline has stage seeds' do
589
      subject { build(:ci_pipeline_with_one_job) }
590

591
      it { is_expected.to have_stage_seeds }
592 593
    end

594
    context 'when pipeline does not have stage seeds' do
595 596
      subject { create(:ci_pipeline_without_jobs) }

597
      it { is_expected.not_to have_stage_seeds }
598 599 600
    end
  end

Connor Shea's avatar
Connor Shea committed
601 602
  describe '#has_warnings?' do
    subject { pipeline.has_warnings? }
603 604 605

    context 'build which is allowed to fail fails' do
      before do
Connor Shea's avatar
Connor Shea committed
606 607
        create :ci_build, :success, pipeline: pipeline, name: 'rspec'
        create :ci_build, :allowed_to_fail, :failed, pipeline: pipeline, name: 'rubocop'
608
      end
609

610 611 612 613 614 615 616
      it 'returns true' do
        is_expected.to be_truthy
      end
    end

    context 'build which is allowed to fail succeeds' do
      before do
Connor Shea's avatar
Connor Shea committed
617 618
        create :ci_build, :success, pipeline: pipeline, name: 'rspec'
        create :ci_build, :allowed_to_fail, :success, pipeline: pipeline, name: 'rubocop'
619
      end
620

621 622 623 624
      it 'returns false' do
        is_expected.to be_falsey
      end
    end
Connor Shea's avatar
Connor Shea committed
625 626 627 628 629 630 631 632 633 634 635 636

    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
637
  end
638

639
  shared_context 'with some outdated pipelines' do
640
    before do
641 642 643 644
      create_pipeline(:canceled, 'ref', 'A', project)
      create_pipeline(:success, 'ref', 'A', project)
      create_pipeline(:failed, 'ref', 'B', project)
      create_pipeline(:skipped, 'feature', 'C', project)
645 646
    end

647 648 649 650 651 652 653 654
    def create_pipeline(status, ref, sha, project)
      create(
        :ci_empty_pipeline,
        status: status,
        ref: ref,
        sha: sha,
        project: project
      )
655 656 657
    end
  end

658
  describe '.newest_first' do
659
    include_context 'with some outdated pipelines'
660

661 662 663
    it 'returns the pipelines from new to old' do
      expect(described_class.newest_first.pluck(:status))
        .to eq(%w[skipped failed success canceled])
664 665 666 667
    end
  end

  describe '.latest_status' do
668
    include_context 'with some outdated pipelines'
669 670

    context 'when no ref is specified' do
671 672
      it 'returns the status of the latest pipeline' do
        expect(described_class.latest_status).to eq('skipped')
673 674 675 676
      end
    end

    context 'when ref is specified' do
677 678
      it 'returns the status of the latest pipeline for the given ref' do
        expect(described_class.latest_status('ref')).to eq('failed')
679 680 681 682
      end
    end
  end

683 684 685 686
  describe '.latest_successful_for' do
    include_context 'with some outdated pipelines'

    let!(:latest_successful_pipeline) do
687
      create_pipeline(:success, 'ref', 'D', project)
688 689 690
    end

    it 'returns the latest successful pipeline' do
691 692
      expect(described_class.latest_successful_for('ref'))
        .to eq(latest_successful_pipeline)
693 694 695
    end
  end

696 697 698
  describe '.latest_successful_for_refs' do
    include_context 'with some outdated pipelines'

699 700 701 702 703 704 705
    let!(:latest_successful_pipeline1) do
      create_pipeline(:success, 'ref1', 'D', project)
    end

    let!(:latest_successful_pipeline2) do
      create_pipeline(:success, 'ref2', 'D', project)
    end
706 707 708 709 710 711 712 713

    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

714 715 716 717 718 719 720 721 722 723 724 725 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 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769
  describe '.latest_status_per_commit' do
    let(:project) { create(:project) }

    before do
      pairs = [
        %w[success ref1 123],
        %w[manual master 123],
        %w[failed ref 456]
      ]

      pairs.each do |(status, ref, sha)|
        create(
          :ci_empty_pipeline,
          status: status,
          ref: ref,
          sha: sha,
          project: project
        )
      end
    end

    context 'without a ref' do
      it 'returns a Hash containing the latest status per commit for all refs' do
        expect(described_class.latest_status_per_commit(%w[123 456]))
          .to eq({ '123' => 'manual', '456' => 'failed' })
      end

      it 'only includes the status of the given commit SHAs' do
        expect(described_class.latest_status_per_commit(%w[123]))
          .to eq({ '123' => 'manual' })
      end

      context 'when there are two pipelines for a ref and SHA' do
        it 'returns the status of the latest pipeline' do
          create(
            :ci_empty_pipeline,
            status: 'failed',
            ref: 'master',
            sha: '123',
            project: project
          )

          expect(described_class.latest_status_per_commit(%w[123]))
            .to eq({ '123' => 'failed' })
        end
      end
    end

    context 'with a ref' do
      it 'only includes the pipelines for the given ref' do
        expect(described_class.latest_status_per_commit(%w[123 456], 'master'))
          .to eq({ '123' => 'manual' })
      end
    end
  end

770 771 772 773 774 775
  describe '.internal_sources' do
    subject { described_class.internal_sources }

    it { is_expected.to be_an(Array) }
  end

776
  describe '#status' do
777 778 779
    let(:build) do
      create(:ci_build, :created, pipeline: pipeline, name: 'test')
    end
780 781 782 783

    subject { pipeline.reload.status }

    context 'on queuing' do
784 785 786
      before do
        build.enqueue
      end
787 788 789 790 791 792

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

    context 'on run' do
      before do
793
        build.enqueue
794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820
        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

821 822 823 824 825 826 827
      context 'when build is pending' do
        let(:build) do
          create(:ci_build, :pending, pipeline: pipeline)
        end

        it { is_expected.to eq('canceled') }
      end
828
    end
829 830 831

    context 'on failure and build retry' do
      before do
Shinya Maeda's avatar
Shinya Maeda committed
832 833
        stub_not_protect_default_branch

834
        build.drop
835
        project.add_developer(user)
836 837

        Ci::Build.retry(build, user)
838 839 840 841 842 843 844 845
      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
846
  end
847

848 849 850 851
  describe '#ci_yaml_file_path' do
    subject { pipeline.ci_yaml_file_path }

    it 'returns the path from project' do
852
      allow(pipeline.project).to receive(:ci_config_path) { 'custom/path' }
853 854 855 856 857

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

    it 'returns default when custom path is nil' do
858
      allow(pipeline.project).to receive(:ci_config_path) { nil }
859 860 861 862 863

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

    it 'returns default when custom path is empty' do
864
      allow(pipeline.project).to receive(:ci_config_path) { '' }
865 866 867 868 869

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

870
  describe '#set_config_source' do
871 872 873
    context 'when pipelines does not contain needed data' do
      it 'defines source to be unknown' do
        pipeline.set_config_source
874

875
        expect(pipeline).to be_unknown_source
876
      end
877
    end
878

879 880 881 882 883 884 885 886 887 888 889 890
    context 'when pipeline contains all needed data' do
      let(:pipeline) do
        create(:ci_pipeline, project: project,
                             sha: '1234',
                             ref: 'master',
                             source: :push)
      end

      context 'when the repository has a config file' do
        before do
          allow(project.repository).to receive(:gitlab_ci_yml_for)
            .and_return('config')
891
        end
892

893 894
        it 'defines source to be from repository' do
          pipeline.set_config_source
895

896 897
          expect(pipeline).to be_repository_source
        end
898

899 900
        context 'when loading an object' do
          let(:new_pipeline) { Ci::Pipeline.find(pipeline.id) }
901

902 903 904
          it 'does not redefine the source' do
            # force to overwrite the source
            pipeline.unknown_source!
905

906
            expect(new_pipeline).to be_unknown_source
907
          end
908
        end
909
      end
910

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

914 915 916 917 918
        context 'auto devops enabled' do
          before do
            stub_application_setting(auto_devops_enabled: true)
            allow(project).to receive(:ci_config_path) { 'custom' }
          end
919

920 921
          it 'defines source to be auto devops' do
            pipeline.set_config_source
922

923
            expect(pipeline).to be_auto_devops_source
924
          end
925
        end
926 927 928
      end
    end
  end
929

930 931
  describe '#ci_yaml_file' do
    let(:implied_yml) { Gitlab::Template::GitlabCiYmlTemplate.find('Auto-DevOps').content }
932

933
    context 'the source is unknown' do
934 935 936
      before do
        pipeline.unknown_source!
      end
937 938 939 940 941 942 943 944 945 946 947 948 949 950

      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')
951 952 953
      end
    end

954
    context 'the source is the repository' do
955 956 957
      before do
        pipeline.repository_source!
      end
958

959 960 961 962 963 964 965
      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
966
      end
967
    end
968

969
    context 'when the source is auto_devops_source' do
970
      before do
971
        stub_application_setting(auto_devops_enabled: true)
972 973
        pipeline.auto_devops_source!
      end
974

975 976 977
      it 'finds the implied config' do
        expect(pipeline.ci_yaml_file).to eq(implied_yml)
        expect(pipeline.yaml_errors).to be_nil
978
      end
979 980 981
    end
  end

982
  describe '#detailed_status' do
983 984
    subject { pipeline.detailed_status(user) }

985 986 987 988
    context 'when pipeline is created' do
      let(:pipeline) { create(:ci_pipeline, status: :created) }

      it 'returns detailed status for created pipeline' do
989
        expect(subject.text).to eq 'created'
990 991 992 993 994 995 996
      end
    end

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

      it 'returns detailed status for pending pipeline' do
997
        expect(subject.text).to eq 'pending'
998 999 1000 1001 1002 1003 1004
      end
    end

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

      it 'returns detailed status for running pipeline' do
1005
        expect(subject.text).to eq 'running'
1006 1007 1008 1009 1010 1011 1012
      end
    end

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

      it 'returns detailed status for successful pipeline' do
1013
        expect(subject.text).to eq 'passed'
1014 1015 1016 1017 1018 1019 1020
      end
    end

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

      it 'returns detailed status for failed pipeline' do
1021
        expect(subject.text).to eq 'failed'
1022 1023 1024 1025 1026 1027 1028
      end
    end

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

      it 'returns detailed status for canceled pipeline' do