module Actions
  module Katello
    module Repository
      # Clones the contnet of the repository into the environment
      # effectively promotion the repository to the environment
      class CloneToEnvironment < Actions::Base
        def plan(repository, environment, options = {})
          clone = find_or_build_environment_clone(repository, environment)

          sequence do
            if clone.new_record?
              plan_action(Repository::Create, clone, true, false)
            else
              plan_action(Repository::Clear, clone)
              clone.copy_library_instance_attributes
              clone.save!

              if ::Katello::Repository.needs_distributor_updates([clone], ::Katello::CapsuleContent.new(::SmartProxy.default_capsule)).first
                plan_action(Pulp::Repository::Refresh, clone)
              end
            end

            if repository.yum?
              plan_action(Repository::CloneYumContent, repository, clone, [], false,
                          :force_yum_metadata_regeneration => options[:force_yum_metadata_regeneration])
            elsif repository.docker?
              plan_action(Repository::CloneDockerContent, repository, clone, [])
            elsif repository.ostree?
              plan_action(Repository::CloneOstreeContent, repository, clone)
            elsif repository.file?
              plan_action(Repository::CloneFileContent, repository, clone)
            end
          end
        end

        # The environment clone clone of the repository is the one
        # visible for the systems in the environment
        def find_or_build_environment_clone(repository, environment)
          version = repository.content_view_version
          clone = version.content_view.get_repo_clone(environment, repository).first

          if clone
            clone = ::Katello::Repository.find(clone.id) # reload readonly object
            clone.update_attributes!(content_view_version_id: version.id)
          else
            clone = repository.build_clone(environment: environment, content_view: version.content_view)
          end
          return clone
        end
      end
    end
  end
end