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
|
# frozen_string_literal: true
module Issues
class CloseWorker
include ApplicationWorker
data_consistency :always
sidekiq_options retry: 3
idempotent!
deduplicate :until_executed, including_scheduled: true
feature_category :source_code_management
urgency :high
weight 2
def perform(project_id, issue_id, issue_type, params = {})
project = Project.find_by_id(project_id)
unless project
logger.info(structured_payload(message: "Project not found.", project_id: project_id))
return
end
issue = case issue_type
when "ExternalIssue"
ExternalIssue.new(issue_id, project)
else
Issue.find_by_id(issue_id)
end
unless issue
logger.info(structured_payload(message: "Issue not found.", issue_id: issue_id))
return
end
author = User.find_by_id(params["closed_by"])
unless author
logger.info(structured_payload(message: "Author not found.", user_id: params["closed_by"]))
return
end
user = User.find_by_id(params["user_id"])
# Only authorizing if user is present for backwards compatibility.
# TODO: Remove with https://gitlab.com/gitlab-org/gitlab/-/work_items/509422
if user && !issue.is_a?(ExternalIssue) && !user.can?(:update_issue, issue)
logger.info(
structured_payload(message: "User cannot update issue.", user_id: params["user_id"], issue_id: issue_id)
)
return
end
commit = Commit.build_from_sidekiq_hash(project, params["commit_hash"])
service = Issues::CloseService.new(container: project, current_user: author)
service.execute(issue, commit: commit)
end
end
end
|
