summaryrefslogtreecommitdiff
path: root/app/workers/members_destroyer/unassign_issuables_worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/members_destroyer/unassign_issuables_worker.rb')
-rw-r--r--app/workers/members_destroyer/unassign_issuables_worker.rb32
1 files changed, 32 insertions, 0 deletions
diff --git a/app/workers/members_destroyer/unassign_issuables_worker.rb b/app/workers/members_destroyer/unassign_issuables_worker.rb
new file mode 100644
index 00000000000..2c17120bf48
--- /dev/null
+++ b/app/workers/members_destroyer/unassign_issuables_worker.rb
@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+module MembersDestroyer
+ class UnassignIssuablesWorker
+ include ApplicationWorker
+
+ ENTITY_TYPES = %w(Group Project).freeze
+
+ queue_namespace :unassign_issuables
+ feature_category :authentication_and_authorization
+
+ idempotent!
+
+ def perform(user_id, entity_id, entity_type)
+ unless ENTITY_TYPES.include?(entity_type)
+ logger.error(
+ message: "#{entity_type} is not a supported entity.",
+ entity_type: entity_type,
+ entity_id: entity_id,
+ user_id: user_id
+ )
+
+ return
+ end
+
+ user = User.find(user_id)
+ entity = entity_type.constantize.find(entity_id)
+
+ ::Members::UnassignIssuablesService.new(user, entity).execute
+ end
+ end
+end