summaryrefslogtreecommitdiff
path: root/app/services/ci/runners/bulk_delete_runners_service.rb
blob: ce07aa541c2368821ff760cbf2f7f53d29fd5200 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
# frozen_string_literal: true

module Ci
  module Runners
    class BulkDeleteRunnersService
      attr_reader :runners

      RUNNER_LIMIT = 50

      # @param runners [Array<Ci::Runner, Integer>] the runners to unregister/destroy
      def initialize(runners:)
        @runners = runners
      end

      def execute
        if @runners
          # Delete a few runners immediately
          return ServiceResponse.success(payload: delete_runners)
        end

        ServiceResponse.success(payload: { deleted_count: 0, deleted_ids: [] })
      end

      private

      def delete_runners
        # rubocop:disable CodeReuse/ActiveRecord
        runners_to_be_deleted = Ci::Runner.where(id: @runners).limit(RUNNER_LIMIT)
        # rubocop:enable CodeReuse/ActiveRecord
        deleted_ids = runners_to_be_deleted.destroy_all.map(&:id) # rubocop: disable Cop/DestroyAll

        { deleted_count: deleted_ids.count, deleted_ids: deleted_ids }
      end
    end
  end
end