Fixes #37552 - container push repo content view support

app/controllers/katello/api/v2/environments_controller.rb

@@ -108,8 +108,7 @@ def update
       update_params[:name] = params[:environment][:new_name] if params[:environment][:new_name]
       @environment.update!(update_params)
       if update_params[:registry_name_pattern] || update_params[:registry_unauthenticated_pull]
-        task = send(async ? :async_task : :sync_task, ::Actions::Katello::Environment::PublishRepositories,
-                    @environment, content_type: Katello::Repository::DOCKER_TYPE)
+        task = send(async ? :async_task : :sync_task, ::Actions::Katello::Environment::PublishContainerRepositories, @environment)
       end
 
       if params.include?(:async) && async && task

app/lib/actions/katello/environment/publish_repositories.rb → app/lib/actions/katello/environment/publish_container_repositories.rb

@@ -1,24 +1,26 @@
 module Actions
   module Katello
     module Environment
-      class PublishRepositories < Actions::EntryAction
+      class PublishContainerRepositories < Actions::EntryAction
         middleware.use ::Actions::Middleware::RemoteAction
 
         input_format do
           param :id
           param :name
         end
 
-        def plan(env, options = {})
-          repositories = options[:content_type] ? env.repositories.with_type(options[:content_type]) : env.repositories
+        def plan(env)
+          repositories = env.repositories.docker_type
           action_subject(env)
           concurrence do
             repositories.each do |repository|
               sequence do
-                repository.set_container_repository_name
-                repository.clear_smart_proxy_sync_histories
-                plan_action(::Actions::Katello::Repository::InstanceUpdate, repository)
-                plan_action(::Actions::Katello::Repository::CapsuleSync, repository)
+                unless repository.root.is_container_push && repository.library_instance?
+                  repository.set_container_repository_name
+                  repository.clear_smart_proxy_sync_histories
+                  plan_action(::Actions::Katello::Repository::InstanceUpdate, repository)
+                  plan_action(::Actions::Katello::Repository::CapsuleSync, repository)
+                end
               end
             end
 
@@ -31,7 +33,7 @@ def rescue_strategy
         end
 
         def humanized_name
-          _("Publish Lifecycle Environment Repositories")
+          _("Publish Lifecycle Environment Container Repositories")
         end
 
         def humanized_input

app/lib/actions/katello/repository/create.rb

@@ -2,7 +2,7 @@ module Actions
   module Katello
     module Repository
       class Create < Actions::EntryAction
-        # rubocop:disable Metrics/MethodLength
+        # rubocop:disable Metrics/MethodLength, Metrics/CyclomaticComplexity
         def plan(repository, args = {})
           clone = args[:clone] || false
           force_repo_create = args[:force_repo_create] || false
@@ -15,7 +15,7 @@ def plan(repository, args = {})
           sequence do
             # Container push repositories will already be in pulp. The version_href is
             # directly updated after a push.
-            unless root.is_container_push
+            unless root.is_container_push && repository.in_default_view?
               create_action = plan_action(Pulp3::Orchestration::Repository::Create,
                                           repository, SmartProxy.pulp_primary, force_repo_create)
               return if create_action.error
@@ -36,7 +36,7 @@ def plan(repository, args = {})
             end
 
             # Container push repos do not need metadata generation or ACS (they do not sync)
-            unless root.is_container_push
+            unless root.is_container_push && repository.in_default_view?
               concurrence do
                 plan_self(:repository_id => repository.id, :clone => clone)
                 if !clone && repository.url.present?

app/lib/actions/katello/repository/metadata_generate.rb

@@ -3,6 +3,7 @@ module Katello
     module Repository
       class MetadataGenerate < Actions::EntryAction
         def plan(repository, options = {})
+          return if repository.root.is_container_push && repository.library_instance?
           action_subject(repository)
           repository.check_ready_to_act!
           source_repository = options.fetch(:source_repository, nil)

app/lib/actions/pulp3/orchestration/repository/copy_all_units.rb

@@ -32,6 +32,10 @@ def plan(target_repo, smart_proxy, source_repositories, options = {})
                   plan_action(Actions::Pulp3::Repository::SaveVersion, target_repo, tasks: copy_actions.last.output[:pulp_tasks])
                 end
               end
+            elsif source_repositories.first.root.is_container_push
+              copy_action = plan_action(Actions::Pulp3::Repository::CopyContent, source_repositories.first, smart_proxy, target_repo,
+                                        copy_all: true)
+              plan_action(Actions::Pulp3::Repository::SaveVersion, target_repo, tasks: copy_action.output[:pulp_tasks])
             else
               plan_self(source_version_repo_id: source_repositories.first.id,
                         target_repo_id: target_repo.id)

app/lib/actions/pulp3/orchestration/repository/delete.rb

@@ -9,10 +9,13 @@ def plan(repository, smart_proxy)
               plan_action(Actions::Pulp3::Repository::DeleteDistributions, repository.id, smart_proxy)
 
               if repository.content_view.default?
-                #we're deleting the library instance, so just delete the whole pulp3 repo
+                # Container push repositories must be deleted through the distribution
+                return if repository.root.is_container_push
+
+                # We're deleting the library instance, so just delete the whole pulp3 repo
                 plan_action(Actions::Pulp3::Repository::Delete, repository.id, smart_proxy)
               elsif repository.environment.nil?
-                #we're deleting the archived instance, so delete the version
+                # We're deleting the archived instance, so delete the version
                 plan_action(Actions::Pulp3::Repository::DeleteVersion, repository, smart_proxy)
               end
             end

app/services/katello/pulp3/api/docker.rb

@@ -19,6 +19,16 @@ def recursive_add_api
         def container_push_api
           PulpContainerClient::RepositoriesContainerPushApi.new(api_client)
         end
+
+        def container_push_repo_for_name(name)
+          # There should be only one repository in Pulp with the requested name
+          container_push_api.list(name: name)&.results&.first
+        end
+
+        def container_push_distribution_for_repository(repository_href)
+          # There should be only one repository in Pulp with the requested repository_href
+          distributions_api.list(repository: repository_href)&.results&.first
+        end
       end
     end
   end

test/actions/katello/environment_test.rb

@@ -14,6 +14,26 @@ class TestBase < ActiveSupport::TestCase
     end
   end
 
+  class PublishContainerRepositoriesTest < TestBase
+    let(:action_class) { ::Actions::Katello::Environment::PublishContainerRepositories }
+    let(:action) { create_action action_class }
+
+    let(:environment) { stub }
+
+    it 'does not plan for container push library repos' do
+      container_push_repo = ::Katello::RootRepository.find_by(name: 'busybox').library_instance
+      container_push_repo.root.update(is_container_push: true)
+      environment.stubs(:repositories).returns(::Katello::Repository.where(id: container_push_repo.id))
+      container_push_repo.expects(:set_container_repository_name).never
+      container_push_repo.expects(:clear_smart_proxy_sync_histories).never
+      action.stubs(:action_subject).with(environment)
+
+      plan_action(action, environment)
+      refute_action_planned(action, ::Actions::Katello::Repository::InstanceUpdate)
+      refute_action_planned(action, ::Actions::Katello::Repository::CapsuleSync)
+    end
+  end
+
   class DestroyTest < TestBase
     let(:action_class) { ::Actions::Katello::Environment::Destroy }
     let(:action) { create_action action_class }