diff options
author | Nick Thomas <nick@gitlab.com> | 2018-11-19 18:03:58 +0300 |
---|---|---|
committer | Nick Thomas <nick@gitlab.com> | 2018-12-06 21:58:00 +0300 |
commit | 9395d198f9b9ec59858d2f316e58cda22ab80050 (patch) | |
tree | 0b494120c8d7d59316d590fada95adcbf0ac23f2 /app/workers/repository_cleanup_worker.rb | |
parent | 79b44c16ccf3827eba6b168aae6c395ac3f3df17 (diff) |
Use BFG object maps to clean projects
Diffstat (limited to 'app/workers/repository_cleanup_worker.rb')
-rw-r--r-- | app/workers/repository_cleanup_worker.rb | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/app/workers/repository_cleanup_worker.rb b/app/workers/repository_cleanup_worker.rb new file mode 100644 index 00000000000..aa26c173a72 --- /dev/null +++ b/app/workers/repository_cleanup_worker.rb @@ -0,0 +1,39 @@ +# frozen_string_literal: true + +class RepositoryCleanupWorker + include ApplicationWorker + + sidekiq_options retry: 3 + + sidekiq_retries_exhausted do |msg, err| + next if err.is_a?(ActiveRecord::RecordNotFound) + + args = msg['args'] + [msg['error_message']] + + new.perform_failure(*args) + end + + def perform(project_id, user_id) + project = Project.find(project_id) + user = User.find(user_id) + + Projects::CleanupService.new(project, user).execute + + notification_service.repository_cleanup_success(project, user) + end + + def perform_failure(project_id, user_id, error) + project = Project.find(project_id) + user = User.find(user_id) + + # Ensure the file is removed + project.bfg_object_map.remove! + notification_service.repository_cleanup_failure(project, user, error) + end + + private + + def notification_service + @notification_service ||= NotificationService.new + end +end |