diff options
Diffstat (limited to 'app/services/ci/update_pending_build_service.rb')
-rw-r--r-- | app/services/ci/update_pending_build_service.rb | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/app/services/ci/update_pending_build_service.rb b/app/services/ci/update_pending_build_service.rb new file mode 100644 index 00000000000..dcba06e60bf --- /dev/null +++ b/app/services/ci/update_pending_build_service.rb @@ -0,0 +1,45 @@ +# frozen_string_literal: true + +module Ci + class UpdatePendingBuildService + VALID_PARAMS = %i[instance_runners_enabled].freeze + + InvalidParamsError = Class.new(StandardError) + InvalidModelError = Class.new(StandardError) + + def initialize(model, update_params) + @model = model + @update_params = update_params + + validations! + end + + def execute + return unless ::Feature.enabled?(:ci_pending_builds_maintain_shared_runners_data, @model, default_enabled: :yaml) + + @model.pending_builds.each_batch do |relation| + relation.update_all(@update_params) + end + end + + private + + def validations! + validate_model! && validate_params! + end + + def validate_model! + raise InvalidModelError unless @model.is_a?(::Project) || @model.is_a?(::Group) + + true + end + + def validate_params! + extra_params = @update_params.keys - VALID_PARAMS + + raise InvalidParamsError, "Unvalid params: #{extra_params.join(', ')}" unless extra_params.empty? + + true + end + end +end |