summaryrefslogtreecommitdiff
path: root/app/workers/packages/debian/generate_distribution_worker.rb
blob: 68fdd80ffb17c268c4fa2c074d0c7196feb30291 (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
37
38
39
40
41
42
43
44
# frozen_string_literal: true

module Packages
  module Debian
    class GenerateDistributionWorker # rubocop:disable Scalability/IdempotentWorker
      include ApplicationWorker
      include Gitlab::Utils::StrongMemoize

      # The worker is idempotent, by reusing component files with the same file_sha256.
      #
      # See GenerateDistributionService#find_or_create_component_file
      deduplicate :until_executed
      idempotent!

      queue_namespace :package_repositories
      feature_category :package_registry

      loggable_arguments 0

      def perform(container_type, distribution_id)
        @container_type = container_type
        @distribution_id = distribution_id

        return unless distribution

        ::Packages::Debian::GenerateDistributionService.new(distribution).execute
      end

      private

      def container_class
        return ::Packages::Debian::GroupDistribution if @container_type == :group

        ::Packages::Debian::ProjectDistribution
      end

      def distribution
        strong_memoize(:distribution) do
          container_class.find_by_id(@distribution_id)
        end
      end
    end
  end
end