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
|
# frozen_string_literal: true
module Tooling
module Danger
module SidekiqQueues
def changed_queue_files
@changed_queue_files ||= git.modified_files.grep(%r{\A(ee/)?app/workers/all_queues\.yml})
end
def added_queue_names
@added_queue_names ||= new_queues.keys - old_queues.keys
end
def changed_queue_names
@changed_queue_names ||=
(new_queues.values_at(*old_queues.keys) - old_queues.values)
.compact.map { |queue| queue[:name] } # rubocop:disable Rails/Pluck
end
private
def old_queues
@old_queues ||= queues_for(gitlab.base_commit)
end
def new_queues
@new_queues ||= queues_for(gitlab.head_commit)
end
def queues_for(branch)
changed_queue_files
.flat_map { |file| YAML.safe_load(`git show #{branch}:#{file}`, permitted_classes: [Symbol]) }
.to_h { |queue| [queue[:name], queue] }
end
end
end
end
|
