summaryrefslogtreecommitdiff
path: root/spec/lib/gitlab/analytics/cycle_analytics/records_fetcher_spec.rb
blob: ebc5ae2a632eae786793bcda34b5cc7b5a665906 (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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
# frozen_string_literal: true

require 'spec_helper'

RSpec.describe Gitlab::Analytics::CycleAnalytics::RecordsFetcher do
  around do |example|
    Timecop.freeze { example.run }
  end

  let(:params) { { from: 1.year.ago, current_user: user } }

  let_it_be(:project) { create(:project, :empty_repo) }
  let_it_be(:user) { create(:user) }

  subject do
    Gitlab::Analytics::CycleAnalytics::DataCollector.new(
      stage: stage,
      params: params
    ).records_fetcher.serialized_records
  end

  describe '#serialized_records' do
    shared_context 'when records are loaded by maintainer' do
      before do
        project.add_user(user, Gitlab::Access::DEVELOPER)
      end

      it 'returns all records' do
        expect(subject.size).to eq(2)
      end
    end

    describe 'for issue based stage' do
      let_it_be(:issue1) { create(:issue, project: project) }
      let_it_be(:issue2) { create(:issue, project: project, confidential: true) }

      let(:stage) do
        build(:cycle_analytics_project_stage, {
          start_event_identifier: :plan_stage_start,
          end_event_identifier: :issue_first_mentioned_in_commit,
          project: project
        })
      end

      before do
        issue1.metrics.update(first_added_to_board_at: 3.days.ago, first_mentioned_in_commit_at: 2.days.ago)
        issue2.metrics.update(first_added_to_board_at: 3.days.ago, first_mentioned_in_commit_at: 2.days.ago)
      end

      context 'when records are loaded by guest' do
        before do
          project.add_user(user, Gitlab::Access::GUEST)
        end

        it 'filters out confidential issues' do
          expect(subject.size).to eq(1)
          expect(subject.first[:iid].to_s).to eq(issue1.iid.to_s)
        end
      end

      include_context 'when records are loaded by maintainer'
    end

    describe 'for merge request based stage' do
      let(:mr1) { create(:merge_request, created_at: 5.days.ago, source_project: project, allow_broken: true) }
      let(:mr2) { create(:merge_request, created_at: 4.days.ago, source_project: project, allow_broken: true) }
      let(:stage) do
        build(:cycle_analytics_project_stage, {
          start_event_identifier: :merge_request_created,
          end_event_identifier: :merge_request_merged,
          project: project
        })
      end

      before do
        mr1.metrics.update(merged_at: 3.days.ago)
        mr2.metrics.update(merged_at: 3.days.ago)
      end

      include_context 'when records are loaded by maintainer'
    end

    describe 'special case' do
      let(:mr1) { create(:merge_request, source_project: project, allow_broken: true, created_at: 20.days.ago) }
      let(:mr2) { create(:merge_request, source_project: project, allow_broken: true, created_at: 19.days.ago) }
      let(:ci_build1) { create(:ci_build) }
      let(:ci_build2) { create(:ci_build) }
      let(:default_stages) { Gitlab::Analytics::CycleAnalytics::DefaultStages }
      let(:stage) { build(:cycle_analytics_project_stage, default_stages.params_for_test_stage.merge(project: project)) }

      before do
        mr1.metrics.update!({
          merged_at: 5.days.ago,
          first_deployed_to_production_at: 1.day.ago,
          latest_build_started_at: 5.days.ago,
          latest_build_finished_at: 1.day.ago,
          pipeline: ci_build1.pipeline
        })
        mr2.metrics.update!({
          merged_at: 10.days.ago,
          first_deployed_to_production_at: 5.days.ago,
          latest_build_started_at: 9.days.ago,
          latest_build_finished_at: 7.days.ago,
          pipeline: ci_build2.pipeline
        })

        project.add_user(user, Gitlab::Access::MAINTAINER)
      end

      context 'returns build records' do
        shared_examples 'orders build records by `latest_build_finished_at`' do
          it 'orders by `latest_build_finished_at`' do
            build_ids = subject.map { |item| item[:id] }

            expect(build_ids).to eq([ci_build1.id, ci_build2.id])
          end
        end

        context 'when requesting records for default test stage' do
          include_examples 'orders build records by `latest_build_finished_at`'
        end

        context 'when requesting records for default staging stage' do
          before do
            stage.assign_attributes(default_stages.params_for_staging_stage)
          end

          include_examples 'orders build records by `latest_build_finished_at`'
        end
      end
    end
  end

  describe 'pagination' do
    let_it_be(:issue1) { create(:issue, project: project) }
    let_it_be(:issue2) { create(:issue, project: project) }
    let_it_be(:issue3) { create(:issue, project: project) }

    let(:stage) do
      build(:cycle_analytics_project_stage, {
        start_event_identifier: :plan_stage_start,
        end_event_identifier: :issue_first_mentioned_in_commit,
        project: project
      })
    end

    before(:all) do
      issue1.metrics.update(first_added_to_board_at: 3.days.ago, first_mentioned_in_commit_at: 2.days.ago)
      issue2.metrics.update(first_added_to_board_at: 3.days.ago, first_mentioned_in_commit_at: 2.days.ago)
      issue3.metrics.update(first_added_to_board_at: 3.days.ago, first_mentioned_in_commit_at: 2.days.ago)
    end

    before do
      project.add_user(user, Gitlab::Access::DEVELOPER)

      stub_const('Gitlab::Analytics::CycleAnalytics::RecordsFetcher::MAX_RECORDS', 2)
    end

    it 'limits the results' do
      expect(subject.size).to eq(2)
    end

    it 'loads the record for the next page' do
      params[:page] = 2

      expect(subject.size).to eq(1)
    end
  end
end