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
|
# frozen_string_literal: true
module Issuable
class RelatedLinksCreateWorker
include ApplicationWorker
data_consistency :delayed
sidekiq_options retry: 3
feature_category :portfolio_management
worker_resource_boundary :unknown
urgency :high
idempotent!
def perform(args)
@params = args.with_indifferent_access
@user = User.find_by_id(params[:user_id])
@issuable = issuable_class.find_by_id(params[:issuable_id])
@links = issuable_class.related_link_class&.where(id: params[:link_ids])
return unless user && issuable && links.present?
create_issuable_notes!
rescue ArgumentError => error
logger.error(
worker: self.class.name,
message: "Failed to complete job (user_id:#{params[:user_id]}, issuable_id:#{params[:issuable_id]}, " \
"issuable_class:#{params[:issuable_class]}): #{error.message}"
)
end
private
attr_reader :params, :user, :issuable, :links
def issuable_class
params[:issuable_class].constantize
rescue NameError
raise ArgumentError, "Unknown class '#{params[:issuable_class]}'"
end
def create_issuable_notes!
errors = create_notes.compact
return unless errors.any?
raise ArgumentError, "Could not create notes: #{errors.join(', ')}"
end
def create_notes
linked_item_notes_errors = links.filter_map { |link| create_system_note(link.target, issuable) }
issuable_note_error = create_system_note(issuable, links.collect(&:target))
linked_item_notes_errors << issuable_note_error
end
def create_system_note(noteable, references, method_name = :relate_issuable)
note = ::SystemNoteService.try(method_name, noteable, references, user)
return if note.present?
"{noteable_id: #{noteable.id}, reference_ids: #{[references].flatten.collect(&:id)}}"
end
end
end
Issuable::RelatedLinksCreateWorker.prepend_mod_with('Issuable::RelatedLinksCreateWorker')
|
