blob: e28b532ebb37484f6dc61e5c37f5f00edf909c62 (
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
|
# frozen_string_literal: true
module Resolvers
module Ci
class RunnerGroupsResolver < BaseResolver
include Gitlab::Graphql::Authorize::AuthorizeResource
include LooksAhead
include ResolvesGroups
type Types::GroupConnection, null: true
authorize :read_runner
authorizes_object!
alias_method :runner, :object
def resolve_with_lookahead(**args)
return unless runner.group_type?
BatchLoader::GraphQL.for(runner.id).batch(key: :runner_namespaces) do |runner_ids, loader|
plucked_runner_and_namespace_ids =
::Ci::RunnerNamespace
.for_runner(runner_ids)
.select(:runner_id, :namespace_id)
.pluck(:runner_id, :namespace_id) # rubocop: disable CodeReuse/ActiveRecord)
namespace_ids = plucked_runner_and_namespace_ids.collect(&:last).uniq
groups = apply_lookahead(::Group.id_in(namespace_ids))
Preloaders::GroupPolicyPreloader.new(groups, current_user).execute
groups_by_id = groups.index_by(&:id)
runner_group_ids_by_runner_id =
plucked_runner_and_namespace_ids
.group_by { |runner_id, _namespace_id| runner_id }
.transform_values { |values| values.filter_map { |_runner_id, namespace_id| groups_by_id[namespace_id] } }
runner_ids.each do |runner_id|
runner_namespaces = runner_group_ids_by_runner_id[runner_id] || []
loader.call(runner_id, runner_namespaces)
end
end
end
private
def preloads
super.merge({ web_url: [:route] })
end
end
end
end
|
