namespace :katello do
  namespace :upgrades do
    namespace '4.4' do
      desc "Republish imported CVs that aren't published"
      task :publish_import_cvvs => ["environment"] do
        ::ForemanTasks.dynflow.config.remote = true
        ::ForemanTasks.dynflow.initialize!

        User.current = User.anonymous_admin

        Katello::Repository.in_content_views(Katello::ContentView.where(:import_only => true)).where(:publication_href => nil).pluck(:content_view_version_id).uniq.each do |cvv_id|
          ForemanTasks.async_task(Actions::Katello::ContentViewVersion::RepublishRepositories, ::Katello::ContentViewVersion.find(cvv_id))
        end
      end
    end
  end
end