app/services/merge_requests/migrate_external_diffs_service.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

# frozen_string_literal: true

module MergeRequests
  class MigrateExternalDiffsService < ::BaseService
    MAX_JOBS = 1000.freeze

    attr_reader :diff

    def self.enqueue!
      ids = MergeRequestDiff.ids_for_external_storage_migration(limit: MAX_JOBS)

      MigrateExternalDiffsWorker.bulk_perform_async(ids.map { |id| [id] })
    end

    def initialize(merge_request_diff)
      @diff = merge_request_diff
    end

    def execute
      diff.migrate_files_to_external_storage!
    end
  end
end