Contents

namespace :katello do
  task :reindex => ["environment", "katello:reset_backends:elasticsearch"]  do
    User.current = User.first #set a user for orchestration

    Dir.glob(Katello::Engine.root.to_s + '/app/models/katello/*.rb').each { |file| require file }

    Katello::Util::Search.active_record_search_classes.each do |model|
      puts "Re-indexing #{model.name}"
      model.create_elasticsearch_index
      sub_classes = model.subclasses

      if sub_classes.empty? || !model.column_names.include?('type')
        objects = model.all
      else
        #Index STI subclasses separately
        objects = model.where(:type => ([nil, model.name]))
      end

      model.index.import(objects) if objects.count > 0
    end

    Katello::Util::Search.pulp_backend_search_classes.each do |object_class|
      puts "Re-indexing #{object_class.name}"
      object_class.index_all
    end

    Katello::Erratum.import_all

    puts "Re-indexing Pools"
    Organization.all.each do |org|
      cp_pools = Katello::Resources::Candlepin::Pool.get_for_owner(org.label)
      if cp_pools
        # Pool objects
        pools = cp_pools.collect{ |cp_pool| Katello::Pool.find_pool(cp_pool['id'], cp_pool) }
        # Index pools
        Katello::Pool.index_pools(pools) if pools.length > 0
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
katello-2.2.2	lib/katello/tasks/reindex.rake