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
170
171
172
173
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
|
# frozen_string_literal: true
RSpec.shared_examples 'StageEventModel' do
describe '.upsert_data' do
let(:time) { Time.parse(Time.current.to_s(:db)) } # truncating the timestamp so we can compare it with the timestamp loaded from the DB
let(:input_data) do
[
{
stage_event_hash_id: 1,
issuable_id: 2,
group_id: 3,
project_id: 4,
author_id: 5,
milestone_id: 6,
state_id: 1,
start_event_timestamp: time,
end_event_timestamp: time
},
{
stage_event_hash_id: 7,
issuable_id: 8,
group_id: 10,
project_id: 11,
author_id: 12,
milestone_id: 13,
state_id: 1,
start_event_timestamp: time,
end_event_timestamp: time
}
]
end
let(:column_order) do
[
:stage_event_hash_id,
described_class.issuable_id_column,
:group_id,
:project_id,
:author_id,
:milestone_id,
:state_id,
:start_event_timestamp,
:end_event_timestamp
]
end
subject(:upsert_data) { described_class.upsert_data(input_data) }
it 'inserts the data' do
upsert_data
expect(described_class.count).to eq(input_data.count)
end
it 'does not produce duplicate rows' do
2.times { upsert_data }
expect(described_class.count).to eq(input_data.count)
end
it 'inserts the data correctly' do
upsert_data
output_data = described_class.all.map do |record|
column_order.map do |column|
if column == :state_id
described_class.states[record[column]]
else
record[column]
end
end
end.sort
expect(input_data.map(&:values).sort).to eq(output_data)
end
end
describe 'scopes' do
def attributes(array)
array.map(&:attributes)
end
RSpec::Matchers.define :match_attributes do |expected|
match do |actual|
actual.map(&:attributes) == expected.map(&:attributes)
end
end
let_it_be(:user) { create(:user) }
let_it_be(:project) { create(:user) }
let_it_be(:milestone) { create(:milestone) }
let_it_be(:issuable_with_assignee) { create(issuable_factory, assignees: [user])}
let_it_be(:record) { create(stage_event_factory, start_event_timestamp: 3.years.ago.to_date, end_event_timestamp: 2.years.ago.to_date) }
let_it_be(:record_with_author) { create(stage_event_factory, author_id: user.id) }
let_it_be(:record_with_project) { create(stage_event_factory, project_id: project.id) }
let_it_be(:record_with_group) { create(stage_event_factory, group_id: project.namespace_id) }
let_it_be(:record_with_assigned_issuable) { create(stage_event_factory, described_class.issuable_id_column => issuable_with_assignee.id) }
let_it_be(:record_with_milestone) { create(stage_event_factory, milestone_id: milestone.id) }
it 'filters by stage_event_hash_id' do
records = described_class.by_stage_event_hash_id(record.stage_event_hash_id)
expect(records).to match_attributes([record])
end
it 'filters by project_id' do
records = described_class.by_project_id(project.id)
expect(records).to match_attributes([record_with_project])
end
it 'filters by group_id' do
records = described_class.by_group_id(project.namespace_id)
expect(records).to match_attributes([record_with_group])
end
it 'filters by author_id' do
records = described_class.authored(user)
expect(records).to match_attributes([record_with_author])
end
it 'filters by assignee' do
records = described_class.assigned_to(user)
expect(records).to match_attributes([record_with_assigned_issuable])
end
it 'filters by milestone_id' do
records = described_class.with_milestone_id(milestone.id)
expect(records).to match_attributes([record_with_milestone])
end
describe 'start_event_timestamp filtering' do
it 'when range is given' do
records = described_class
.start_event_timestamp_after(4.years.ago)
.start_event_timestamp_before(2.years.ago)
expect(records).to match_attributes([record])
end
it 'when specifying upper bound' do
records = described_class.start_event_timestamp_before(2.years.ago)
expect(attributes(records)).to include(attributes([record]).first)
end
it 'when specifying the lower bound' do
records = described_class.start_event_timestamp_after(4.years.ago)
expect(attributes(records)).to include(attributes([record]).first)
end
end
describe 'end_event_timestamp filtering' do
it 'when range is given' do
records = described_class
.end_event_timestamp_after(3.years.ago)
.end_event_timestamp_before(1.year.ago)
expect(records).to match_attributes([record])
end
it 'when specifying upper bound' do
records = described_class.end_event_timestamp_before(1.year.ago)
expect(attributes(records)).to include(attributes([record]).first)
end
it 'when specifying the lower bound' do
records = described_class.end_event_timestamp_after(3.years.ago)
expect(attributes(records)).to include(attributes([record]).first)
end
end
end
describe '#total_time' do
it 'calcualtes total time from the start_event_timestamp and end_event_timestamp columns' do
model = described_class.new(start_event_timestamp: Time.new(2022, 1, 1, 12, 5, 0), end_event_timestamp: Time.new(2022, 1, 1, 12, 6, 30))
expect(model.total_time).to eq(90)
end
context 'when total time is calculated in SQL as an extra column' do
it 'returns the SQL calculated time' do
create(stage_event_factory) # rubocop:disable Rails/SaveBang
model = described_class.select('*, 5 AS total_time').first
expect(model.total_time).to eq(5)
end
end
end
end
|
