summaryrefslogtreecommitdiff
path: root/app/workers/merge_requests/create_approval_note_worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/merge_requests/create_approval_note_worker.rb')
-rw-r--r--app/workers/merge_requests/create_approval_note_worker.rb32
1 files changed, 32 insertions, 0 deletions
diff --git a/app/workers/merge_requests/create_approval_note_worker.rb b/app/workers/merge_requests/create_approval_note_worker.rb
new file mode 100644
index 00000000000..841431f6a9d
--- /dev/null
+++ b/app/workers/merge_requests/create_approval_note_worker.rb
@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+module MergeRequests
+ class CreateApprovalNoteWorker
+ include Gitlab::EventStore::Subscriber
+
+ data_consistency :always
+ feature_category :code_review
+ urgency :low
+ idempotent!
+
+ 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
+
+ SystemNoteService.approve_mr(merge_request, current_user)
+ end
+ end
+end