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
|
# frozen_string_literal: true
module Integrations
class GroupMentionWorker
include ApplicationWorker
idempotent!
feature_category :integrations
deduplicate :until_executed
data_consistency :delayed
urgency :low
worker_has_external_dependencies!
def perform(args)
args = args.with_indifferent_access
mentionable_type = args[:mentionable_type]
mentionable_id = args[:mentionable_id]
hook_data = args[:hook_data]
is_confidential = args[:is_confidential]
mentionable = case mentionable_type
when 'Issue'
Issue.find_by_id(mentionable_id)
when 'MergeRequest'
MergeRequest.find_by_id(mentionable_id)
else
Sidekiq.logger.error(
message: 'Integrations::GroupMentionWorker: mentionable not supported',
mentionable_type: mentionable_type,
mentionable_id: mentionable_id
)
nil
end
return if mentionable.nil?
Integrations::GroupMentionService.new(mentionable, hook_data: hook_data, is_confidential: is_confidential).execute
end
end
end
|
