15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
# File 'app/workers/merge_requests/execute_approval_hooks_worker.rb', line 15
def handle_event(event)
current_user_id = event.data[:current_user_id]
merge_request_id = event.data[:merge_request_id]
current_user = User.find_by_id(current_user_id)
unless current_user
logger.info(structured_payload(message: 'Current user not found.', current_user_id: current_user_id))
return
end
merge_request = MergeRequest.find_by_id(merge_request_id)
unless merge_request
logger.info(structured_payload(message: 'Merge request not found.', merge_request_id: merge_request_id))
return
end
::MergeRequests::ExecuteApprovalHooksService
.new(project: merge_request.project, current_user: current_user)
.execute(merge_request)
end
|