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
|
class PipelineSerializer < BaseSerializer
InvalidResourceError = Class.new(StandardError)
entity PipelineEntity
def with_pagination(request, response)
tap { @paginator = Gitlab::Serializer::Pagination.new(request, response) }
end
def paginated?
@paginator.present?
end
def represent(resource, opts = {})
if resource.is_a?(ActiveRecord::Relation)
resource = resource.preload(
:user,
:trigger_requests,
statuses: { project: [:project_feature, :namespace] },
project: :namespace)
if paginated?
resource = @paginator.paginate(resource)
end
resource = resource.preload([
:retryable_builds,
:cancelable_statuses,
:trigger_requests,
:project,
{ pending_builds: :project },
{ manual_actions: :project },
{ artifacts: :project }
])
end
preload_commit_authors(resource)
elsif paginated?
raise Gitlab::Serializer::Pagination::InvalidResourceError
end
super(resource, opts)
end
def represent_status(resource)
return {} unless resource.present?
data = represent(resource, { only: [{ details: [:status] }] })
data.dig(:details, :status) || {}
end
private
def preload_commit_authors(resource)
emails = find_unique_author_emails(resource)
authors = find_authors_by_emails(emails)
author_map = index_authors_by_emails(authors)
resource.each do |pipeline|
# Using safe navigator would always construct the arguments, bad.
# rubocop:disable Style/SafeNavigation
if pipeline.commit
pipeline.commit.author = author_map[pipeline.git_author_email]
end
end
end
def find_unique_author_emails(resource)
emails = Set.new
resource.each do |r|
emails << r.git_author_email.downcase if r.git_author_email
end
emails.to_a
end
def find_authors_by_emails(emails)
sql = <<-SQL.strip_heredoc
SELECT users.*, emails.email AS alternative_email
FROM users LEFT OUTER JOIN emails ON emails.user_id = users.id
WHERE users.email IN (?)
OR emails.email in (?)
SQL
User.find_by_sql([sql, emails, emails])
end
def index_authors_by_emails(authors)
authors.index_by do |a|
a.alternative_email || a.email
end
end
def represent_stages(resource)
return {} unless resource.present?
data = represent(resource, { only: [{ details: [:stages] }] })
data.dig(:details, :stages) || []
end
end
|
