summaryrefslogtreecommitdiff
path: root/app/workers/packages/go/sync_packages_worker.rb
blob: e41f27f2252b8ef0cd2c5cc55901b1205aeda8ee (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
# frozen_string_literal: true

module Packages
  module Go
    class SyncPackagesWorker
      include ApplicationWorker
      include Gitlab::Golang

      queue_namespace :package_repositories
      feature_category :package_registry

      deduplicate :until_executing
      idempotent!

      def perform(project_id, ref_name, path)
        project = Project.find_by_id(project_id)
        return unless project && project.repository.find_tag(ref_name)

        module_name = go_path(project, path)
        mod = Packages::Go::ModuleFinder.new(project, module_name).execute
        return unless mod

        ver = Packages::Go::VersionFinder.new(mod).find(ref_name)
        return unless ver

        Packages::Go::CreatePackageService.new(project, nil, version: ver).execute

      rescue ::Packages::Go::CreatePackageService::GoZipSizeError => ex
        Gitlab::ErrorTracking.log_exception(ex)
      end
    end
  end
end