summaryrefslogtreecommitdiff
path: root/app/services/container_expiration_policy_service.rb
blob: 82274fd866889e4377567ea1b49657c0da4bfd33 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
# frozen_string_literal: true

class ContainerExpirationPolicyService < BaseService
  def execute(container_expiration_policy)
    container_expiration_policy.schedule_next_run!

    container_expiration_policy.container_repositories.find_each do |container_repository|
      CleanupContainerRepositoryWorker.perform_async(
        nil,
        container_repository.id,
        container_expiration_policy.attributes
          .except('created_at', 'updated_at')
          .merge(container_expiration_policy: true)
      )
    end
  end
end